wait_for
是 C++ 标准库 <chrono>
中的一个函数,它用于等待给定的时间间隔。这个函数的主要功能是阻塞当前线程直到指定的时间到达或者发生某个特定事件。wait_for
的常见用途包括:
std::chrono::seconds
或 std::chrono::milliseconds
),你可以让当前线程暂停一段时间。这对于实现定时任务或延时操作非常有用。#include <iostream>
#include <chrono>
#include <thread>
int main() {
std::cout << "Waiting for 5 seconds...\n";
std::this_thread::sleep_for(std::chrono::seconds(5));
std::cout << "5 seconds have passed.\n";
return 0;
}
wait_for
也可以与条件变量结合使用,以实现轮询检查某个条件是否满足。当条件不满足时,线程会等待一段时间,然后再次检查。这比忙等待(busy-waiting)更节省资源。#include <iostream>
#include <chrono>
#include <thread>
#include <mutex>
#include <condition_variable>
std::mutex mtx;
std::condition_variable cv;
bool ready = false;
void print_id(int id) {
std::unique_lock<std::mutex> lck(mtx);
while (!ready) { // 如果 ready 为 false, 则等待
cv.wait(lck); // 当前线程被阻塞, 当全局变量 ready 变为 true 之后,
}
// ...
}
int main() {
std::thread threads[10];
// spawn 10 threads:
for (int i = 0; i < 10; ++i)
threads[i] = std::thread(print_id, i);
std::cout << "10 threads ready to race...\n";
{
std::lock_guard<std::mutex> lck(mtx);
ready = true; // set the flag to true
}
cv.notify_all(); // wake up all threads
for (auto &th : threads) th.join();
return 0;
}
在这个例子中,print_id
函数会等待直到全局变量 ready
被设置为 true
。主线程在设置 ready
为 true
之后,通过 cv.notify_all()
唤醒所有等待的线程。
需要注意的是,wait_for
函数会阻塞当前线程,直到指定的时间间隔到达或者发生某个特定事件。如果在这段时间内没有其他线程调用 cv.notify_one()
来唤醒等待的线程,那么等待的线程将会一直阻塞下去。因此,在使用 wait_for
时,通常需要配合条件变量来实现更复杂的同步逻辑。