| /oneTBB/src/tbb/ |
| H A D | task_dispatcher.cpp | 24 static inline void spawn_and_notify(d1::task& t, arena_slot* slot, arena* a) { in spawn_and_notify() 30 void __TBB_EXPORTED_FUNC spawn(d1::task& t, d1::task_group_context& ctx) { in spawn() 42 void __TBB_EXPORTED_FUNC spawn(d1::task& t, d1::task_group_context& ctx, d1::slot_id id) { in spawn() 77 void __TBB_EXPORTED_FUNC submit(d1::task& t, d1::task_group_context& ctx, arena* a, std::uintptr_t … in submit() 119 void __TBB_EXPORTED_FUNC execute_and_wait(d1::task& t, d1::task_group_context& t_ctx, d1::wait_cont… in execute_and_wait() 153 void task_dispatcher::execute_and_wait(d1::task* t, d1::wait_context& wait_ctx, d1::task_group_cont… in execute_and_wait()
|
| H A D | waiters.h | 57 bool continue_execution(arena_slot& slot, d1::task*& t) const { in continue_execution() 127 bool continue_execution(arena_slot& slot, d1::task*& t) const { in continue_execution() 163 bool continue_execution(arena_slot& slot, d1::task*& t) const { in continue_execution() 185 static bool postpone_execution(d1::task& t) { in postpone_execution()
|
| H A D | task_dispatcher.h | 46 d1::task* t = nullptr; in get_self_recall_task() local 162 if (d1::task* t = a.steal_task(arena_index, random, ed, isolation)) { in steal_or_get_critical() local 177 d1::task* t = nullptr; in receive_or_steal_task() local 243 d1::task* task_dispatcher::local_wait_for_all(d1::task* t, Waiter& waiter ) { in local_wait_for_all() 396 inline d1::task* task_dispatcher::get_critical_task(d1::task* t, execution_data_ext& ed, isolation_… in get_critical_task() 436 inline d1::task* task_dispatcher::get_critical_task(d1::task* t, execution_data_ext&, isolation_typ… in get_critical_task() 455 d1::task* task_dispatcher::local_wait_for_all(d1::task* t, Waiter& waiter) { in local_wait_for_all()
|
| H A D | threading_control_client.h | 35 …threading_control_client(pm_client* p, thread_dispatcher_client* t) : my_pm_client(p), my_thread_d… in threading_control_client()
|
| H A D | itt_notify.h | 83 #define ITT_CALLEE_ENTER(cond, t, obj) if(cond) {\ argument 103 #define ITT_CALLEE_ENTER(cond, t, obj) ((void)0) argument
|
| /oneTBB/include/oneapi/tbb/detail/ |
| H A D | _flow_graph_node_impl.h | 41 bool push( T& t ) { in push() 89 graph_task* try_put_task( const input_type& t) override { in try_put_task() 161 operation_type(const input_type& e, op_type t) : in operation_type() 163 operation_type(op_type t) : type(char(t)), r(nullptr), bypass_t(nullptr) {} in operation_type() 261 graph_task* internal_try_put_bypass( const input_type& t ) { in internal_try_put_bypass() 270 graph_task* try_put_task_impl( const input_type& t, /*lightweight=*/std::true_type ) { in try_put_task_impl() 283 graph_task* try_put_task_impl( const input_type& t, /*lightweight=*/std::false_type ) { in try_put_task_impl() 305 …graph_task* t = allocator.new_object<task_type>( my_graph_ref, allocator, *this, input, my_priorit… in create_body_task() local 332 …graph_task* t = allocator.new_object<task_type>( graph_reference(), allocator, *this, my_priority … in create_forward_task() local
|
| H A D | _task.h | 180 inline void spawn(task& t, task_group_context& ctx) { in spawn() 185 inline void spawn(task& t, task_group_context& ctx, slot_id id) { in spawn() 190 inline void execute_and_wait(task& t, task_group_context& t_ctx, wait_context& wait_ctx, task_group… in execute_and_wait()
|
| H A D | _flow_graph_cache_impl.h | 346 graph_task* try_put_task( const T &t ) override { in try_put_task() 370 bool gather_successful_try_puts( const T &t, graph_task_list& tasks ) { in gather_successful_try_puts() 414 graph_task* try_put_task( const T &t ) override { in try_put_task()
|
| H A D | _task_handle.h | 87 task_handle(task_handle_task* t) : m_handle {t}{}; in task_handle()
|
| /oneTBB/examples/parallel_for/tachyon/src/ |
| H A D | triangle.cpp | 71 tri *t; in newtri() local 98 stri *t; in newstri() local 140 tri *t = (tri *)obj; in tri_bbox() local 159 flt det, inv_det, t, u, v; in tri_intersect() local
|
| H A D | intersect.cpp | 118 void add_intersection(flt t, object *obj, ray *ry) { in add_intersection() 138 int closest_intersection(flt *t, object **obj, intersectstruct *intstruct) { in closest_intersection()
|
| H A D | cylinder.cpp | 92 flt t, s, tin, tout, ln, d; in cylinder_intersect() local 136 flt t; in cylinder_normal() local 205 flt t, s, tin, tout, ln, d, tmp, tmp3; in fcylinder_intersect() local
|
| H A D | plane.cpp | 85 flt t, td; in plane_intersect() local
|
| H A D | ring.cpp | 96 flt t, td; in ring_intersect() local
|
| /oneTBB/examples/parallel_for/game_of_life/ |
| H A D | Evolution.cpp | 61 oneapi::tbb::tick_count t = oneapi::tbb::tick_count::now(); in Run() local 112 oneapi::tbb::tick_count t = oneapi::tbb::tick_count::now(); in Run() local
|
| /oneTBB/test/tbb/ |
| H A D | test_buffer_node.cpp | 229 touches< T > t( num_threads ); in test_parallel() local 240 touches< T > t( num_threads ); in test_parallel() local 254 touches< T > t( num_threads ); in test_parallel() local 284 touches< T > t( num_threads ); in test_parallel() local
|
| H A D | test_flow_graph_whitebox.cpp | 92 std::thread t([&] { in TestBufferingNode() local 167 std::thread t([&] { in TestContinueNode() local 266 std::thread t([&] { in TestFunctionNode() local 350 tbb::flow::tag_value t = tbb::flow::tag_value(v / my_mult); in operator ()() local 586 std::thread t([&] { in TestMultifunctionNode() local 674 std::thread t([&]{ in TestSequencerNode() local
|
| H A D | test_overwrite_node.cpp | 41 for ( int t = 0; t < T; ++t ) { in simple_read_write_tests() local 112 for ( int t = 0; t < T; ++t ) { in parallel_read_write_tests() local
|
| H A D | test_write_once_node.cpp | 42 for ( int t = 0; t < T; ++t ) { in simple_read_write_tests() local 134 for ( int t = 0; t < T; ++t ) { in parallel_read_write_tests() local
|
| H A D | test_enumerable_thread_specific.cpp | 73 T& check_alignment(T& t, const char *aname) { in check_alignment() 82 const T& check_alignment(const T& t, const char *aname) { in check_alignment() 344 typedef struct { char t; U padded; } test_alignment; member
|
| H A D | test_join_node.cpp | 82 for(int t = 1; t<=maxTag; ++t) tag_queue.try_put(t); in test() local
|
| /oneTBB/examples/parallel_for/seismic/ |
| H A D | universe.cpp | 54 ValueType t = (ValueType)i / (ValueType)UniverseHeight; in InitializeUniverse() local 82 ValueType t = (i - ColorMapSize / 2) * scale; in InitializeUniverse() local 110 ValueType t = (pulseCounter - pulseTime / 2) * 0.05f; in UpdatePulse() local
|
| /oneTBB/test/conformance/ |
| H A D | conformance_resumable_tasks.cpp | 36 std::thread t; variable
|
| /oneTBB/examples/parallel_pipeline/square/ |
| H A D | square.cpp | 50 TextSlice* t = (TextSlice*)oneapi::tbb::tbb_allocator<char>().allocate(sizeof(TextSlice) + in allocate() local 122 TextSlice* t = next_slice; in operator ()() local
|
| /oneTBB/examples/graph/cholesky/ |
| H A D | cholesky.cpp | 163 algorithm(const std::string &alg_name, bool t) : name(alg_name), is_tiled(t) {} in algorithm() 334 tag_t t; in operator ()() local 365 tag_t t; in operator ()() local 396 tag_t t; in operator ()() local 497 tag_t t; in func() local 550 continue_ptr_type **t = new continue_ptr_type *[p]; in func() local
|