Lines Matching refs:nthreads
987 for (std::size_t nthreads = MinThread; nthreads <= MaxThread; ++nthreads) { in TestAbort() local
995 SimplePushBody my_push_body1(&iq1, nthreads); in TestAbort()
996 utils::NativeParallelFor(nthreads + 1, my_push_body1); in TestAbort()
998 …REQUIRE_MESSAGE(failed_pushes == nthreads, "All threads should have failed to push an element to z… in TestAbort()
1000 if (nthreads < (MaxThread + MinThread) / 2) { in TestAbort()
1014 SimplePushBody my_push_body2(&iq2, nthreads); in TestAbort()
1015 utils::NativeParallelFor(nthreads + 1, my_push_body2); in TestAbort()
1017 if (nthreads>= 2) in TestAbort()
1018 …REQUIRE_MESSAGE(failed_pushes == nthreads - 2, "nthreads-2 threads should have failed to push an e… in TestAbort()
1032 SimplePopBody my_pop_body(&iq3, nthreads, 2); in TestAbort()
1033 utils::NativeParallelFor( nthreads+1, my_pop_body ); in TestAbort()
1035 if (nthreads>= 2) in TestAbort()
1036 …REQUIRE_MESSAGE(failed_pops == nthreads - 2, "nthreads-2 threads should have failed to pop an elem… in TestAbort()
1044 std::size_t cap = nthreads / 2; in TestAbort()
1052 SimplePushBody my_push_body2(&iq4, nthreads); in TestAbort()
1053 utils::NativeParallelFor(nthreads + 1, my_push_body2); in TestAbort()
1055 if (nthreads>= cap) in TestAbort()
1056 …REQUIRE_MESSAGE(failed_pushes == nthreads-cap, "nthreads-cap threads should have failed to push an… in TestAbort()
1057 SimplePopBody my_pop_body(&iq4, nthreads, num_pushed); in TestAbort()
1058 utils::NativeParallelFor( nthreads+1, my_pop_body ); in TestAbort()
1060 if (nthreads>= cap) in TestAbort()
1061 …REQUIRE_MESSAGE(failed_pops == nthreads-cap, "nthreads-cap threads should have failed to pop an el… in TestAbort()