1. ホーム
  2. c++

[解決済み] C++0xにはセマフォがない?スレッドを同期させる方法は?

2022-05-03 18:34:28

質問

C++0xからセマフォがなくなるというのは本当ですか?Stack Overflowには、すでにセマフォの使用に関する質問がいくつか寄せられています。私は、あるスレッドが他のスレッドのイベントを待つために、いつもセマフォ(posixセマフォ)を使っています。

void thread0(...)
{
  doSomething0();

  event1.wait();

  ...
}

void thread1(...)
{
  doSomething1();

  event1.post();

  ...
}

それをミューテックスでやるとしたら。

void thread0(...)
{
  doSomething0();

  event1.lock(); event1.unlock();

  ...
}

void thread1(...)
{
  event1.lock();

  doSomethingth1();

  event1.unlock();

  ...
}

問題:醜いし、thread1 が最初に mutex をロックすることが保証されていない(同じスレッドが mutex をロックしアンロックすべきであると考えると、thread0 と thread1 が開始する前に event1 をロックすることもできない)。

boostにはセマフォもないので、上記を実現する一番簡単な方法は何でしょうか?

どのように解決するのですか?

mutexと条件変数から簡単に作ることができます。

#include <mutex>
#include <condition_variable>

class semaphore {
    std::mutex mutex_;
    std::condition_variable condition_;
    unsigned long count_ = 0; // Initialized as locked.

public:
    void release() {
        std::lock_guard<decltype(mutex_)> lock(mutex_);
        ++count_;
        condition_.notify_one();
    }

    void acquire() {
        std::unique_lock<decltype(mutex_)> lock(mutex_);
        while(!count_) // Handle spurious wake-ups.
            condition_.wait(lock);
        --count_;
    }

    bool try_acquire() {
        std::lock_guard<decltype(mutex_)> lock(mutex_);
        if(count_) {
            --count_;
            return true;
        }
        return false;
    }
};