在C++中,直接唤醒一个特定的线程并不像在Java的Thread
类中有interrupt()
方法或者某些操作系统特定的API(如POSIX的pthread_cond_signal
或Windows的SetEvent
)那样简单。C++标准库没有提供一个直接的方法来"唤醒"一个正在等待的线程。然而,你可以使用条件变量(std::condition_variable
)与互斥锁(std::mutex
)来协调线程之间的通信,从而达到"唤醒"线程的效果。
以下是一个简单的示例,说明如何使用std::condition_variable
和std::mutex
来"唤醒"一个特定的线程:
#include <iostream> | |
#include <thread> | |
#include <mutex> | |
#include <condition_variable> | |
#include <atomic> | |
std::mutex mtx; | |
std::condition_variable cv; | |
std::atomic_bool ready(false); | |
void worker_thread() { | |
std::unique_lock<std::mutex> lock(mtx); | |
cv.wait(lock, [](){ return ready.load(); }); // 等待直到ready为true | |
// 线程被唤醒后,继续执行后续操作 | |
std::cout << "Worker thread is awaken and continuing execution.\n"; | |
} | |
int main() { | |
std::thread t(worker_thread); | |
// 模拟一些工作,然后唤醒线程 | |
std::this_thread::sleep_for(std::chrono::seconds(2)); | |
{ | |
std::lock_guard<std::mutex> lock(mtx); | |
ready.store(true); // 设置ready为true,这可能会唤醒等待的线程 | |
} | |
cv.notify_one(); // 唤醒一个等待在cv上的线程(如果有的话) | |
t.join(); | |
return 0; | |
} |
在这个示例中,worker_thread
函数中的线程会等待ready
变量变为true
。主线程在模拟一些工作后,通过修改ready
变量的值并使用cv.notify_one()
来唤醒等待的线程。注意,即使notify_one()
被调用,也只有在ready
变量变为true
时,等待的线程才会真正继续执行。这是因为我们使用了cv.wait(lock, predicate)
,它会在条件不满足时继续等待。
这种方法并不是直接"唤醒"线程,而是通过改变共享状态并使用条件变量来通知线程可以继续执行了。在实际应用中,这通常是你想要的行为,因为它允许你更精细地控制线程之间的通信和同步。