art::GlobalTaskGroup Class Reference

#include <GlobalTaskGroup.h>

Public Member Functions
	GlobalTaskGroup (unsigned n_threads, unsigned stack_size)
template<typename T >
void	run (T &&t)
void	may_run (hep::concurrency::WaitingTaskPtr task, std::exception_ptr ex_ptr={})
tbb::task_group &	native_group ()

Private Attributes
tbb::global_control	threadControl_
tbb::global_control	stackSizeControl_
tbb::task_group	group_

Detailed Description

Definition at line 11 of file GlobalTaskGroup.h.

Constructor & Destructor Documentation

art::GlobalTaskGroup::GlobalTaskGroup	(	unsigned	n_threads,
		unsigned	stack_size
	)

Definition at line 3 of file GlobalTaskGroup.cc.

  : threadControl_{tbb::global_control::max_allowed_parallelism, n_threads}
  , stackSizeControl_{tbb::global_control::thread_stack_size, stack_size}
{}

Member Function Documentation

void art::GlobalTaskGroup::may_run	(	hep::concurrency::WaitingTaskPtr	task,
		std::exception_ptr	ex_ptr = {}
	)

Definition at line 10 of file GlobalTaskGroup.cc.

{
  if (task->decrement_done_count() == 0u) {
    group_.run([t = std::move(task), ex_ptr] {
      t->dependentTaskFailed(ex_ptr);
      (*t)();
    });
  }
}

tbb::task_group& art::GlobalTaskGroup::native_group ( )

inline

Definition at line 27 of file GlobalTaskGroup.h.

    {
      return group_;
    }

template<typename T >

void art::GlobalTaskGroup::run ( T &&  t )

inline

Definition at line 17 of file GlobalTaskGroup.h.

    {
      group_.run(std::move(t));
    }

Member Data Documentation

tbb::task_group art::GlobalTaskGroup::group_

private

Definition at line 35 of file GlobalTaskGroup.h.

tbb::global_control art::GlobalTaskGroup::stackSizeControl_

private

Definition at line 34 of file GlobalTaskGroup.h.

tbb::global_control art::GlobalTaskGroup::threadControl_

private

Definition at line 33 of file GlobalTaskGroup.h.

---

The documentation for this class was generated from the following files:

• art/art/Utilities/GlobalTaskGroup.h
• art/art/Utilities/GlobalTaskGroup.cc