21 #ifndef __TBB_flow_graph_impl_H 22 #define __TBB_flow_graph_impl_H 24 #include "../tbb_stddef.h" 26 #include "../task_arena.h" 27 #include "../flow_graph_abstractions.h" 29 #if __TBB_PREVIEW_FLOW_GRAPH_PRIORITIES 30 #include "../concurrent_priority_queue.h" 35 #if TBB_DEPRECATED_FLOW_ENQUEUE 36 #define FLOW_SPAWN(a) tbb::task::enqueue((a)) 38 #define FLOW_SPAWN(a) tbb::task::spawn((a)) 41 #if __TBB_PREVIEW_FLOW_GRAPH_PRIORITIES 42 #define __TBB_FLOW_GRAPH_PRIORITY_EXPR( expr ) expr 43 #define __TBB_FLOW_GRAPH_PRIORITY_ARG0( priority ) , priority 44 #define __TBB_FLOW_GRAPH_PRIORITY_ARG1( arg1, priority ) arg1, priority 46 #define __TBB_FLOW_GRAPH_PRIORITY_EXPR( expr ) 47 #define __TBB_FLOW_GRAPH_PRIORITY_ARG0( priority ) 48 #define __TBB_FLOW_GRAPH_PRIORITY_ARG1( arg1, priority ) arg1 49 #endif // __TBB_PREVIEW_FLOW_GRAPH_PRIORITIES 56 #if __TBB_PREVIEW_FLOW_GRAPH_PRIORITIES 62 namespace interface10 {
66 #if __TBB_PREVIEW_FLOW_GRAPH_PRIORITIES 82 template <
typename GraphContainerType,
typename GraphNodeType>
104 if (
this != &other) {
165 #if __TBB_PREVIEW_FLOW_GRAPH_PRIORITIES 181 __TBB_ASSERT_EX( result,
"Number of critical tasks for scheduler and tasks" 182 " in graph's priority queue mismatched" );
184 "Incorrect task submitted to graph priority queue" );
186 "Tasks from graph's priority queue must have priority" );
203 template<
typename Body >
222 template<
typename Receiver,
typename Body >
280 #if TBB_PREVIEW_FLOW_GRAPH_TRACE 281 void set_name(
const char *
name);
305 template< typename Receiver, typename Body >
306 void run(Receiver &r, Body body) {
308 task* rtask =
new (task::allocate_additional_child_of(*
root_task()))
317 template<
typename Body >
331 #if TBB_USE_EXCEPTIONS 336 #if TBB_USE_EXCEPTIONS 362 template<
typename C,
typename N>
407 #if __TBB_PREVIEW_FLOW_GRAPH_PRIORITIES 417 #if __TBB_PREVIEW_FLOW_GRAPH_PRIORITIES 418 template<
typename Input,
typename Output,
typename Policy,
typename Allocator>
429 template<
typename C,
typename N>
439 #if TBB_PREVIEW_FLOW_GRAPH_TRACE 440 virtual void set_name(
const char *
name) = 0;
443 #if TBB_DEPRECATED_FLOW_NODE_EXTRACTION 444 virtual void extract() = 0;
477 task* task_to_spawn = &arena_task;
478 #if __TBB_PREVIEW_FLOW_GRAPH_PRIORITIES 480 graph_task* t = static_cast<graph_task*>(&arena_task);
505 #endif // __TBB_flow_graph_impl_H Tag class used to indicate the "attaching" constructor.
graph_task(node_priority_t node_priority=no_priority)
GraphNodeType & reference
static tbb::task *const SUCCESSFULLY_ENQUEUED
Base class for tasks generated by graph nodes.
void add_task_to_graph_reset_list(graph &g, tbb::task *tp)
bool operator==(const graph_iterator &other) const
Equality.
const_iterator cend() const
end const iterator
std::forward_iterator_tag iterator_category
tbb::spin_mutex nodelist_mutex
pointer operator->() const
Dereference.
virtual task * execute()=0
Should be overridden by derived classes.
graph_iterator()
Default constructor.
#define __TBB_ASSERT(predicate, comment)
No-op version of __TBB_ASSERT.
void increment_wait_count()
#define __TBB_PREVIEW_FLOW_GRAPH_PRIORITIES
graph_iterator operator++(int)
Post-increment.
void const char const char int ITT_FORMAT __itt_group_sync x void const char ITT_FORMAT __itt_group_sync s void ITT_FORMAT __itt_group_sync p void ITT_FORMAT p void ITT_FORMAT p no args __itt_suppress_mode_t unsigned int void size_t ITT_FORMAT d void ITT_FORMAT p void ITT_FORMAT p __itt_model_site __itt_model_site_instance ITT_FORMAT p __itt_model_task __itt_model_task_instance ITT_FORMAT p void ITT_FORMAT p void ITT_FORMAT p void size_t ITT_FORMAT d void ITT_FORMAT p const wchar_t ITT_FORMAT s const char ITT_FORMAT s const char ITT_FORMAT s const char ITT_FORMAT s no args void ITT_FORMAT p size_t ITT_FORMAT d no args const wchar_t const wchar_t ITT_FORMAT s __itt_heap_function void size_t int ITT_FORMAT d __itt_heap_function void ITT_FORMAT p __itt_heap_function void void size_t int ITT_FORMAT d no args no args unsigned int ITT_FORMAT u const __itt_domain __itt_id ITT_FORMAT lu const __itt_domain __itt_id __itt_id __itt_string_handle ITT_FORMAT p const __itt_domain __itt_id ITT_FORMAT p const __itt_domain __itt_id __itt_timestamp begin
~graph()
Destroys the graph.
Used to form groups of tasks.
void remove_node(graph_node *n)
internal::return_type_or_void< F >::type execute(F &f)
Base class for types that should not be copied or assigned.
graph_iterator< const graph, const graph_node > const_iterator
void register_node(graph_node *n)
reference operator*() const
Dereference.
tbb::task_group_context * my_context
Base class for user-defined tasks.
void run(Receiver &r, Body body)
Spawns a task that runs a body and puts its output to a specific receiver.
void push(const_reference elem)
Pushes elem onto the queue, increasing capacity of queue if necessary.
const_iterator cbegin() const
start const iterator
graph_node * my_nodes_last
void decrement_wait_count()
#define __TBB_ASSERT_EX(predicate, comment)
"Extended" version is useful to suppress warnings if a variable is only used with an assert
tbb::task * root_task()
Returns the root task of the graph.
static const node_priority_t no_priority
unsigned int node_priority_t
The base of all graph nodes.
void __TBB_EXPORTED_METHOD reset()
Forcefully reinitializes the context after the task tree it was associated with is completed.
A lock that occupies a single byte.
Base class for types that should not be assigned.
bool operator()(const graph_task *left, const graph_task *right)
void wait_for_all()
Wait for reference count to become one, and set reference count to zero.
internal::allocate_continuation_proxy & allocate_continuation()
Returns proxy for overloaded new that allocates a continuation task of *this.
graph_task_priority_queue_t & my_priority_queue
graph_iterator< graph, graph_node > iterator
Pure virtual template classes that define interfaces for async communication.
const GraphNodeType & const_reference
wait_functor(tbb::task *t)
void activate_graph(graph &g)
tbb::task * graph_root_task
iterator end()
end iterator
bool try_pop(reference elem)
Gets a reference to and removes highest priority element.
bool operator!=(const graph_iterator &other) const
Inequality.
void release_wait() __TBB_override
Deregisters an external entity that may have interacted with the graph.
void deactivate_graph(graph &g)
run_task(Body &body, node_priority_t node_priority=no_priority)
virtual void reset_node(reset_flags f=rf_reset_protocol)=0
std::list< tbb::task * > task_list_type
void reset(reset_flags f=rf_reset_protocol)
internal::graph_task_priority_queue_t my_priority_queue
GraphContainerType * my_graph
graph_iterator & operator=(const graph_iterator &other)
Assignment.
tbb::task_arena * my_task_arena
task * execute() __TBB_override
Should be overridden by derived classes.
tbb::task * execute() __TBB_override
Should be overridden by derived classes.
bool __TBB_EXPORTED_METHOD is_group_execution_cancelled() const
Returns true if the context received cancellation request.
graph_iterator & operator++()
Pre-increment.
iterator begin()
start iterator
graph_iterator(const graph_iterator &other)
Copy constructor.
tbb::task * execute() __TBB_override
Should be overridden by derived classes.
bool is_cancelled()
return status of graph execution
void execute_in_graph_arena(graph &g, F &f)
Executes custom functor inside graph arena.
void set_ref_count(int count)
Set reference count.
Concurrent priority queue.
void spawn_in_graph_arena(graph &g, tbb::task &arena_task)
Spawns a task inside graph arena.
graph()
Constructs a graph with isolated task_group_context.
void make_critical(task &t)
void prepare_task_arena(bool reinit=false)
void wait_for_all()
Wait until graph is idle and decrement_wait_count calls equals increment_wait_count calls.
task_list_type my_reset_task_list
priority_task_selector(graph_task_priority_queue_t &priority_queue)
bool is_graph_active(graph &g)
void reserve_wait() __TBB_override
Used to register that an external entity may still interact with the graph.
void initialize()
Forces allocation of the resources for the task_arena as specified in constructor arguments.
void const char const char int ITT_FORMAT __itt_group_sync x void const char * name
spawn_functor(tbb::task &t)
void run(Body body)
Spawns a task that runs a function object.
A functor that spawns a task.
tbb::concurrent_priority_queue< graph_task *, graph_task_comparator > graph_task_priority_queue_t
uintptr_t traits() const
Returns the context's trait.
run_and_put_task(Receiver &r, Body &body)