lending_thread_pool 0.1.2

A thread pool where workers can lend their data to their tasks.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

use std::{thread::sleep, time::Duration};

use lending_thread_pool::ThreadPool;
use tracing::Level;

pub fn main() {
	tracing_subscriber::fmt()
		.with_max_level(Level::TRACE)
		.init();

	let cores = num_cpus::get() as u64;

	let mut pool = ThreadPool::new(
		(0..cores)
			.map(|i| format!("Hello from worker {i}"))
			.collect::<Vec<_>>(),
	);

	for _ in 0..cores {
		pool.enqueue(move |worker_greetings| {
			println!("Message from worker: {worker_greetings}");
			sleep(Duration::from_millis(100));
		});
	}

	// once dropped, the pool will automatically join all worker threads.
	// if you need to control when threads are joined, you can manually
	// drop the pool or call pool.join()

	pool.join(); // or, equivalently, drop(pool);
	println!("main thread finished");
}