C++: latch

개요

• 스레드를 동기화 하는데 사용하는 하향 카운터
• 카운터 값은 생성 시 초기화
• 카운터가 0으로 감소할 때까지 차단
• barrier와 달리 재사용 불가
• 소멸자를 제외한 멤버 함수를 동시 호출해도 데이터 경합 없음
• 멤버 함수
  • count_down()
    • non-blocking 방식으로 카운터를 감소
  • try_wait()
    • 카운터가 0인지 확인
  • wait()
    • 카운터가 0이 될 때까지 차단
  • arrive_and_wait()
    • 카운터를 감소시키고 0이 될 때까지 차단
  • max()
    • 카운터의 최대값

예제

• 코드

    #include <future>
    #include <iostream>
    #include <latch>
    #include <string>
    #include <vector>

    using namespace std;

    int main() {
    	vector<string> datas = {"a", "b", "c"};

    	latch done(datas.size());

    	auto run = [&done](string s) {
    		cout << s + " start" << endl;

    		done.arrive_and_wait();

    		cout << s + " end" << endl;
    	};

    	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
    c end
    a end
    b end