[C++] barrier

개요

• 알려진 크기의 스레드 그룹이 barrier에 도달할때까지 차단하는 스레드 조정 메커니즘 제공
• 소멸자를 제외한 멤버 함수를 동시 호출해도 데이터 경합 없음
• latch와의 차이점
  • 재사용 가능
    • 스레드 그룹이 차단 해제된 경우
    • 카운트는 생성 시 설정된 값에서 arrive_and_drop 호출 수를 뺀 값으로 재설정
  • 차단 해제전에 callable 실행
• 멤버 함수
  • arrive()
    • barrier에 도달하고 카운트 감소
  • wait()
    • callable이 실행될 때까지 차단
  • arrive_and_wait()
    • barrier에 도달하고 카운트 감소 후 차단
  • arrive_and_drop()
    • barrier에 도달하고 설정 카운트와 현재 카운트를 감소
  • max()
    • 카운트의 최대값

예제

• 코드

   #include <barrier>
   #include <future>
   #include <iostream>
   #include <string>
   #include <vector>
      
   using namespace std;
      
   int main() {
   	vector<string> datas = {"a", "b", "c"};
      
   	barrier done(ssize(datas), []() {
   		static string s = "done1\n";
      
   		cout << s;
      
   		s = "done2\n";
   	});
      
   	auto run = [&done](string s) {
   		cout << s + " start" << endl;
      
   		done.arrive_and_wait();
      
   		cout << s + " end" << endl;
      
   		done.arrive_and_wait();
   	};
      
   	vector<future<void>> futures;
      
   	for (const auto &iter : datas) {
   		futures.push_back(async(
   			launch::async, [run](string s) { run(s); }, iter));
   	}
      
   	for (auto &iter : futures) {
   		iter.get();
   	}
      
   	return 0;
   }
  

• 실행 결과

   a start
   b start
   c start
   done1
   c end
   a end
   b end
   done2