593     const std::size_t nthread;  member
594 …veQueueBody( oneapi::tbb::concurrent_bounded_queue<T>& q, std::size_t n ) : queue(q), nthread(n) {}  in TestNegativeQueueBody()
597             int number_of_pops = int(nthread) - 1;  in operator ()()
620 void TestNegativeQueue( std::size_t nthread ) {  in TestNegativeQueue()  argument
622     utils::NativeParallelFor( nthread, TestNegativeQueueBody<T>(queue,nthread));  in TestNegativeQueue()
641     const std::size_t nthread;  member
642     Body( std::size_t nthread_ ) : nthread(nthread_) {}  in Body()
646         memset(serial, 0, nthread * sizeof(std::size_t));  in operator ()()
647         CHECK(thread_id < nthread);  in operator ()()
667             CHECK_FAST(f.get_thread_id() <= nthread);  in operator ()()
668 …CHECK_FAST_MESSAGE((f.get_thread_id() == nthread || serial[f.get_thread_id()] < f.get_serial()), "…  in operator ()()
679 void TestPushPop(typename CQ::size_type prefill, std::ptrdiff_t capacity, std::size_t nthread ) {  in TestPushPop()  argument
681     CHECK(nthread> 0);  in TestPushPop()
695         Body<CQ,T> body(nthread);  in TestPushPop()
701             f.set_thread_id(nthread);  in TestPushPop()
708         utils::NativeParallelFor( nthread, body);  in TestPushPop()
711         for (std::size_t k = 0; k < nthread; ++k) {  in TestPushPop()
715         int expected = int( nthread * ((M - 1) * M / 2) + ((prefill - 1) * prefill) / 2);  in TestPushPop()
731         if (nthread> 1 && prefill == 0) {  in TestPushPop()
742 …                 nthread, long(PopKind[k]), k==0?"failed":"succeeded", max_trial, min_requirement);  in TestPushPop()
753     for (std::size_t nthread = MinThread; nthread <= MaxThread; ++nthread) {  in TestConcurrentPushPop()  local
754         INFO(" Testing with "<< nthread << " thread(s)");  in TestConcurrentPushPop()
755         TestNegativeQueue<move_support_tests::Foo>(nthread);  in TestConcurrentPushPop()
757 …opWrapper<move_support_tests::Foo>, move_support_tests::Foo>(prefill, std::ptrdiff_t(-1), nthread);  in TestConcurrentPushPop()
758 …PopWrapper<move_support_tests::Foo>, move_support_tests::Foo>(prefill, std::ptrdiff_t(1), nthread);  in TestConcurrentPushPop()
759 …PopWrapper<move_support_tests::Foo>, move_support_tests::Foo>(prefill, std::ptrdiff_t(2), nthread);  in TestConcurrentPushPop()
760 …opWrapper<move_support_tests::Foo>, move_support_tests::Foo>(prefill, std::ptrdiff_t(10), nthread);  in TestConcurrentPushPop()
761 …pWrapper<move_support_tests::Foo>, move_support_tests::Foo>(prefill, std::ptrdiff_t(100), nthread);  in TestConcurrentPushPop()
765                 move_support_tests::Foo>(prefill, std::ptrdiff_t(-1), nthread);  in TestConcurrentPushPop()
767                 move_support_tests::Foo>(prefill, std::ptrdiff_t(1), nthread);  in TestConcurrentPushPop()
769                 move_support_tests::Foo>(prefill, std::ptrdiff_t(2), nthread);  in TestConcurrentPushPop()
771                 move_support_tests::Foo>(prefill, std::ptrdiff_t(10), nthread);  in TestConcurrentPushPop()
773                 move_support_tests::Foo>(prefill, std::ptrdiff_t(100), nthread);  in TestConcurrentPushPop()