MCPcopy Create free account
hub / github.com/NthTensor/Forte / with_worker

Method with_worker

src/thread_pool.rs:388–396  ·  view source on GitHub ↗
(&'static self, func: F)

Source from the content-addressed store, hash-verified

386 })
387 .unwrap();
388 let control = ThreadControl { halt, handle };
389 managed_workers.push(ManagedWorker {
390 member_index,
391 control,
392 });
393 }
394
395 managed_workers.len()
396 }
397 // The size decreased
398 cmp::Ordering::Less => {
399 // Pull the workers we intend to halt out of the thread manager.

Callers 15

forteFunction · 0.80
throughput_forteFunction · 0.80
forteFunction · 0.80
forteFunction · 0.80
forteFunction · 0.80
joinMethod · 0.80
scopeMethod · 0.80
broadcastMethod · 0.80
spawn_broadcastMethod · 0.80
spawn_cancel_safetyFunction · 0.80
join_deepFunction · 0.80
join_wideFunction · 0.80

Calls 2

get_workerMethod · 0.80
with_worker_coldMethod · 0.80

Tested by 8

spawn_cancel_safetyFunction · 0.64
join_deepFunction · 0.64
join_wideFunction · 0.64
scope_concurrencyFunction · 0.64
scope_nesting_new_workerFunction · 0.64
scope_divide_and_conquerFunction · 0.64
scope_update_treeFunction · 0.64