c++ - boost 线程锁错误

Question

我有这个错误的代码:

 error this boost::lock_error
 error this boost::lock_error
 error this boost::lock_error
 error this boost::lock_error
 error this boost::lock_error

因为我不知道错误在哪里我会尝试复制代码:

主要

  boost::tuple<ppa::Node*, ppa::Node*, ppa::Node*, bool>  tuple = dups.back();
  ppa::Node *n = boost::get<0>(tuple);
  cout << "creating other threads" << endl;
  for ( int i = 0; i < 5; ++i )
  {
    cout << "making  thread " << i << endl;
    g.create_thread( boost::bind( threaded_function, boost::ref(mf), 
                                    boost::ref(n) ));
  }

线程

  void threaded_function(Model_factory &mf, ppa::Node *root)
  {
    try 
    {   
      while(true)
      {
        boost::mutex::scoped_lock lock(result_mutex);

        if(wait.empty())
        {
          lock.unlock();
          break;
        }
        else 
        {
          lock.lock();
          if(!running_jobs.empty())
          {
            cout << "vector wait size = " << wait.size()   << "\n";
            cout << "running size   = " << running_jobs.size() << "\n";
            cout << "done size  = " << done.size()   << "\n";
            boost::tuple<ppa::Node*, ppa::Node*, ppa::Node*, bool> tuple;
            tuple = running_jobs.back();
            running_jobs.pop_back();
            ...
          }
          ...
        }
        ...
      }
    }
    catch (boost::lock_error& le)
    {
      cout << "error this " << le.what() << endl;
    }
  }

该代码用于我尝试并行执行的对齐程序，它在不同线程中逐个对齐元组，直到等待列表( vector 等待)为空。谢谢。 我做了一些事情，我在每个 if 和 else 之前放了一个 lock.unlock() 并且它现在可以工作了，但是为什么呢？

Answer 1

你锁定了互斥体两次。

boost::mutex::scoped_lock lock(result_mutex);

为您锁定互斥量。当它超出范围时它也会解锁它，所以你不需要自己解锁它。

所以下面几行是不必要的:

lock.lock();
lock.unlock();