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

Method with_worker_cold

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

Source from the content-addressed store, hash-verified

402 // Terminate and wake the workers.
403 let member_data = self.get_member_data();
404 for worker in &terminating_workers {
405 // Tell the worker to halt.
406 worker.control.halt.store(true, Ordering::Relaxed);
407 // Signal the worker.
408 member_data.semaphores[worker.member_index].signal();
409 }
410
411 // Drop the lock on the state so as not to block the workers or
412 // heartbeat.
413 drop(managed_workers);

Callers 1

with_workerMethod · 0.80

Calls 2

enrollMethod · 0.80
activateMethod · 0.80

Tested by

no test coverage detected