C++ 11 - condition_variable - wait_until 未按预期工作

In lại 作者：太空狗 更新时间：2023-10-29 21:04:08 30 4

#include 
#include 
#include 
#include 
#include 
#include 

sử dụng không gian tên std;
using namespace std::chrono;

condition_variable cv;
mutex m;
bool flagValue=false;

int sampleFunction(int a)
{
    cout<<"Executing sampleFunction...";
    cout.flush();
    this_thread::sleep_for(seconds(5));
    cout<<"Done."<<>
    return a;
}

void sampleFunctionCond(int a)
{
    lock_guard lg(m);
    cout<<"Executing sampleFunctionCond...";
    cout.flush();
    this_thread::sleep_for(seconds(5));
    cout<<"Done."<<>
    cout<<"Value : "<<><>
    flagValue=true;
    cv.notify_one();
    trở lại;
}

int chính()
{
   unique_lock ul(m);
   future f1=async(launch::async,sampleFunction,10);
   future_status statusF1=f1.wait_for(seconds(1));
   if(statusF1==future_status::ready)
    cout<<"Future is ready"<<>
   else if (statusF1==future_status::timeout)
    cout<<"Timeout occurred"<<>
   else if (statusF1==future_status::deferred)
    cout<<"Task is deferred"<<>
   cout<<"Value : "<<><>

   cv_status statusF2;
   thread t1(sampleFunctionCond,20);
   t1.detach();
   while(!flagValue)
   {
       statusF2=cv.wait_until(ul,system_clock::now()+seconds(2));
       if(statusF2==cv_status::timeout)
       {
       cout<<"Timeout occurred."<<>
       phá vỡ;
       }
       khác
       {
       cout<<"Condition variable is ready or spurious wake up occurred."<<>
       }
   }
}

Executing sampleFunction...Timeout occurred
Done.
Value : 10
Executing sampleFunctionCond...Done.
Value : 20
Timeout occurred.

30 4 0

• c++ - std::condition_variable 在来自其他线程的 std::condition_variable::notify_all() 之后未正确唤醒

  此代码是实际项目代码的简化。主线程创建工作线程并使用 std::condition_variable 等待工作线程真正启动。在下面的代码中，std::condition_variable 在 curr

• c++ - std::condition_variable::wait_for 和 std::condition_variable::wait_until 有什么区别？

  reference I'm using用以下方式解释这两者: wait_for "阻塞当前线程，直到条件变量被唤醒或在指定的超时时间之后" wait_until "阻塞当前线程，直到条件变量被唤醒或到

• c++ - CONDITION_VARIABLE 是如何实现的？

  标题问题的较长版本是: On my machine, sizeof(std::condition_variable) is 72 bytes.What are these 72 bytes used

• c++ - condition_variable.notify同步点吗？

  假设我有这样的事情: bool signalled = false; std::condition_variable cv; void thread1() { while (true) {

• Boost condition_variable 参数错误

  我在下面的代码中遇到错误。 recursive_mutex m_RecurMutex; condition_variable cond; unique_lock lock(m_RecurMutex);

• c++ - condition_variable 等待参数？

  这是什么: bool ready; boost::mutex mutex; boost::condition_variable cond; boost::unique_lock lock(mutex)

• c++ - condition_variable 获取锁速度慢

  这个问题是关于condition_variable.wait()的功能。我认为它可能没有锁定 unique_lock当它被通知时立即。让我展示一下我的代码，您会更好地理解我的测试。 注意:编译器 g+

• c++ - 为什么在此代码块中使用 condition_variable？

  我是条件变量的新手，我想知道为什么计数器变量等于 99 之后的这段代码块？删除for循环并改用“counter += 99”使代码工作，它与sleep_for有什么关系吗？感谢您的帮助:) #incl

• c++ - condition_variable 等待锁

  đóng cửa. Câu hỏi này yêu cầu chi tiết gỡ lỗi. Hiện tại nó không chấp nhận câu trả lời. Chỉnh sửa câu hỏi để bao gồm hành vi mong muốn, một vấn đề hoặc lỗi cụ thể và

• c++ - condition_variable 并不总是有效

  似乎 condition_variable notify_one 并不总是按应有的方式工作。 struct Task { std::mutex mutex; std::conditio

• c++ - condition_variable 的常见用例场景

  条件变量可用于向其他线程发出信号，表明发生了某些事情: mutex m; condition_variable cv; thread t1([&cv]{ // processing .

• c++ - condition_variable 的目的

  没有 std::condition_variable 的应用程序: #include #include #include #include #include #include std::m

• c++ - 等待时销毁 condition_variable

  首先是我的代码，让我的解释更清楚: struct Foo { std::condition_variable cv; }; static Foo* foo; // dynamically cr

• c++ - std::condition_variable 内存写入可见性

  std::condition_variable::notify_one() 或 std::condition_variable::notify_all() 是否保证非原子内存写入当前线程之前该调用将在

• multithreading - std::condition_variable::wait访问冲突

  我目前正在对并发队列进行编程，同时学习如何使用C++ 11的多线程功能。 当使用者调用dequeue()函数且队列中没有任何条目时，该函数应等待，直到另一个线程调用enqueue()为止。我正在为此使

• c++ - condition_variable::notify_one 不会立即解除等待？

  我有一个关于notify_one函数的问题。在下面的代码中， #include #include #include #include #include std::condition_vari

• gcc - 无法编译boost::condition_variable cond_

  我有一个以下类(class)- boost::condition_varaible cond_; 当我尝试编译时- [rmitra @ butterfly boost] $ make EXE = th

• c++ - 当通知简历时，condition_variable::wait_for是否返回true

  这是一个小代码段 request_ptr pop() { request_ptr rp; std::unique_lock lock(cv_mtx); auto time =

• c++ - condition_variable，引用和线程:谁拥有锁？

  假设我有一个包含std::queue的ThreadQueue类，并且我将每个std::ref的实例传递给线程。进一步假设，线程1(主线程)创建并保存ThreadQueue对象，并将消息倒入其中，第二个

• C++。 std::condition_variable 和多个等待线程

  我有课，用 queue的 std::function成员和方法 Push和 Pop . 我要实现加法PushAndWaitUntilExecuted .当你有一个时很容易consumer-thread