GlobalTaskGroup.cc

Go to the documentation of this file.

#include "art/Utilities/GlobalTaskGroup.h"

art::GlobalTaskGroup::GlobalTaskGroup(unsigned const n_threads,
                                      unsigned const stack_size)
  : threadControl_{tbb::global_control::max_allowed_parallelism, n_threads}
  , stackSizeControl_{tbb::global_control::thread_stack_size, stack_size}
{}

void
art::GlobalTaskGroup::may_run(hep::concurrency::WaitingTaskPtr task,
                              std::exception_ptr ex_ptr)
{
  if (task->decrement_done_count() == 0u) {
    group_.run([t = std::move(task), ex_ptr] {
      t->dependentTaskFailed(ex_ptr);
      (*t)();
    });
  }
}