206         g_TGCCancelled.validate( g_NumThreads, "Too many tasks ran after exception thrown");  in TestParallelLoopAux()
207 …REQUIRE_MESSAGE(g_CurExecuted <= g_ExecutedAtLastCatch + g_NumThreads, "Too many tasks survived ex…  in TestParallelLoopAux()
303             minExecuted = (g_NumThreads - 1) * innerCalls;  in Test3()
324         g_TGCCancelled.validate(g_NumThreads, "Too many tasks survived exception");  in Test3()
326 …REQUIRE_MESSAGE ((g_CurExecuted <= minExecuted + (g_ExecutedAtLastCatch + g_NumThreads)), "Too man…  in Test3()
330 …REQUIRE_MESSAGE ((g_CurExecuted <= g_ExecutedAtLastCatch + g_NumThreads), "Too many tasks survived…  in Test3()
369         g_TGCCancelled.validate(g_NumThreads, "Too many tasks survived exception");  in Test4()
374 …REQUIRE_MESSAGE (g_CurExecuted <= minExecuted + (g_ExecutedAtLastCatch + g_NumThreads), "Too many …  in Test4()
379 …REQUIRE_MESSAGE ((g_CurExecuted <= g_ExecutedAtLastCatch + g_NumThreads), "Too many tasks survived…  in Test4()
380 …REQUIRE_MESSAGE (g_CurExecuted <= outerCalls * (1 + g_NumThreads), "Too many tasks survived except…  in Test4()
388         g_NumThreads = static_cast<int>(concurrency_level);
390         if (g_NumThreads > 1) {
391             tbb::task_arena a(g_NumThreads);
409         g_NumThreads = static_cast<int>(concurrency_level);
411         if (g_NumThreads > 1) {
412             tbb::task_arena a(g_NumThreads);
430         g_NumThreads = static_cast<int>(concurrency_level);
432         if (g_NumThreads > 1) {
433             tbb::task_arena a(g_NumThreads);
451         g_NumThreads = static_cast<int>(concurrency_level);
453         if (g_NumThreads > 1) {
454             tbb::task_arena a(g_NumThreads);
472         g_NumThreads = static_cast<int>(concurrency_level);
474         if (g_NumThreads > 1) {
475             tbb::task_arena a(g_NumThreads);
545 …REQUIRE_MESSAGE (g_ExecutedAtLastCatch < g_NumThreads, "Somehow worker tasks started their executi…  in TestCancelation2()
546     g_TGCCancelled.validate(g_NumThreads, "Too many tasks survived cancellation");  in TestCancelation2()
547 …REQUIRE_MESSAGE (g_CurExecuted <= g_ExecutedAtLastCatch + g_NumThreads, "Some tasks were executed …  in TestCancelation2()
684         g_NumThreads = static_cast<int>(concurrency_level);
686         if (g_NumThreads > 1) {
687             tbb::task_arena a(g_NumThreads);
705         g_NumThreads = static_cast<int>(concurrency_level);
707         if (g_NumThreads > 1) {
708             tbb::task_arena a(g_NumThreads);
726         g_NumThreads = static_cast<int>(concurrency_level);
728         if (g_NumThreads > 1) {
729             tbb::task_arena a(g_NumThreads);
747         g_NumThreads = static_cast<int>(concurrency_level);
749         if (g_NumThreads > 1) {
750             tbb::task_arena a(g_NumThreads);
770     return std::max(50, g_NumThreads * 2);  in get_iter_range_size()
845 …REQUIRE_MESSAGE (g_CurExecuted <= g_ExecutedAtLastCatch + g_NumThreads, "Too many tasks survived e…  in Test1_parallel_for_each()
846     g_TGCCancelled.validate(g_NumThreads, "Too many tasks survived cancellation");  in Test1_parallel_for_each()
849 …REQUIRE_MESSAGE (g_CurExecuted <= g_ExecutedAtLastCatch + g_NumThreads, "Too many tasks survived e…  in Test1_parallel_for_each()
884 …REQUIRE_MESSAGE (g_CurExecuted <= g_ExecutedAtLastCatch + g_NumThreads, "Too many tasks survived e…  in Test2_parallel_for_each()
885     g_TGCCancelled.validate(g_NumThreads, "Too many tasks survived cancellation");  in Test2_parallel_for_each()
888 …REQUIRE_MESSAGE (g_CurExecuted <= g_ExecutedAtLastCatch + g_NumThreads, "Too many tasks survived e…  in Test2_parallel_for_each()
923              minExecuted = (g_NumThreads - 1) * innerCalls;  in Test3_parallel_for_each()
931     g_TGCCancelled.validate(g_NumThreads, "Too many tasks survived exception");  in Test3_parallel_for_each()
934 …REQUIRE_MESSAGE (g_CurExecuted <= minExecuted + (g_ExecutedAtLastCatch + g_NumThreads), "Too many …  in Test3_parallel_for_each()
938 …REQUIRE_MESSAGE (g_CurExecuted <= g_ExecutedAtLastCatch + g_NumThreads, "Too many tasks survived e…  in Test3_parallel_for_each()
983     g_TGCCancelled.validate(g_NumThreads, "Too many tasks survived exception");  in Test4_parallel_for_each()
997 …REQUIRE_MESSAGE (g_CurExecuted < g_ExecutedAtLastCatch + g_NumThreads + outerCalls, "Too many task…  in Test4_parallel_for_each()
998 …REQUIRE_MESSAGE (g_CurExecuted <= outerCalls * (1 + g_NumThreads), "Too many tasks survived except…  in Test4_parallel_for_each()
1040         g_NumThreads = static_cast<int>(concurrency_level);
1042         if (g_NumThreads > 1) {
1043             tbb::task_arena a(g_NumThreads);
1061         g_NumThreads = static_cast<int>(concurrency_level);
1063         if (g_NumThreads > 1) {
1064             tbb::task_arena a(g_NumThreads);
1082         g_NumThreads = static_cast<int>(concurrency_level);
1084         if (g_NumThreads > 1) {
1085             tbb::task_arena a(g_NumThreads);
1103         g_NumThreads = static_cast<int>(concurrency_level);
1105         if (g_NumThreads > 1) {
1106             tbb::task_arena a(g_NumThreads);
1124         g_NumThreads = static_cast<int>(concurrency_level);
1126         if (g_NumThreads > 1) {
1127             tbb::task_arena a(g_NumThreads);
1179 …REQUIRE_MESSAGE(get_iter_range_size() - threshold > g_NumThreads, "Threshold should leave more tha…  in TestCancelation1_parallel_for_each()
1190 …REQUIRE_MESSAGE (g_CurExecuted < g_ExecutedAtLastCatch + g_NumThreads, "Too many tasks were execut…  in TestCancelation1_parallel_for_each()
1224         g_NumThreads = static_cast<int>(concurrency_level);
1226         if (g_NumThreads > 1) {
1227             tbb::task_arena a(g_NumThreads);
1244         g_NumThreads = static_cast<int>(concurrency_level);
1246         if (g_NumThreads > 1) {
1247             tbb::task_arena a(g_NumThreads);
1318                 WaitUntilConcurrencyPeaks( std::min(g_NumTokens, g_NumThreads) );  in operator ()()
1391     g_TGCCancelled.validate(g_NumThreads, "Too many tasks survived exception");  in Test1_pipeline()
1392 …REQUIRE_MESSAGE (g_CurExecuted <= g_ExecutedAtLastCatch + g_NumThreads, "Too many tasks survived e…  in Test1_pipeline()
1395 …REQUIRE_MESSAGE (g_CurExecuted <= g_ExecutedAtLastCatch + g_NumThreads, "Too many tasks survived e…  in Test1_pipeline()
1427 …REQUIRE_MESSAGE (g_CurExecuted <= g_ExecutedAtLastCatch + g_NumThreads, "Too many tasks survived e…  in Test2_pipeline()
1458                  minExecuted = (g_NumThreads - 1) * innerCalls;  in Test3_pipeline()
1494                 g_TGCCancelled.validate(g_NumThreads, "Tasks not in-flight were executed");  in Test3_pipeline()
1500 …REQUIRE_MESSAGE (((g_CurExecuted <= g_ExecutedAtLastCatch + g_NumThreads) || okayNoExceptionCaught…  in Test3_pipeline()
1550 …g_TGCCancelled.validate(g_NumThreads, "Too many tasks survived exception");  // probably will asse…  in Test4_pipeline()
1563 …REQUIRE_MESSAGE (g_CurExecuted <= g_ExecutedAtLastCatch + g_NumThreads, "Too many tasks survived m…  in Test4_pipeline()
1576         g_NumThreads = static_cast<int>(concurrency_level);  in TestWithDifferentFiltersAndConcurrency()
1578         if (g_NumThreads > 1) {  in TestWithDifferentFiltersAndConcurrency()
1590                 tbb::task_arena a(g_NumThreads);  in TestWithDifferentFiltersAndConcurrency()
1594                     g_NumTokens = 2 * g_NumThreads;  in TestWithDifferentFiltersAndConcurrency()
1672 …REQUIRE_MESSAGE(get_iter_range_size() - threshold > g_NumThreads, "Threshold should leave more tha…  in TestCancelation1_pipeline()
1674     g_TGCCancelled.validate(g_NumThreads, "Too many tasks survived cancellation");  in TestCancelation1_pipeline()
1675 …REQUIRE_MESSAGE (g_CurExecuted < g_ExecutedAtLastCatch + g_NumThreads, "Too many tasks were execut…  in TestCancelation1_pipeline()
1712         g_NumThreads = static_cast<int>(concurrency_level);
1714         if (g_NumThreads > 1) {
1715             tbb::task_arena a(g_NumThreads);
1721                     g_NumTokens = 2 * g_NumThreads;  in __anone85726901202()
1734         g_NumThreads = static_cast<int>(concurrency_level);
1736         if (g_NumThreads > 1) {
1737             tbb::task_arena a(g_NumThreads);
1743                     g_NumTokens = 2 * g_NumThreads;  in __anone85726901302()