Searched refs:thds (Results 1 – 8 of 8) sorted by relevance
81 grpc_core::Thread thds[100]; in test_mt() local82 thd_args ta[GPR_ARRAY_SIZE(thds)]; in test_mt()84 for (size_t i = 0; i < GPR_ARRAY_SIZE(thds); i++) { in test_mt()88 thds[i] = grpc_core::Thread("grpc_mt_test", test_thread, &ta[i]); in test_mt()89 thds[i].Start(); in test_mt()94 while (num_done != GPR_ARRAY_SIZE(thds)) { in test_mt()106 for (auto& th : thds) { in test_mt()148 grpc_core::Thread thds[50]; in test_mt_multipop() local150 thd_args ta[GPR_ARRAY_SIZE(thds)]; in test_mt_multipop()152 for (size_t i = 0; i < GPR_ARRAY_SIZE(thds); i++) { in test_mt_multipop()[all …]
55 grpc_core::Thread thds[NUM_THREADS]; in test1() local61 for (auto& th : thds) { in test1()70 for (auto& th : thds) { in test1()82 grpc_core::Thread thds[NUM_THREADS]; in test2() local83 for (auto& th : thds) { in test2()89 for (auto& th : thds) { in test2()
68 grpc_core::Thread thds[CONCURRENT_TEST_THREADS]; in test_thd_count() local77 thds[i] = in test_thd_count()79 thds[i].Start(); in test_thd_count()83 for (auto& thd : thds) { in test_thd_count()
97 grpc_core::Thread thds[100]; in test_execute_many() local98 thd_args ta[GPR_ARRAY_SIZE(thds)]; in test_execute_many()99 for (size_t i = 0; i < GPR_ARRAY_SIZE(thds); i++) { in test_execute_many()103 thds[i] = grpc_core::Thread("grpc_execute_many", execute_many_loop, &ta[i]); in test_execute_many()104 thds[i].Start(); in test_execute_many()106 for (size_t i = 0; i < GPR_ARRAY_SIZE(thds); i++) { in test_execute_many()109 thds[i].Join(); in test_execute_many()
23 thds = []25 thds << Thread.new do34 thds.each(&:join)
101 grpc_core::Thread thds[CONCURRENT_TEST_THREADS]; in concurrent_test() local104 thds[i] = in concurrent_test()106 thds[i].Start(); in concurrent_test()111 for (auto& th : thds) { in concurrent_test()
106 thds = []108 thds << Thread.new do121 thds.each(&:join)
382 thds = 2.times.map do389 thds.map(&:join)