c++ - boost 线程同步

Question

当我在 thread() 中注释行 wait(1) 时，我没有看到同步输出。我可以让它们同时运行(一个接一个)而不必使用“wait(1)”吗？

#include <boost/thread.hpp> 
#include <iostream> 

void wait(int seconds) 
{
  boost::this_thread::sleep(boost::posix_time::seconds(seconds)); 
}

boost::mutex mutex; 

void thread()
{
  for (int i = 0; i < 100; ++i) 
  {
    wait(1); 
    mutex.lock(); 
    std::cout << "Thread " << boost::this_thread::get_id() << ": " << i << std::endl; 
    mutex.unlock(); 
  }
}

int main()
{
  boost::thread t1(thread); 
  boost::thread t2(thread);

  t1.join();
  t2.join();
}

Answer 1

“同时(一个接着一个)”是矛盾的。通过调用 sleep() 它们会同时运行。无需调用 sleep()，它们就会一个接一个地运行。只有 100 行要输出，线程 t1 在 t2 开始执行之前完成。在我的计算机上，在 t1 运行足够长的时间以使 t2 启动之前，我必须将循环计数器设置为 10000，而 t1 仍在执行:

Thread 0x2305010: 0
Thread 0x2305010: 1
Thread 0x2305010: 2
...
Thread 0x2305010: 8730
Thread 0x2305010: 8731
Thread 0x23052a0: 0
Thread 0x23052a0: 1
...
Thread 0x23052a0: 146
Thread 0x23052a0: 147
Thread 0x2305010: 8732
Thread 0x2305010: 8733
etc

哦，是的，如果您的目标是让两个线程轮流执行，boost::condition_variable 就是解决方案:

boost::mutex mutex;
boost::condition_variable cv;

void thread()
{
  for (int i = 0; i < 100; ++i)
  {
    boost::unique_lock<boost::mutex> lock(mutex);
    std::cout << "Thread " << boost::this_thread::get_id() << ": " << i << std::endl;
    cv.notify_one();
    cv.wait(lock);
  }
  cv.notify_one();
}