뮤텍스를 사용하여 한 번에 실행되는 스레드 수를 제한합니다. 2

Question

나는 10 개의 스레드를 벡터로 푸시하는 프로그램이 있습니다. 각 스레드는 완료 전에 문자를 5 번 인쇄합니다 ('A'는 첫 번째 스레드, 두 번째 스레드의 'B'등). 나는 한 번에 (detach()를 사용하여) 모두 실행 시키거나 한번에 하나씩 (join()을 사용하여) 실행할 수있다. 이제 뮤텍스를 사용하여 한 번에 2 장까지 인쇄 할 수있는 스레드 수를 제한하려고합니다. 뮤텍스를 선언하고 잠금을 설정했지만이 제한을 적용하는 방법을 잘 모르겠습니다. . 누구든지 진행 방법에 대한 아이디어가 있습니까?

deque<int> q ; 
mutex print_mutex ; 
mutex queue_mutex ; 
condition_variable queue_cond ; 

void begin(int num) { 
    unique_lock<mutex> ul {queue_mutex}; 
    q.emplace_back(num); 
    queue_cond.wait(ul,[num]{ 
     return q.front() == num; }); 
    q.pop_front(); 
    cout << num << " leaves begin " << endl ; 
} 

void end (int num) { 
    lock_guard<mutex>lg{queue_mutex}; 
    queue_cond.notify_all(); 
    cout << num << " has ended " << endl ; 
} 

void run(int num, char ch) { 
    begin(num); 
    for (int i = 0; i < 5; ++i) { 
     { 
      lock_guard<mutex> lg { print_mutex }; 
      cout << ch << endl << flush ; 
     } 
     sleep_for(milliseconds(250)); 
    } 
    end(num); 
} 

int main() { 
    vector<thread>threads {}; 
    for (int i = 0; i < 10; ++i) { 
     threads.push_back(thread{run,i,static_cast<char>(65+i)}); 
     threads.at(i).join(); 
    } 
} 

Answer 1

당신은 이미 글로벌 deque<int> q와 스레드에 대한 FIFO를 설정했습니다. 그래서 그것을 사용합시다.

현재 현재 스레드가 전면에 위치 할 때까지 실행을 제한하려고합니다. begin은 즉시 deque에서 해당 스레드를 팝하기 때문에 버그가 있습니다. end으로 전화 할 때 값을 삭제하는 것이 좋습니다. 여기서 첫째, 그 변화의 :이 특정 값을 제거하는 <algorithm>에서 std::find를 사용

void end(int num) 
{ 
    { 
     lock_guard<mutex>lg{queue_mutex}; 
     cout << num << " has ended " << endl ; 
     q.erase(find(q.begin(), q.end(), num)); 
    } 
    queue_cond.notify_all(); 
} 

. pop_front을 사용할 수는 있지만,이 로직을 변경하여 더 일반적인 것입니다. 또한 통지 할 때 조건 변수를 잠그지 않아도됩니다.

begin의 로직을 처음 두 위치로 확장하는 것은 그리 중요하지 않습니다. 여기 :

void begin(int num) 
{ 
    unique_lock<mutex> ul {queue_mutex}; 
    q.emplace_back(num); 
    queue_cond.wait(ul,[num]{ 
     auto end = q.begin() + std::min(2, static_cast<int>(q.size())); 
     return find(q.begin(), end, num) != end; 
     }); 
    cout << num << " leaves begin " << endl ; 
} 

당신은 통과 많은 스레드까지 가능, 그 2 당신이 원하는 무엇이든을 변경할 수 있습니다. 언젠가는이 접근법을 포기하고 단일 카운터 변수처럼 더 단순한 것을 사용하고 스레드 스케줄러를 사용하여 FIFO에 강제로 넣는 대신 어떤 스레드가 깨어 있는지 관리 할 수 ​​있습니다. 그렇게하면 notify_one을 사용하여 단일 스레드를 깨우고 스위칭 오버 헤드를 줄일 수 있습니다.

어쨌든 마지막으로 할 일은 스레드 생성 루프에서 join을 제거하는 것입니다. 동시성은 이제 begin 및 end에 의해 관리됩니다. 따라서 다음을 수행하십시오.

for (int i = 0; i < 10; ++i) { 
    threads.push_back(thread{run, i, 'A'+i}); 
} 
for (auto & t : threads) t.join();