Home
last modified time | relevance | path

Searched refs:processed (Results 1 – 12 of 12) sorted by relevance

/oneTBB/doc/main/tbb_userguide/
H A DCook_Until_Done_parallel_do.rst16 can be safely processed in parallel, and processing each item takes at
84 processed.
H A Davoid_dynamic_node_removal.rst22 nodes while there are messages being processed in the graph can lead to
H A DParallelizing_Flow_Graph.rst22 where a sequence of values is processed as each value passes through the
27 completely processed, sum is equal to the sum of the sequence of squares
H A DNodes.rst85 You can then wait for the messages to be processed by calling
107 In the above graph, each message is processed sequentially. If however,
H A DWorking_on_the_Assembly_Line_pipeline.rst130 a serial in-order filter, each token must be processed serially in
131 order. In a parallel filter, multiple tokens can by processed in
192 the item until its predecessors are processed. There is another kind of
235 points to the ``TextSlice`` to be processed. Since it is used for the
H A Davoiding_data_races.rst57 processed sequentially by ``f``. You may also note that the ``input_node`` also
H A Dbroadcast_or_send.rst86 in the graph above, where each message will be processed in priority
/oneTBB/doc/
H A Dtest_classification.dox14 /// processed correctly. Additionally, this class of tests might
H A DDoxyfile.in299 # The output of markdown processing is further processed by doxygen, so you can
949 # properly processed by doxygen.
962 # properly processed by doxygen.
1612 # which needs to be processed by an external indexer. Doxygen will invoke an
2081 # contain include files that are not input files but should be processed by the
/oneTBB/test/tbb/
H A Dtest_task_arena.cpp1076 …, int num_tasks, std::vector<wait_context*>& waiters, std::atomic<int>& processed, tbb::task_group… in TestMultipleWaitsArenaWait() argument
1077 …h_size ), my_num_tasks(num_tasks), my_waiters( waiters ), my_processed( processed ), my_context(tg… in TestMultipleWaitsArenaWait()
1101 …::task_arena& a, std::vector<wait_context*>& waiters, std::atomic<int>& processed, tbb::task_group… in TestMultipleWaitsThreadBody() argument
1102 …tasks( num_tasks ), my_arena( a ), my_waiters( waiters ), my_processed( processed ), my_context(tg… in TestMultipleWaitsThreadBody()
1124 std::atomic<int> processed(0); in TestMultipleWaits() local
1129 while ( processed < bunch*bunch_size ) utils::yield(); in TestMultipleWaits()
1133 …thread( TestMultipleWaitsThreadBody( bunch_size, num_tasks, a, waiters, processed, tgc ), idx++ ).… in TestMultipleWaits()
1139 …std::thread( TestMultipleWaitsThreadBody( bunch_size, num_tasks, a, waiters, processed, tgc ), idx… in TestMultipleWaits()
1140 while ( processed ) utils::yield(); in TestMultipleWaits()
H A Dtest_limiter_node.cpp513 std::atomic<int> processed; in test_decrement_while_try_put_task() local
524 processed.store(value); in test_decrement_while_try_put_task()
534 CHECK_MESSAGE(processed.load() == threshold, "decrementer terminate flow graph work"); in test_decrement_while_try_put_task()
/oneTBB/doc/main/tbb_userguide/design_patterns/
H A DWavefront.rst50 have no predessors (have counts of zero). After an item is processed,