多线程：如何“锁定”一个或多个线程的对象

Question

我有一个“主”线程，它创建 SlowData 类的对象数组。这些对象的操作速度相对较慢。这就是为什么当我最初加载它们时，它们充满了存根数据。

加载数组中的每个对象后，我可以立即在 UI 中显示该数组。与此同时，我开始对数组进行计算。 SlowDataComputation 对象被指示向 UI 报告结果（UI 反过来会可视化特定 SlowData 对象的修改）。

下面是它的样子：

void main()
{
  std::vector<SlowData> aData;
  aData.reserve(1000000); // one million instances

  Fast_PopulateVector(aData);

  DataUi aUi;

  SlowDataComputation aCalc;
  aCalc.SetUiCallback(aUi);           // instruct the object to periodically
                                      // report computation results to the UI

  aCalc.Slow_ComputeInSeveralThreads(aData);

  aUi.VisualizeInMessageLoop(aData);  // message loop that exits upon user signal

  if ( aCalc.StillWorking() )
    aCalc.Stop();                     // terminate threads gradually

  // after VisualizeInMessageLoop returns, aData will then be destroyed
}

我希望 SlowDataComputation 启动几个线程，每个线程都会处理数组中的某个段：

class SlowDataComputation
{
  std::vector<SlowData> * myData;
  DataUi                * myUI;

public:
  void Slow_ComputeInSeveralThreads(std::vector<SlowData> & theV)
  {
    myData = &theV;

    size_t aSize = myData->size();
    size_t aNumThreads = 10;
    size_t aBlockSize = aSize / aNumThreads;

    for (size_ti = 0; i < aNumThreads; i++)
    {
      ComputationThread aThr(myData);
      aThr.SetBoundary(i * aBlockSize, (i+1) * aBlockSize);
      aThr.SetUiCallback(myUI);

      aThr.Run();   // process a given segment in the array
    }
  }
};

最后，这是 UI 的一些伪代码：

class DataUi
{
  std::vector<SlowData> * myData;

public:
  void VisualizeInMessageLoop()
  {
    Message aMsg;

    while ( HasMessage(aMsg) )
      if (aMsg.Code == Message::MSG_PROGRAM_QUIT)
        SignalQuit();  // next time, HasMessage will return false

    // return from message loop
  }
};

问题是：如何确保 SlowData 实例的销毁安全，以便十个计算线程中的任何一个当前正在处理某个对象，销毁需要等到每个计算线程完成（要么因为它完成处理，要么因为调用了 SlowDataComputation::Stop 方法）？什么同步原语最适合此任务？

我设法用一个计算线程解决了这个问题。我使用了关键部分。但这一解决方案无法很好地适应多个计算线程。

Answer 1

在 main 函数末尾使用 pthread_join
就像......

  for(t=0; t<NUM_THREADS; t++) {
     rc = pthread_join(thread[t], &status);
     //check rc and status
  }
  //destroy shared data safely. All the threads are done.

你不需要锁定对象，这更昂贵。您只需要知道所有线程都完成了计算。