C++でメインスレッドの関数をセカンダリスレッドで実行している関数から実行することはできますか？

Question

例えば、私はメインスレッドを持っています、クラスなどがたくさん作成されています。私は別のスレッドでクライアントデータを待つネットワーク部分を持っています。この「ウェイター」は、メインスレッドで作成されたクラスからいくつかの関数を実行する必要があり、この関数はメインスレッドで実行する必要があります。

どうすればいいですか？私が必要としている方法をこのように呼び出すなら、ウェイターからのSomeClass::SomeMethod(some_args);、彼らはセカンダリスレッドで実行されます。

このようなものがありますか？ SomeClass::Invoke(function_pointer);ですから、function_pointerがポイントする機能はメインスレッドで実行されますか？私はWindows OSのアドバイスが必要です。

Answer 1

これがWindowsのWin32アプリケーションの場合、アプリケーションのメッセージ処理キューを使用するのが一般的なアプローチです。コンソールアプリケーションの場合

(in header file) 
#define WM_MYCUSTOMMESSAGE (WM_USER + 1) 

(WndProc for you main window) 
LRESULT WndProc(HWND hWnd, UINT message, WPARAM wParam, LPARAM lParam) 
{ 
    switch(msg) 
    { 
    case WM_MYCUSTOMMESSAGE: 
     ... Process something 
     break; 
    } 
} 

(On seconday thread) 
SendMessage(hWnd, WM_MYCUSOMMESSAGE, wParam, lParam); // Send and wait for the result 

PostMessage(hWnd, WM_MYCUSTOMMESSAGE, wParam, lParam); // Send the message and continue this thread. 

[EDIT] 、Windowsのイベントを使用してみてください：あなたは、カスタム・ユーザー・メッセージを待つのアプリのメインウィンドウで は、一般的にそれが何かのようになります。したがって、名前付きイベントを作成するには、次のようにしてください。

(On primary thread) 
HANDLE myEvent = CreateEvent(NULL, FALSE, FALSE, "MyEvent"); 

... later as part of a message processing loop 
while(true) 
{ 
    WaitForSingleObject(myEvent, 0); // Block until event is triggers in secondary thread 

    ... process messages here 
    ... I recommend storing "messages" in a synchronized queue 
} 

(On secondary thread) 
SetEvent(myEvent); // Triggers the event on the main thread. 

Answer 2

呼び出されたとしても、関数は呼び出されたスレッドで実行されるため、使用しません。

セカンダリスレッドで解放されたメインスレッドでループ内にビジー待機またはミューテックスを持つことができます。解放されると、3変数の値に応じていくつかのメソッドが呼び出されます。

//thread1 
runThread2(); 
while (true) 
{ 
    mutex.acquire(); 
    mutex.lock(); 
    switch(command) 
    { 
     case command_noop: 
     sleep(1000); 
     break; 
     case command1: 
     foo1(); 
     break; 
     case command2: 
     foo2(); 
     break; 
     //and so on... 
    } 
    mutex.release(); 
} 

//thread2: 
mutex.lock(); 
//commands 
command = 1; 
mutex.release(); 
mutex.acquire(); 
//rest of commands