Searched refs:num_workers (Results 1 – 3 of 3) sorted by relevance
98 const size_t num_workers = std::min<size_t>(end, GetHardwareConcurrencyHint()); in TaskMapOverInt() local111 futures.reserve(num_workers); in TaskMapOverInt()112 for (size_t i = 0; i < num_workers; i++) in TaskMapOverInt()114 for (size_t i = 0; i < num_workers; i++) in TaskMapOverInt()
92 dt_create(const char *socket_path, unsigned num_workers);
138 dt_create(const char *socket_path, unsigned num_workers) in dt_create() argument152 log_assert(num_workers > 0); in dt_create()176 fstrm_iothr_options_set_num_input_queues(fopt, num_workers); in dt_create()