c++ - 线程构建 block : Deadlocks because all threads used up

Question

在英特尔线程构建 block 框架中，如何确保所有线程不忙于等待其他线程完成。

例如考虑以下代码，

#include <tbb/tbb.h>
#include <vector>
#include <cstdlib>
#include <future>
#include <iostream>

std::future<bool> run_something(std::function<bool(bool)> func, bool b) {
  auto task = std::make_shared<std::packaged_task<bool()> >(std::bind(func, b));
  std::future<bool> res = task->get_future();
  tbb::task_group g;
  g.run([task]() { (*task)(); });
  return res;
};

int main() {
  tbb::parallel_for(0, 100, 1, [=](size_t i) {
    g.run([] () {
      std::cout << "A" << std::endl;  
      run_something([] (bool b) { return b; }, true).get();
    });
  });
  return EXIT_SUCCESS;
}

这里 main 函数作为任务产生，因为 TBB 库使用的线程池中有线程。然后，当 run_something 函数中第二次调用生成更多任务时，TBB 调度程序会发现没有线程可用，并且只是死锁。也就是说，我看到该打印语句在 4 个超线程机器上正好经过 4 次，在 8 个超线程机器上正好经过 8 次。

我该如何避免这种情况，特别是有没有办法确保两个 task_group 或 task_arena 或 parallel_for 构造使用两个完全不相交的线程集？

Answer 1

std::future 与 TBB 的可选并行范例不兼容。 std::future::get() 实际上应该命名为 let_me_block_in_system_wait_here()。除非你想让 TBB 死锁，否则禁止在 TBB 任务调度程序不知道的 TBB 任务之间实现任何类型的同步。也就是说，使用 TBB 方式表达 TBB 任务之间的依赖关系。

可选的并行性意味着您的代码必须仅使用单个线程正确运行。只有 tbb::task::enqueue() promise 除了主线程之外至少有一个工作线程。

您的代码甚至不应该编译，因为您在 main() 中使用了 g.run() 而没有声明 g。并且禁止在调用wait()之前销毁task_group，如the reference所述对于析构函数:要求:在销毁 task_group 之前必须调用方法 wait，否则析构函数会抛出异常。

至于共享线程池。是的，TBB 有一个共享线程池。但是您可以使用 task_arena 控制工作的共享方式。没有任务可以离开竞技场，但工作线程可以在运行任务之间的时间内跨竞技场迁移。