A class to manage the asynchronous execution of work items.
A TTaskGroup represents concurrent execution of a group of tasks. Tasks may be dynamically added to the group as it is executing.
A TTaskGroup represents concurrent execution of a group of tasks. Tasks may be dynamically added to the group as it is executing. Nesting TTaskGroup instances may result in a runtime overhead.
Definition at line 26 of file TTaskGroup.hxx.
Public Member Functions | |
TTaskGroup () | |
TTaskGroup (const TTaskGroup &)=delete | |
TTaskGroup (TTaskGroup &&other) | |
~TTaskGroup () | |
void | Cancel () |
Cancel all submitted tasks immediately. | |
TTaskGroup & | operator= (TTaskGroup &&other) |
void | Run (const std::function< void(void)> &closure) |
Add to the group an item of work which will be ran asynchronously. | |
void | Wait () |
Wait until all submitted items of work are completed. | |
Private Member Functions | |
void | ExecuteInIsolation (const std::function< void(void)> &operation) |
Run operation in the internal task arena to implement work isolation, i.e. | |
Private Attributes | |
std::shared_ptr< ROOT::Internal::RTaskArenaWrapper > | fTaskArenaW |
void * | fTaskContainer {nullptr} |
#include <ROOT/TTaskGroup.hxx>
ROOT::Experimental::TTaskGroup::TTaskGroup | ( | ) |
Definition at line 59 of file TTaskGroup.cxx.
ROOT::Experimental::TTaskGroup::TTaskGroup | ( | TTaskGroup && | other | ) |
Definition at line 70 of file TTaskGroup.cxx.
|
delete |
ROOT::Experimental::TTaskGroup::~TTaskGroup | ( | ) |
Definition at line 83 of file TTaskGroup.cxx.
void ROOT::Experimental::TTaskGroup::Cancel | ( | ) |
Cancel all submitted tasks immediately.
Definition at line 107 of file TTaskGroup.cxx.
|
private |
Run operation in the internal task arena to implement work isolation, i.e.
prevent stealing of work items spawned by ancestors.
Definition at line 96 of file TTaskGroup.cxx.
TTaskGroup & ROOT::Experimental::TTaskGroup::operator= | ( | TTaskGroup && | other | ) |
Definition at line 75 of file TTaskGroup.cxx.
void ROOT::Experimental::TTaskGroup::Run | ( | const std::function< void(void)> & | closure | ) |
Add to the group an item of work which will be ran asynchronously.
Adding many small items of work to the TTaskGroup is not efficient, unless they run for long enough. If the work to be done is little, look try to express nested parallelism or resort to other constructs such as the TThreadExecutor. Trying to add a work item to the group while it is in waiting state makes the method block.
Definition at line 122 of file TTaskGroup.cxx.
void ROOT::Experimental::TTaskGroup::Wait | ( | ) |
Wait until all submitted items of work are completed.
This method is blocking.
Definition at line 134 of file TTaskGroup.cxx.
|
private |
Definition at line 36 of file TTaskGroup.hxx.
|
private |
Definition at line 37 of file TTaskGroup.hxx.