Searched refs:num_threads (Results 1 – 10 of 10) sorted by relevance
38 num_threads=${NUM_THREADS:-16}100 out_name="benchmark_${operation}.t${num_threads}.s${syncval}.log"105 --threads=$num_threads \110 …rize_result $output_dir/${out_name} ${operation}.t${num_threads}.s${syncval} $operation $num_threa…115 out_name="benchmark_readrandom.t${num_threads}.log"119 --threads=$num_threads \124 summarize_result $output_dir/${out_name} readrandom.t${num_threads} readrandom $num_threads130 out_name="benchmark_readwhile${operation}.t${num_threads}.log"135 --threads=$num_threads \141 …ult $output_dir/${out_name} readwhile${operation}.t${num_threads} readwhile${operation} $num_threa…
49 num_threads=${NUM_THREADS:-64}234 --threads=$num_threads \261 --threads=$num_threads \343 --threads=$num_threads \368 out_name="benchmark_readrandom.t${num_threads}.log"372 --threads=$num_threads \388 --threads=$num_threads \401 out_name="benchmark_${full_name}.t${num_threads}.log"407 --threads=$num_threads \421 out_name="benchmark_${full_name}.t${num_threads}.log"[all …]
2887 int num_threads = FLAGS_threads; in Run() local2930 if (num_threads > 1) { in Run()2934 num_threads = 1; in Run()2954 if (num_threads > 1) { in Run()2958 num_threads = 1; in Run()2985 num_threads = 1; in Run()3009 num_threads++; // Add extra thread for writing in Run()3014 num_threads++; // Add extra thread for writing in Run()3017 num_threads++; // Add extra thread for merging in Run()3105 if (num_threads > 1) { in Run()[all …]
224 uint32_t num_threads = 4; in TEST_F() local243 for (uint64_t i = 1 + t; i <= num_keys; i += num_threads) { in TEST_F()248 for (size_t t = 0; t < num_threads; ++t) { in TEST_F()259 static_cast<double>(elapsed) / num_threads / num_keys); in TEST_F()266 for (uint64_t i = 1 + t; i <= num_keys; i += num_threads) { in TEST_F()272 for (size_t t = 0; t < num_threads; ++t) { in TEST_F()283 static_cast<double>(elapsed) / num_threads / num_keys); in TEST_F()291 for (uint64_t i = num_keys + 1 + t; i <= 2 * num_keys; i += num_threads) { in TEST_F()299 for (size_t t = 0; t < num_threads; ++t) { in TEST_F()310 static_cast<double>(elapsed) / num_threads / num_keys, in TEST_F()
502 ThreadPool* NewThreadPool(int num_threads) { in NewThreadPool() argument504 thread_pool->SetBackgroundThreads(num_threads); in NewThreadPool()
56 extern ThreadPool* NewThreadPool(int num_threads);
98 num_threads, 1,408 uint64_t* sequence, uint32_t num_threads) in Benchmark() argument412 num_threads_(num_threads) {} in Benchmark()
573 const size_t num_threads = compact_->sub_compact_states.size(); in Run() local574 assert(num_threads > 0); in Run()579 thread_pool.reserve(num_threads - 1); in Run()
1456 const size_t num_threads = 4; in TEST_P() local1472 for (uint32_t i = 0; i < num_threads; i++) { in TEST_P()
9551 return static_cast<size_t>(process_info.num_threads); in GetThreadCount()