루프 내에서 C++ std :: thread synchronization

Question

스레드 동시성 할당을 위해 std :: thread를 선택하여 실수를했습니다. 나는 다른 어떤 방법을 배울 시간이 없다. 그래서 당신이 저를 여기서 도울 수 있기를 바랍니다. 나는 mutexes, promises, futures 등 모든 유형에 대해 정말로 혼란스러워합니다. 다양한 문서/튜토리얼의 부족은 우울합니다. 그래서 3 개의 스레드 (플레이어)가 동일한 작업을 수행하기를 원합니다. 전역 2 차원 배열의 인덱스로 2 개의 난수를 선택하고, 셀의 값이 0이면 스레드의 ID와 같게 설정하고 그렇지 않으면 실. 스레드가 하나만 남을 때까지 반복하십시오. 내가 필요로하는 것은 3 개의 스레드를 매번 (다음에 가기 전에) 반복하는 방법을 찾아서 하나의 스레드가 50 번째 반복에있을 수없고 다른 하나는 30 번째에있을 수 없다는 것, 즉 스레드는 계속 진행하기 전에 모든 다른 사람들이 반복을 완료 할 때까지 기다리십시오. 나는 어떤 종류의 장벽이 필요합니다. 마지막 종료 스레드가 깨어 신호를 낼 때까지 스레드를 잠자기 상태로 놓으려고 시도했지만 상태가 정상적으로 작동하지 않습니다. 나는 모든 반복에 (먼저 도래) 하나의 스레드에 의해 실행되는 "call_once"것은 내부의 표현을 기대

std::mutex GridMutex, FinishMutex, LeftMutex; 
int Grid[X][Y], Finished = 0, PlayersLeft = 3; 

void Fight(int Id) { 
    int RandX, RandY, i = 0; 
    std::random_device rd; // access random device 
    std::mt19937 e(rd()); // seed the engine 
    std::uniform_int_distribution<int> r1(0, X-1); 
    std::uniform_int_distribution<int> r2(0, Y-1); 
    LeftMutex.lock(); // mutex on PlayersLeft 
    while (PlayersLeft != 1) { 
    ++i; 
    /*std::call_once(flag, [Id, i](){*/std::cout << " Round " << i << " Left: " << PlayersLeft << '\n';/*});*/ 
    LeftMutex.unlock(); 
//  FinishMutex.lock(); 
//  std::call_once(flag, [](){Finished = 0;}); 
//  FinishMutex.unlock(); 
    RandX = r1(e); 
    RandY = r2(e); 
    GridMutex.lock(); 
    if (Grid[RandX][RandY] != Id) { 
     if (Grid[RandX][RandY] == 0) { 
     Grid[RandX][RandY] = Id; 
     std::cout << "i= "<< i << " Thread " << Id << " occupied cell " << RandX << RandY << '\n'; 
     std::chrono::milliseconds sleepDuration(100); 
     std::this_thread::sleep_for(sleepDuration); //just to lock the grid for some time 
     GridMutex.unlock(); 
     } 
     else { 
     GridMutex.unlock(); 
     LeftMutex.lock(); 
     --PlayersLeft; 
     LeftMutex.unlock(); 
     break; //stop thread if cell occupied 
     } 
    } 
    //Wait for the others here 
//  FinishMutex.lock(); 
//  ++Finished; 
//  if (Finished == 3) { 
//  FinishMutex.unlock(); 
//  AllReady.notify_all(); 
//  } 
//  else { 
//  FinishMutex.unlock(); 
//  AllReady.wait(Lk, [](){return Finished == 3;}); 
//  Lk.unlock(); 
//  } 
    LeftMutex.lock(); 
    } 
} 
int main() { 
    SetGrid(); 
    std::thread t1(&Fight, 1); 
    std::thread t2(&Fight, 2); 
    std::thread t3(&Fight, 3); 
    t1.join(); 
    t2.join(); 
    t3.join(); 
    GetGrid(); 
    return 0; 
} 

하지만 obiviously 내가 그것 때문에 무슨 생각이 아니다 : 내 실패한 시도가 주석 처리되어 그것은 이상한 행동을 초래합니다. 그렇게하는 방법? 자, 코드가 추악 할 수도 있고 클래스와 메소드 또는 다른 것들 안에 넣어 두어야 할 수도 있습니다. 그러나이 코드는 아무리 중요하게 생각해도됩니다. 미리 감사드립니다.

Answer 1

당신은 잠금을하지 않는 것과

다음. std::atomic_int 및 std::atomic_bool (또는 std::atomic_flag 같은 atomic variables를 사용하여 일부 잠금을 제거하고 자신의 잠금을 해제하지만 std::lock_guard처럼,이에 대한 RAII 래퍼를 사용할 수 있습니다.이 잠 깁니다 잠금 객체 자체가 파괴 될 때까지 지정된 뮤텍스 (대개 범위를 벗어날 때)

이제 이러한 것들을 사용하면 코드가 크게 향상되지만 실제 논리 오류는 매우 간단합니다. 상수 3이 아니라 playersLeft입니다. 조건은 이것에 의존합니다.이 변수를 변경할 때마다 신호를 보내야합니다.