std:: counting_semaphore, std:: binary_semaphore

counting_semaphore は、コンストラクタで初期化される内部カウンタを持ちます。このカウンタは acquire() および関連メソッドの呼び出しによって減少し、 release() の呼び出しによって増加します。カウンタがゼロの場合、 acquire() はカウンタが増加するまでブロックしますが、 try_acquire() はブロックしません。 try_acquire_for() と try_acquire_until() は、カウンタが増加するかタイムアウトに達するまでブロックします。

std::condition_variable::wait() と同様に、 counting_semaphore の try_acquire() は偽の失敗を起こす可能性があります。

std::counting_semaphore の特殊化は、 DefaultConstructible 、 CopyConstructible 、 MoveConstructible 、 CopyAssignable 、または MoveAssignable ではありません。

データメンバ

メンバー関数

注記

その名が示す通り、 LeastMaxValue は 最小 の最大値であり、 実際の 最大値ではありません。したがって max() は LeastMaxValue よりも大きな値を返す可能性があります。

std::mutex とは異なり、 counting_semaphore は実行スレッドに紐付けられていません - 例えば、セマフォの獲得はセマフォの解放とは異なるスレッドで発生することができます。 counting_semaphore に対するすべての操作は、特定の実行スレッドとの関係なく並行して実行できますが、デストラクタは例外で、並行して実行することはできませんが、異なるスレッドで実行することは可能です。

例

#include <chrono>
#include <iostream>
#include <semaphore>
#include <thread>
// グローバルなバイナリセマフォインスタンス
// オブジェクトカウントは0に設定
// オブジェクトは非シグナル状態
std::binary_semaphore
    smphSignalMainToThread{0},
    smphSignalThreadToMain{0};
void ThreadProc()
{
    // メインプロセスからのシグナルを待機
    // セマフォのデクリメントを試行することで
    smphSignalMainToThread.acquire();
    // この呼び出しは、メインプロセスからセマフォのカウントが
    // 増加されるまでブロックする
    std::cout << "[thread] Got the signal\n"; // 応答メッセージ
    // スレッドによる作業を模倣するため3秒間待機
    // スレッドによる何らかの作業
    using namespace std::literals;
    std::this_thread::sleep_for(3s);
    std::cout << "[thread] Send the signal\n"; // メッセージ
    // メインプロセスにシグナルを返す
    smphSignalThreadToMain.release();
}
int main()
{
    // ワーカースレッドを作成
    std::thread thrWorker(ThreadProc);
    std::cout << "[main] Send the signal\n"; // メッセージ
    // ワーカースレッドに作業開始をシグナル
    // セマフォのカウントを増加させることで
    smphSignalMainToThread.release();
    // ワーカースレッドの作業完了を待機
    // セマフォのカウントをデクリメントしようとすることで
    smphSignalThreadToMain.acquire();
    std::cout << "[main] Got the signal\n"; // 応答メッセージ
    thrWorker.join();
}

[main] Send the signal
[thread] Got the signal
[thread] Send the signal
[main] Got the signal