4

次のように定義されたクラスがあります。これは完全ではなく、おそらくコンパイルされません。

class Server
{
public:
  Server();
  ~Server();

  class Worker
  {
  public: 
    Worker(Server& server) : _server(server) { }
    ~Worker() { }

    void Run() { }
    void Stop() { }

  private:  
    Server& _server;
  }


  void Run()
  {
    while(true) {
       // do work
    }
   }

  void Stop()
  {
     // How do I stop the thread?
  }

private:
  std::vector<Worker> _workers;
};

私の質問は、サーバーという名前の外部クラスを渡すワーカー配列をどのように初期化するかです。

私が欲しいのは、ワーカースレッドのベクトルです。各ワーカー スレッドには独自の状態がありますが、他の共有データにアクセスできます (表示されていません)。また、スレッドを作成するにはどうすればよいですか。クラス オブジェクトが最初に作成されるとき、または外部で thread_group から作成される必要があります。

また、スレッドをクリーンかつ安全にシャットダウンするにはどうすればよいですか?

編集：

次のように Worker を初期化できるようです。

Server::Server(int thread_count) 
  : _workers(thread_count), Worker(*this)), _thread_count(thread_count) { }

そして、私は現在、スレッドを作成するために Server::Run でこれを行っています。

boost::thread_group _threads; // a Server member variable 

Server::Run(){
   for (int i = 0; i < _thread_count; i++)
     _threads.create_thread(boost::bind(&Server::Worker::Run, _workers(i)));

   // main thread.
   while(1) {  
       // Do stuff
   }

   _threads.join_all();
}

誰もこれに問題があると思いますか? 安全なシャットダウンはどうですか？

編集: 私が見つけた問題の 1 つは、Worker オブジェクトが構築されていないように見えることです! おっとっと。はい、Worker クラスにコピー コンストラクターが必要です。

しかし奇妙なことに、スレッドを作成すると、Worker のコピー コンストラクターが複数回呼び出されます。

4

2 に答える 2

1

私は純粋なWINAPIでそれを行いました。見てください：

#include <stdio.h>
#include <conio.h>
#include <windows.h>
#include <vector>

using namespace std;

class Server
{

public:

    class Worker
    {
        int     m_id;
        DWORD   m_threadId;
        HANDLE  m_threadHandle;
        bool    m_active;

        friend Server;

    public:

        Worker (int id)
        {
            m_id = id;
            m_threadId = 0;
            m_threadHandle = 0;
            m_active = true;
        }

        static DWORD WINAPI Run (LPVOID lpParam)
        {
            Worker* p = (Worker*) lpParam;      // it's needed because of the static modifier

            while (p->m_active)
            {
                printf ("I'm a thread #%i\n",  p->m_id);
                Sleep (1000);
            }

            return 0;
        }

        void Stop ()
        {
            m_active = false;
        }
    };

    Server ()
    {
        m_workers = new vector <Worker*> ();
        m_count = 0;
    }

    ~Server ()
    {
        delete m_workers;
    }

    void Run ()
    {
        puts ("Server is run");
    }

    void Stop ()
    {
        while (m_count > 0)
            RemoveWorker ();

        puts ("Server has been stopped");
    }

    void AddWorker ()
    {
        HANDLE  h;
        DWORD   threadId;

        Worker* n = new Worker (m_count ++);
        m_workers->push_back (n);

        h = CreateThread (NULL, 0, Worker::Run, (VOID*) n, CREATE_SUSPENDED, &threadId);
        n->m_threadHandle = h;
        n->m_threadId = threadId;
        ResumeThread (h);
    }

    void RemoveWorker ()
    {
        HANDLE  h;
        DWORD   threadId;

        if (m_count <= 0)
            return;

        Worker* n = m_workers->at (m_count - 1);
        m_workers->pop_back ();

        n->Stop ();
        TerminateThread (n->m_threadHandle, 0);

        m_count --;

        delete n;
    }

private:

    int                 m_count;
    vector <Worker*>*   m_workers;
};

int main (void)
{
    Server  a;
    int     com = 1;

    a.Run ();

    while (com)
    {
        if (kbhit ())
        {
            switch (getch ())
            {
            case 27:        // escape key code

                com = 0;
                break;

            case 'a':       // add worker

                a.AddWorker ();
                break;

            case 'r':       // remove worker

                a.RemoveWorker ();
                break;

            }
        }
    }

    a.Stop ();

    return 0;
}

ここには同期コードはありません。これを行うには十分な時間がないためです...しかし、お役に立てば幸いです =)

于 2010-11-10T07:58:53.497 に答える
0

ブーストasioをまったく見たことがありますか？あなたがやろうとしていることにぴったりのようです。さらに、ブースト asio の io_service の実行 (Run メソッドと同様) を多くのスレッドから呼び出すことができます。つまり、多くのスレッドで IO を処理できます。asio ベースのスレッドプールのhttp://think-async.com/Asio/Recipesも興味深いかもしれません。

asioの例を見てください。おそらく、彼らはあなたがやろうとしていることを処理する別の方法を提供します. 特に。クリーンなシャットダウンがどのように達成されるかを見てください。

于 2010-11-09T11:03:25.927 に答える