Searched refs:worker_threads (Results 1 – 5 of 5) sorted by relevance
61 worker_threads: VecDeque::new(), in new()83 let workers = std::mem::take(&mut shared.worker_threads); in shutdown()163 worker_threads: VecDeque<(usize, thread::JoinHandle<()>)>, field183 shared.worker_threads.push_back((worker_id, join_handle)); in create_permanent_threads()243 shared.worker_threads.push_back((worker_id, join_handle)); in spawn()296 for (thread_id, thread) in shared.worker_threads.iter().enumerate() { in wait_temporary()298 shared.worker_threads.remove(thread_id); in wait_temporary()512 .worker_threads in ut_blocking_pool_spawner_create_permanent_threads()540 .worker_threads in ut_blocking_pool_spawner_create_permanent_threads()
147 .worker_threads(4) in sdv_async_h2_client_send_request()221 .worker_threads(4) in sdv_async_h2_client_send_request_concurrently()
74 .worker_threads(threads_count) in tokio_runtime_set_threads()
414 .worker_threads(thread_num) in init_test_work_runtime()
40 self.worker_threads = multiprocessing.cpu_count() // 2