イベントを使用してスレッドを同期する

Question

イベントを使用してスレッドを同期するのは初めてです。私のコードは正常に動作します。しかし私が経験したように、それは上手く見えるかもしれませんが、私が大きなプロジェクトでこのコンセプトを使用すると、本当に見つけにくいバグがあります。

スレッドを同期するためにこのようなイベントを使用する方法がうまくいくかどうかを尋ねたいだけです。

私たちはメインスレッドからのみ呼び出すことができるGetSymbol関数を持っているということです。サーバースレッドは、この関数の結果をメインスレッドに問い合わせる必要があります。

#include <windows.h> 
#include <process.h> 
#include <stdio.h> 

HANDLE symbol_need, symbol_ready, end; 

int symbol_container; 

int GetSymbol() 
{ 
    // Only main thread can use this function. 
    static int i = 0; 
    return ++i; 
} 

void Server(void* p) 
{ 
    printf("Ask for first symbol.\n"); 
    SetEvent(symbol_need); 

    DWORD wait_result; 

    wait_result = WaitForSingleObject(symbol_ready, INFINITE); 
    if(WAIT_OBJECT_0 == wait_result) 
    { 
     ResetEvent(symbol_ready); 
     printf("First symbol: %i\n", symbol_container); 
    } else { 
     printf("Something went wrong.\n"); 
    } 

    printf("Ask for second symbol.\n"); 
    SetEvent(symbol_need); 

    wait_result = WaitForSingleObject(symbol_ready, INFINITE); 
    if(WAIT_OBJECT_0 == wait_result) 
    { 
     ResetEvent(symbol_ready); 
     printf("Second symbol: %i\n", symbol_container); 
    } else { 
     printf("Something went wrong.\n"); 
    } 

    printf("OK, finish it."); 
    SetEvent(end); 
} 


int main(int argc, char* argv[]) 
{ 
    symbol_need = CreateEvent(NULL, FALSE, FALSE, NULL); 
    symbol_ready = CreateEvent(NULL, FALSE, FALSE, NULL); 
    end = CreateEvent(NULL, FALSE, FALSE, NULL); 

    _beginthread(Server, 0, NULL); 

    DWORD wait_result; 

    while(1) 
    { 
     wait_result = WaitForSingleObject(symbol_need, 100); 
     if(WAIT_OBJECT_0 == wait_result) 
     { 
      ResetEvent(symbol_need); 
      symbol_container = GetSymbol(); 
      SetEvent(symbol_ready); 
     } 
     wait_result = WaitForSingleObject(end, 100); 
     if(WAIT_OBJECT_0 == wait_result) 
     { 
      break; 
     } 
    } 
    return 0; 
} 

Answer 1

はい、このコードは正しいです。

この例は、イベントの仕組みを確認するのに便利です。しかし、生産コードを書くときには、ホイールを改革する必要はありません。例えば、説明したインタラクションは、Intel TBBライブラリーのような同時データ構造を使用してエレガントにモデル化することができます。 concurrent_bounded_queue。