수동으로 부스트 잠금을 해제 하시겠습니까?

Question

boost :: thread의 조합법을 배우기 위해 공통 뮤텍스 (M)를 잠그는 스레드에 간단한 장벽 (BR)을 구현했습니다. 그러나 BR.wait()에 갈 때 뮤텍스의 잠금은 해제되지 않으므로 모든 스레드가 BR에 도착하도록하려면 M에 대한 잠금을 수동으로 해제해야합니다. 그래서 나는 다음과 같은 코드가 있습니다 :

boost::barrier BR(3); 
boost::mutex M; 

void THfoo(int m){ 
    cout<<"TH"<<m<<" started and attempts locking M\n"; 
    boost::lock_guard<boost::mutex> ownlock(M); 

    cout<<"TH"<<m<<" locked mutex\n"; 
    Wait_(15); //simple wait for few milliseconds 

    M.unlock(); //probably bad idea 
    //boost::lock_guard<boost::mutex> ~ownlock(M); 
    // this TH needs to unlock the mutex before going to barrier BR 

    cout<<"TH"<<m<<" unlocked mutex\n"; 
    cout<<"TH"<<m<<" going to BR\n"; 
    BR.wait(); 
    cout<<"TH"<<m<<" let loose from BR\n"; 
} 

int main() 
{ 
    boost::thread TH1(THfoo,1); 
    boost::thread TH2(THfoo,2); 
    boost::thread TH3(THfoo,3); 

    TH2.join(); //but TH2 might end before TH1, and so destroy BR and M 
    cout<<"exiting main TH \n"; 

    return 0; 
} 

M.unlock()가 명확하게 (잠금을 사용하지 않는) 나쁜 솔루션입니다 반면; 그래서 (단순히) 자물쇠를 해제하는 방법? 또한 : 어떻게 maint()에서 (모든) 스레드가 완료 될 때까지 (올바르게) 기다려야합니까? (TH2.join()이 나쁘다. 왜냐하면 TH2가 먼저 끝날 수 있기 때문이다.);

다음과 같은 내용을 제안하지 마십시오. 조건부 변수를 사용할 수도 있지만, 직접 변수없이 수행 할 수 있어야합니다.

Answer 1

뭔가 같은 :

이

void THfoo(int m){ 
    // use a scope here, this means that the lock_guard will be destroyed (and therefore mutex unlocked on exiting this scope 
    { 
    cout<<"TH"<<m<<" started and attempts locking M\n"; 
    boost::lock_guard<boost::mutex> ownlock(M); 

    cout<<"TH"<<m<<" locked mutex\n"; 
    Wait_(15); //simple wait for few milliseconds 

    } 
    // This is outside of the lock 
    cout<<"TH"<<m<<" unlocked mutex\n"; 
    cout<<"TH"<<m<<" going to BR\n"; 
    BR.wait(); 
    cout<<"TH"<<m<<" let loose from BR\n"; 
} 

대기에 관해서는, 단순히 이미 완료 한 경우 (모든 스레드 핸들에 가입 호출합니다 기능은

Answer 2

이 범위를 벗어나 가자 :

void THfoo(int m){ 
    cout<<"TH"<<m<<" started and attempts locking M\n"; 
    { 
     boost::lock_guard<boost::mutex> ownlock(M); 

     cout<<"TH"<<m<<" locked mutex\n"; 
     Wait_(15); //simple wait for few milliseconds 
    } 

    // this TH needs to unlock the mutex before going to barrier BR 

    cout<<"TH"<<m<<" unlocked mutex\n"; 
    cout<<"TH"<<m<<" going to BR\n"; 
    BR.wait(); 
    cout<<"TH"<<m<<" let loose from BR\n"; 
} 

Answer 3

cout<<"TH"<<m<<" started and attempts locking M\n"; 
{ 
    boost::lock_guard<boost::mutex> ownlock(M); 

    cout<<"TH"<<m<<" locked mutex\n"; 
    Wait_(15); //simple wait for few milliseconds 

} //boost::lock_guard<boost::mutex> ~ownlock(M); 
// this TH needs to unlock the mutex before going to barrier BR 

cout<<"TH"<<m<<" unlocked mutex\n"; 

) 즉시 반환한다3210

모든 스레드가 join 인 경우 TH2가 처음 완료 될 때 유일한 문제는 TH2가 join에 의해 "수확 될"수 있고 반환 값과 같은 남은 리소스가 해제되기 전에 TH1이 실행을 완료해야한다는 것입니다. 3 개의 스레드에 대해 걱정할 필요가 없습니다. 메모리 사용이 문제가 있다면 timed_join을 사용하여 차례로 모든 스레드를 반복적으로 시도 할 수 있습니다.

또한 주 스레드가 조건 변수를 기다리고, 각 스레드가 완료되면 완료 될 때까지 값을 저장하고 주 변수가 주 변수를 전달할 수 있도록 신호를 보냅니다. 쓰레드는 join입니다. 스레드가 신호를 보낼 것이라는 것을 절대 확신해야합니다. 그렇지 않으면 영원히 기다릴 수 있습니다. 따라서 스레드를 취소하는 경우 조심하십시오.

Answer 4

boost :: lock_guard 대신 boost :: mutex :: scoped_lock을 사용하면 unlock() 메소드가 있습니다. 호출하면 잠금은 소멸자에서 다시 잠금 해제를 시도하지 않습니다. 자물쇠를 자체 블록에 배치하는 것보다 코드를 더 맛있게 보았습니다.

Answer 5

블록에 boost::lock_guard 범위를 지정하는 것 외에도, 당신은 또한 'unlock() 될 수 boost::unique_lock 명시 적으로 에드 사용할 수 있습니다 나중에 재 취득하기 전에 뮤텍스를 해제해야하는 경우

boost::unique_lock<boost::mutex> ownlock(M); 

cout<<"TH"<<m<<" locked mutex\n"; 
Wait_(15); //simple wait for few milliseconds 

ownlock.unlock(); 

이 유용합니다.

가입의 경우 모든 스레드 핸들에서 차례대로 join()을 호출하면됩니다.