| /oneTBB/test/conformance/ |
| H A D | conformance_collaborative_call_once.cpp | 62 for (int iter = 0; iter < 100; ++iter) { variable
66 }, iter); in __anon8e61f74e0102()
|
| H A D | conformance_enumerable_thread_specific.cpp | 1102 auto iter = ets.begin(); in TestETSIterator() local
1103 while(iter != ets.end()) { in TestETSIterator()
1104 ++counter % 2 == 0 ? ++iter : iter++; in TestETSIterator()
1107 while(iter != ets.begin()) { in TestETSIterator()
1108 --counter % 2 == 0 ? --iter : iter--; in TestETSIterator()
|
| H A D | conformance_concurrent_queue.cpp | 421 typename CQ::const_iterator iter; in TestConstructors() local
480 iter = src_queue.unsafe_begin(); in TestConstructors()
481 auto res = std::mismatch(dqb, dqe, iter); in TestConstructors()
491 iter = src_queue.unsafe_begin(); in TestConstructors()
492 REQUIRE_MESSAGE(std::equal(dqb, dqe, iter), "unexpected element"); in TestConstructors()
508 iter = src_queue.unsafe_begin(); in TestConstructors()
509 auto res = std::mismatch(dqb, dqe, iter); in TestConstructors()
|
| /oneTBB/test/tbb/ |
| H A D | test_eh_flow_graph.cpp | 511 for(int iter = 0; iter < 2; ++iter) { // run, reset, run again in run_one_functype_node_test() local
816 for(int iter = 0; iter < 2; ++iter) { in run_one_continue_node_test() local
931 for(int iter = 0; iter < 2; ++iter) { in run_one_buffer_node_test() local
960 if(iter == 0) { in run_one_buffer_node_test()
1065 for(int iter = 0; iter < 2; ++iter) { in run_one_sequencer_node_test() local
1188 for(int iter = 0; iter < 2; ++iter) { in run_one_priority_queue_node_test() local
1330 for(int iter = 0; iter < 2; ++iter) { in execute_test() local
1440 for(int iter = 0; iter < 2; ++iter) { in execute_test() local
1572 for(int iter = 0; iter < 2; ++iter) { in run_one_limiter_node_test() local
1698 for(int iter = 0; iter < 2; ++iter) { // run, reset, run again in run_one_split_node_test() local
[all …]
|
| H A D | test_resumable_tasks.cpp | 347 std::atomic<int> iter{}; in TestNativeThread() local
348 … utils::NativeParallelFor(arena.max_concurrency() / 2, [&arena, &tg, &asyncActivity, &iter](int) { in TestNativeThread()
350 arena.execute([&tg, &asyncActivity, &iter]() { in TestNativeThread()
354 iter++; in TestNativeThread()
359 CHECK(iter == (arena.max_concurrency() / 2 * 10)); in TestNativeThread()
|
| /oneTBB/python/tbb/ |
| H A D | test.py | 113 assert list(pool.imap(return42, iter([]))) == []
114 assert list(pool.imap_unordered(return42, iter([]))) == []
116 assert list(pool.imap_async(return42, iter([])).get()) == []
117 assert list(pool.imap_unordered_async(return42, iter([])).get()) == []
|
| H A D | pool.py | 130 return iter(collector)
139 return iter(collector)
184 apply_result._set_value(iter([]))
201 apply_result._set_value(iter([]))
245 it_ = iter(iterable)
552 self._to_notify._set_value(iter(self))
619 self._to_notify._set_value(iter(self))
|
| /oneTBB/examples/task_arena/fractal/ |
| H A D | fractal.cpp | 32 unsigned int iter; in calc_one_pixel() local
42 iter = 0; in calc_one_pixel()
47 while (((x * x + y * y) <= 4) && (iter < max_iterations)) { in calc_one_pixel()
52 iter++; in calc_one_pixel()
55 if (iter == max_iterations) { in calc_one_pixel()
|
| /oneTBB/doc/main/tbb_userguide/ |
| H A D | Iterating_Over_a_Concurrent_Queue_for_Debugging.rst | 21 typedef concurrent_queue<Foo>::const_iterator iter;
22 for(iter i(q.unsafe_begin()); i!=q.unsafe_end(); ++i ) {
|
| /oneTBB/test/common/ |
| H A D | doctest.h | 2276 #define DOCTEST_TEST_CASE_TEMPLATE_DEFINE_IMPL(dec, T, iter, func) \
2281 struct iter; \
2283 struct iter<std::tuple<Type, Rest...>> \
2285 iter(const char* file, unsigned line, int index) { \
2291 iter<std::tuple<Rest...>>(file, line, index + 1); \
2295 struct iter<std::tuple<>> \
2297 iter(const char*, unsigned, int) {} \
|