溫馨提示×

C++中如何實(shí)現(xiàn)信號(hào)量以同步多個(gè)進(jìn)程

c++
小億
134
2024-04-02 13:49:06
欄目: 編程語言

在C++中實(shí)現(xiàn)信號(hào)量可以使用std::mutex和std::condition_variable來實(shí)現(xiàn)。下面是一個(gè)簡單的示例代碼來展示如何使用這兩個(gè)類來實(shí)現(xiàn)信號(hào)量：

#include <iostream>
#include <thread>
#include <mutex>
#include <condition_variable>

class Semaphore {
public:
    Semaphore(int count) : count(count) {}

    void wait() {
        std::unique_lock<std::mutex> lock(mutex);
        while (count <= 0) {
            cv.wait(lock);
        }
        count--;
    }

    void signal() {
        std::unique_lock<std::mutex> lock(mutex);
        count++;
        cv.notify_one();
    }

private:
    int count;
    std::mutex mutex;
    std::condition_variable cv;
};

Semaphore semaphore(1);

void process() {
    for (int i = 0; i < 5; i++) {
        semaphore.wait();
        std::cout << "Thread ID: " << std::this_thread::get_id() << " is executing" << std::endl;
        semaphore.signal();
    }
}

int main() {
    std::thread t1(process);
    std::thread t2(process);
    
    t1.join();
    t2.join();
    
    return 0;
}

在這個(gè)示例代碼中，我們定義了一個(gè)Semaphore類，其中包含wait和signal方法用于等待和通知信號(hào)量。在process函數(shù)中，我們創(chuàng)建了兩個(gè)線程來模擬多個(gè)進(jìn)程同時(shí)執(zhí)行，每個(gè)線程在執(zhí)行前會(huì)等待信號(hào)量，然后執(zhí)行完畢后通知信號(hào)量。通過使用std::mutex和std::condition_variable來實(shí)現(xiàn)信號(hào)量，我們可以實(shí)現(xiàn)多個(gè)進(jìn)程之間的同步。

0 踩