Intel(R) Threading Building Blocks Doxygen Documentation
version 4.2.3
|
Classes | |
class | successor_cache |
class | broadcast_cache |
class | round_robin_cache |
class | predecessor_cache |
class | reservable_predecessor_cache |
class | async_storage |
struct | async_helpers |
struct | async_helpers< T, typename std::enable_if< std::is_base_of< async_msg< typename T::async_msg_data_type >, T >::value >::type > |
class | untyped_sender |
class | untyped_receiver |
class | async_body_base |
class | async_body |
struct | graph_task_comparator |
class | priority_task_selector |
Typedefs | |
typedef tbb::concurrent_priority_queue< graph_task *, graph_task_comparator > | graph_task_priority_queue_t |
Functions | |
opencl_device_list | find_available_devices () |
void | activate_graph (tbb::flow::interface10::graph &g) |
void | deactivate_graph (tbb::flow::interface10::graph &g) |
bool | is_graph_active (tbb::flow::interface10::graph &g) |
tbb::task & | prioritize_task (tbb::flow::interface10::graph &g, tbb::task &arena_task) |
void | spawn_in_graph_arena (graph &g, tbb::task &arena_task) |
Spawns a task inside graph arena. More... | |
void | enqueue_in_graph_arena (graph &g, tbb::task &arena_task) |
Enqueues a task inside graph arena. More... | |
void | add_task_to_graph_reset_list (tbb::flow::interface10::graph &g, tbb::task *tp) |
typedef tbb::concurrent_priority_queue<graph_task*, graph_task_comparator> tbb::flow::interface11::internal::graph_task_priority_queue_t |
Definition at line 181 of file _flow_graph_impl.h.
|
inline |
Definition at line 486 of file _flow_graph_impl.h.
References tbb::flow::interface10::graph::my_is_active.
Referenced by tbb::flow::interface10::graph::reset().
|
inline |
Definition at line 537 of file _flow_graph_impl.h.
References tbb::flow::interface10::graph::my_reset_task_list.
Referenced by tbb::flow::interface11::source_node< Output >::reset_node().
|
inline |
Definition at line 490 of file _flow_graph_impl.h.
References tbb::flow::interface10::graph::my_is_active.
Referenced by tbb::flow::interface10::graph::reset().
|
inline |
Enqueues a task inside graph arena.
Definition at line 530 of file _flow_graph_impl.h.
References __TBB_ASSERT, tbb::task::enqueue(), tbb::interface7::task_arena::is_active(), is_graph_active(), tbb::flow::interface10::graph::my_task_arena, and prioritize_task().
Referenced by tbb::flow::interface11::async_node< Input, Output, Policy, Allocator >::try_put_impl().
|
inline |
Definition at line 294 of file flow_graph_opencl_node.h.
References tbb::flow::interface11::opencl_device_list::add(), d, tbb::flow::interface11::enforce_cl_retcode(), and p.
Referenced by tbb::flow::interface11::opencl_info::available_devices().
|
inline |
Definition at line 494 of file _flow_graph_impl.h.
References tbb::flow::interface10::graph::my_is_active.
Referenced by internal::function_input_base< Input, Policy, A, ImplType >::create_body_task(), internal::function_input_base< Input, Policy, A, ImplType >::create_forward_task(), internal::join_node_FE< reserving, InputTuple, OutputTuple >::decrement_port_count(), internal::join_node_FE< queueing, InputTuple, OutputTuple >::decrement_port_count(), enqueue_in_graph_arena(), internal::continue_input< Output, Policy >::execute(), internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::fill_output_buffer(), tbb::flow::interface11::limiter_node< T, DecrementType >::forward_task(), internal::join_node_base< JP, InputTuple, OutputTuple >::handle_operations(), tbb::flow::interface11::buffer_node< T, Allocator >::handle_operations_impl(), tbb::flow::interface11::limiter_node< T, DecrementType >::register_predecessor(), tbb::flow::interface11::limiter_node< T, DecrementType >::register_successor(), tbb::flow::interface11::overwrite_node< T >::register_successor(), tbb::flow::interface10::graph::run(), spawn_in_graph_arena(), and tbb::flow::interface11::limiter_node< T, DecrementType >::try_put_task().
|
inline |
Non-preemptive priority pattern. The original task is submitted as a work item to the priority queue, and a new critical task is created to take and execute a work item with the highest known priority. The reference counting responsibility is transferred (via allocate_continuation) to the new task.
Non-preemptive priority pattern. The original task is submitted as a work item to the priority queue, and a new critical task is created to take and execute a work item with the highest known priority. The reference counting responsibility is transferred (via allocate_continuation) to the new task.
Definition at line 499 of file _flow_graph_impl.h.
References tbb::task::allocate_continuation(), tbb::internal::make_critical(), tbb::flow::interface10::graph::my_priority_queue, tbb::flow::internal::no_priority, tbb::flow::interface11::graph_task::priority, and tbb::interface5::concurrent_priority_queue< T, Compare, A >::push().
Referenced by enqueue_in_graph_arena(), and spawn_in_graph_arena().
|
inline |
Spawns a task inside graph arena.
Definition at line 521 of file _flow_graph_impl.h.
References __TBB_ASSERT, tbb::interface7::task_arena::execute(), tbb::interface7::task_arena::is_active(), is_graph_active(), tbb::flow::interface10::graph::my_task_arena, and prioritize_task().
Referenced by internal::function_input< Input, Output, Policy, A >::apply_body_impl_bypass(), internal::check_task_and_spawn(), internal::join_node_FE< reserving, InputTuple, OutputTuple >::decrement_port_count(), internal::join_node_FE< queueing, InputTuple, OutputTuple >::decrement_port_count(), tbb::flow::interface11::buffer_node< T, Allocator >::enqueue_forwarding_task(), internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::fill_output_buffer(), tbb::flow::interface11::limiter_node< T, DecrementType >::forward_task(), internal::join_node_base< JP, InputTuple, OutputTuple >::handle_operations(), tbb::flow::interface11::limiter_node< T, DecrementType >::register_predecessor(), tbb::flow::interface11::limiter_node< T, DecrementType >::register_successor(), tbb::flow::interface11::overwrite_node< T >::register_successor(), tbb::flow::interface10::graph::reset(), internal::function_input_base< Input, Policy, A, ImplType >::spawn_forward_task(), tbb::flow::interface11::internal::untyped_receiver::try_put(), and tbb::flow::interface11::buffer_node< T, Allocator >::try_put_task().