継承を使用したマルチスレッド化（C++）

Question

新しいスレッドで「実行」関数を呼び出そうとしています。今、私はこのコードを実際には新しいスレッドで "Run"を実行しないopenMPを使用しています。注：私はOpenMPを使用して助けを求めていません。このコードはちょうど簡単な修正でした。私はこれについて行くのCreateThread（）メソッドを好むだろう。

vector<ICommand*>* commands; 
string strInput; 
// For each command... 
for(vector<ICommand*>::iterator i = commands->begin(); i != commands->end(); ++i) 
{ 
    // ...if the current command we're examining is valid... 
    if((*i)->ContainsCommand(strInput)) 
    { 
     // ...run it in a new thread and don't let ZChatInput handle it normally... 
     #pragma omp sections nowait 
     { 
     #pragma omp section 
      (*i)->Run(strInput); 
     #pragma omp section 
      bRet = false; 
     } 

     // ...and don't check any more commands. 
     break; 
    } 

} 

これは、標準とSTLだけを使用してどのように行われますか？もちろん、私は動作する方法を探しています:)

Answer 1

だから、私はMSDNのドキュメントをダブルチェックした後にそれを理解しました。あなたが興味を持っている場合は、どうやってやったのですか。

static vector<ICommand*>* commands; 
// This is what we pass to CommandOnThread. 
struct CommandParameter 
{ 
    string strInput; 
    ICommand* command; 
}; 

int CommandOnThread(CommandParameter* cp) 
{ 
    cp->command->Run(cp->strInput); 
    delete cp; 

    return 0; 
} 

void foo() 
{ 
    string strInput; 
    ... 
    // For each command... 
    for(vector<ICommand*>::iterator i = commands->begin(); i != commands->end(); ++i) 
    { 
     // ...if the current command we're examining is valid... 
     if((*i)->ContainsCommand(strInput)) 
     { 
      // Put the CP on the stack. 
      CommandParameter* temp = new CommandParameter; 
      if(temp == NULL) 
      { 
       Print("Out of memory!"); 
       bRet = false; 
       break; 
      } 

      // ...set up the parameters to createthread... 
      temp->strInput = strInput; 
      temp->command = *i; 

      // ...run it in a new thread... 
      CreateThread(NULL, NULL, (LPTHREAD_START_ROUTINE)CommandOnThread, temp, NULL, NULL); 

      // ...and don't check any more commands. 
      bRet = false; 
      break; 
     } 
    } 
} 

Answer 2

Boost.Threadの使い方はどうですか？

if((*i)->ContainsCommand(strInput)) 
{ 
    boost::thread t(boost::bind(&ICommand::Run, *i)); 
} 

これは、分離スレッドで "実行"を実行します。 （これはテストしていないことに注意してください）

Answer 3

本当にコマンドごとにスレッドを作成しますか？スレッドの作成は高価です。 この部分が非同期である必要がある場合 - 同期化されたキューを作成するには、事前に生成されたスレッド数（スケーラビリティ）をキューでブロックし、 。

 
// setup 
sync_queue wq; // that would be protected by mutex and a conditional var or two 
for (i = 0; i < parallel_factor; ++i) start_thread(th_func, wq); 
... 

// your loop body : 
    ... 
    if (valid_input) q.put(item); 
    ... 

// thread function 
void th_func(sync_queue& q) 
{ 
    work_item* pwi; 
    while ((pwi = q.get())) do_it(pwi); 
} 

は理にかなって：

あなたのコメントに答えますか？

Answer 4

このような？このため

vector<ICommand*>* commands; 
string strInput; 

void CommandOnThread(void* command) 
{ 
    (ICommand*)command->Run(); 
} 

// For each command... 
for(vector<ICommand*>::iterator i = commands->begin(); i != commands->end(); ++i) 
{ 
    // ...if the current command we're examining is valid... 
    if((*i)->ContainsCommand(strInput)) 
    { 
     //Attach the input to the command 
     (*i)->AttachInput(strInput); 
     _beginthread(CommandOnThread, 0, *i); 
     break; 
    } 
} 

あなたはわずか2つのステップでコマンド入力を渡すためのコマンド・インタフェースを変更する必要があります：最初のコマンドオブジェクトに入力を保存し、呼び出すhttp://msdn.microsoft.com/en-us/library/kdzttdcb(VS.80).aspx

Answer 5

あなたはこのような何かを試すことができます引数なしでRun（）を実行します。あなたが似ているのが好きなら、_beginthreadをCreateThreadに置き換えることができます。

明確にする：_beginthread（またはCreateThread）の関数パラメータとしてインスタンスメソッドを使用することはできません。上記の解決策は、オブジェクト（コマンド）を関数に渡し、そのインスタンスメソッド（実行）を呼び出すことです。しかし、この場合、スレッド関数に余分な引数を渡すことはできません。したがって、引数をインスタンスメソッドに渡すことはできません。このための最も簡単な解決策は、スレッド関数に渡す前に、引数をインスタンスに何らかの形で添付することです。

こちらがお役に立てば幸いです。もちろん、Commandクラスのインタフェースと実装を変更できない場合、この解決策は不可能です。