std :: condition_variables를 카운팅 세마포로 사용할 수 있습니까?

Question

후속 조치는 Can C++11 condition_variables be used to synchronize processes?입니다.

카운트 세마포어로 std :: condition_variable 개체를 사용할 수 있습니까?

메타 링크는 객체가 std :: mutex에 바인딩되어있는 것처럼 보이지 않으므로 바이너리 세마포어로만 사용할 수 있습니다. here, here 및 here을 (를) 포함하여 온라인에서 보았지만 이러한 개체를 카운팅 세마포로 사용하는 참조 또는 예제를 찾을 수 없습니다.

Answer 1

예.

struct counting_sem { 
    counting_sem(std::ptrdiff_t init=0):count(init) {} 
    // remove in C++17: 
    counting_sem(counting_sem&& src) { 
    auto l = src.lock(); // maybe drop, as src is supposed to be dead 
    count = src.count; 
    } 
    counting_sem& operator=(counting_sem&& src) = delete; 
    void take(std::size_t N=1) { 
    if (N==0) return; 
    auto l = lock(); 
    cv.wait(l, [&]{ 
     if (count > 0 && count < (std::ptrdiff_t)N) { 
     N -= count; 
     count = 0; 
     } else if (count >= (std::ptrdiff_t)N) { 
     count -= N; 
     N = 0; 
     } 
     return N == 0; 
    }); 
    } 
    void give(std::size_t N=1) { 
    if (N==0) return; 
    { 
     auto l = lock(); 
     count += N; 
    } 
    cv.notify_all(); 
    } 
    // reduce the count without waiting for it 
    void reduce(std::size_t N=1) { 
    if (N==0) return; 
    auto l = lock(); 
    count -= N; 
    } 
private: 
    std::mutex m; 
    std::condition_variable cv; 
    std::ptrdiff_t count; 

    auto lock() { 
    return std::unique_lock<std::mutex>(m); 
    } 
    auto unlocked() { 
    return std::unique_lock<std::mutex>(m, std::defer_lock_t{}); 
    } 
}; 

코드는 테스트되지 않았거나 컴파일되었지만 사운드는 디자인되었습니다.

take(7)은 for(repeat 7 times) take()과 같지 않습니다. 대신 충분하지 않은 경우 차단할 수있는만큼 걸립니다. 정도가 될 때까지 아무것도하지 않도록

이

수정은 간단합니다 : 당신은 왜 세마포어와 같은 개체를 찾고 있습니다

 if (count >= (std::ptrdiff_t)N) { 
     count -= N; 
     N = 0; 
     }