c++ - 使用 tbb 在线程之间进行同步

Question

我正在使用 C++ 中的 tbb 编程。我不应该使用消息队列、FIFO、PIPES 等，因为它是特定于平台的。我应该使用 tbb 特定的 API。

Thread1: // Pseuodo code exits as below

     // I will take mutex

     m_bIsNewSubsArrived = true;
     StartSubscriptionTimer();
     m_bIsFristSubsArrived = true;  

     // Spawn a thread here.
     if(m_tbbTimerThread == NULL)
     {
        m_bIsTimerMutexTaken = true;
                m_timerMutex.lock(); 
        m_tbbTimerThread = new tbb::tbb_thread(&WaitForTimerMutex, this);
        if (m_tbbTimerThread->native_handle() == 0)
        {
            // report error and return.
            return;
        }
    }

    // Thread 1 exited.


In another thead I am releasing mutex which is taken above.

Thread 2.

 m_timerMutex.unlock();
 m_bIsTimerMutexTaken = false;


Thread 3: 

   // I am waiting for mutex 
    m_timerMutex.lock(); 

在上面的代码问题中，我认为是线程 1 锁定的 m_timerMutex 没有被释放，所以我认为线程 2 无法解锁。线程 3 永远被阻塞。

我想我可以使用 sempahore，但是在 TBB 中用于 sempahore 的 API 是什么。

我可以在不休眠和使用特定于 tbb 的 API 的情况下做到这一点的最佳技术是什么。

感谢您的宝贵时间和帮助。

Answer 1

目前 TBB 中不支持信号量。原因是 TBB 旨在将原始线程之上的抽象级别提升到任务级别，而信号量被认为是线程编程的低级“goto”。请注意，C++11 也没有信号量。

使用任务而不是线程通常允许同步变得隐式，并且通常允许通过 TBB 中的工作窃取调度程序进行自动负载平衡。

如果您的问题不适用于基于任务的解决方案，请考虑使用条件变量，它是 C++11 的一部分。 TBB 的最新版本带有 partial implementation C++11 条件变量。