#include <iostream>
#include <string>
#include <thread>
#include <mutex>
#include <condition_variable>
std::mutex m;
std::condition_variable cv;
std::string data;
bool ready = false;
bool processed = false;
void worker_thread()
{
// Wait until main() sends data
std::unique_lock<std::mutex> lk(m);
cv.wait(lk, []{return ready;});
// after the wait, we own the lock.
std::cout << "Worker thread is processing data\n";
data += " after processing";
// Send data back to main()
processed = true;
std::cout << "Worker thread signals data processing completed\n";
// Manual unlocking is done before notifying, to avoid waking up
// the waiting thread only to block again (see notify_one for details)
lk.unlock();
cv.notify_one();
}
int main()
{
std::thread worker(worker_thread);
data = "Example data";
// send data to the worker thread
{
std::lock_guard<std::mutex> lk(m);
ready = true;
std::cout << "main() signals data ready for processing\n";
}
cv.notify_one();
// wait for the worker
{
std::unique_lock<std::mutex> lk(m);
cv.wait(lk, []{return processed;});
}
std::cout << "Back in main(), data = " << data << '\n';
worker.join();
}
std::thread worker(worker_thread);
std::unique_lock<std::mutex> lk(m);
cv.wait(lk, []{return ready;});
{
std::lock_guard<std::mutex> lk(m);
ready = true;
std::cout << "main() signals data ready for processing\n";
}
在您附加的链接中,请注意以下内容
等待操作自动释放互斥体并挂起线程的执行。
因此这条线
cv.wait(lk, []{return ready;});
我在理解条件变量及其在互斥体中的使用时遇到了一些困难,我希望社区能帮助我。请注意,我来自win32背景,因此与CRITICAL_SECTION、HANDLE、SetEvent、WaitForMultipleObject等一起使用。 这是我第一次尝试使用C++11标准库进行并发操作,它是在这里找到的一个程序示例的修改版本。 关于这个的几个问题。 我读过“任何要等待std::condition_var
我需要弄清楚lock和condition_variable是如何工作的。 在这里略有修改的cplusplusreference代码中 我感到困惑的是,如果worker_thread已经锁定了互斥体,主线程如何锁定它。 我不明白为什么在这种情况下会出现“运行时错误”。
问题内容: 使用GCC 4.8.2(在Linux / Debian / Sid 64位上)或GCC 4.9(在C ++ 11中可用)-我有一些互斥锁 实际上,它是某个类的成员,同时包含下面的和方法。 它被锁定像 我想检查一下确实被锁定了: (仅在内部调用的通知。。。效率可能非常低下,有时甚至不准确) 当然,我还有其他函数调用,例如 但不存在。…我应该如何定义它?(实际上,我想确保互斥体已被某些[间
我知道是一个原子对象。但是原子化到什么程度呢?据我所知,操作可以是原子的。使一个对象原子化到底是什么意思?例如,如果有两个线程同时执行以下代码: 那么整个操作(例如)是原子操作吗?还是对变量atomic(so)进行了更改?
我知道互斥体通常也会保护共享数据,使用原子变量只是一个例子。问题不是如何保护共享数据,而是是否需要使用相同的互斥体来保护两者。另一个使用第二互斥体的示例:
我想演示/记录一些行为。我希望记录对和的每个调用(不管它们是成功还是必须阻止)。最初,由于那些方法不是,我尝试用以下方式包装标准的,而不是使用继承: 忽略在多个线程中调用时,调用可能会产生损坏的输出。 然后,我想检查一个简单的示例的输出,例如: 问题是它不能编译,因为显然要求用常规的实例化相应的,而我试图将它与自己的一起使用。 有没有办法记录一个标准互斥体的锁定和解锁的内部使用情况?或者是否有方法