在C++中實現信號量可以使用std::mutex
和std::condition_variable
來實現。下面是一個簡單的示例代碼來展示如何使用這兩個類來實現信號量:
#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;
}
在這個示例代碼中,我們定義了一個Semaphore
類,其中包含wait
和signal
方法用于等待和通知信號量。在process
函數中,我們創建了兩個線程來模擬多個進程同時執行,每個線程在執行前會等待信號量,然后執行完畢后通知信號量。通過使用std::mutex
和std::condition_variable
來實現信號量,我們可以實現多個進程之間的同步。