Lines Matching refs:enqueue
204 a1.enqueue(work); // put async work in TestConcurrentArenasFunc()
207 a2.enqueue(work); // another work in TestConcurrentArenasFunc()
235 my_a.enqueue(AsynchronousWork(my_b2, /*blocking=*/false)); in operator ()()
280 my_a.enqueue(Runner(wait)); in operator ()()
302 …a.enqueue(AsynchronousWork(barrier, /*blocking=*/true)); // occupy the worker, a regression test f… in TestMultipleMasters()
481 a.enqueue( test ); in TestArenaConcurrency()
540 a.enqueue([&] { in TestMandatoryConcurrency()
683 a.enqueue( tf ); in TestConstantFunctorRequirement()
945 arena.enqueue([&]() { in execute()
997 arena.enqueue([&]() { in TestEnqueue()
1044 my_a.enqueue([this] { my_b1.wait(); }); // tasks to sync with workers in operator ()()
1207 ta.enqueue( MoveOnlyFunctor() ); in TestFunctors()
1208 ta.enqueue( mpf ); in TestFunctors()
1211 ta.enqueue( std::move(mpf) ); in TestFunctors()
1421 auto wakeup = [&arenas] { for (auto& a : arenas) a.enqueue([]{}); }; in TestArenaWorkersMigrationWithNumThreads()
1724 curr_arena->arena->enqueue([] { utils::doDummyWork(1000); }); in StressTestMixFunctionality()
1760 …if (my_task_counter++ < 100000) my_arena.enqueue(enqueue_test_helper(my_arena, my_ets, my_task_cou… in operator ()()
1782 a.enqueue([&] { in test_threads_sleep()
1966 arena.enqueue(enqueue_test_helper(arena, ets, task_counter));
1990 …CHECK_THROWS_WITH_AS(ta.enqueue(tbb::task_handle{}), "Attempt to schedule empty… in should_fail()
1991 …CHECK_THROWS_WITH_AS(tbb::this_task_arena::enqueue(tbb::task_handle{}), "Attempt to schedule empty… in should_fail()
2060 arena.enqueue([&] { in __anon1d1198c32802()