safina-threadpool

This is a safe Rust thread pool library.

It is part of safina, a safe async runtime.

Features

• forbid(unsafe_code)
• Depends only on std
• Good test coverage (100%)

Limitations

• Allocates memory
• Not optimized

Documentation

https://docs.rs/safina-threadpool

Examples

let pool =
    safina_threadpool::ThreadPool::new("worker", 2);
let receiver = {
    let (sender, receiver) =
        std::sync::mpsc::channel();
    for data in data_source {
        let sender_clone = sender.clone();
        pool.schedule(
            move || process_data(data, sender_clone));
    }
    receiver
};
let results: Vec<ProcessResult> =
    receiver.iter().collect();
// ...

Alternatives

• blocking
  • Popular
  • A little unsafe code
• threadpool
  • Popular
  • Well maintained
  • Dependencies have unsafe code
• futures-executor
  • Very popular
  • Full of unsafe
• scoped_threadpool
  • Popular
  • Contains unsafe code
• scheduled-thread-pool
  • Used by a popular connection pool library
  • Dependencies have unsafe code
• workerpool
  • Dependencies have unsafe code
• threads_pool
  • Full of unsafe
• thread-pool
  • Old
  • Dependencies have unsafe code
• tasque
  • Dependencies have unsafe code
• fast-threadpool
  • Dependencies have unsafe code
• blocking-permit
  • Full of unsafe
• rayon-core
  • Full of unsafe

Changelog

• v0.1.0 - First release

TO DO

• DONE - Add schedule and try_schedule
• DONE - Add tests
• DONE - Add docs
• DONE - Publish on crates.io
• Add a stress test
• Add a benchmark. See benchmarks in https://crates.io/crates/executors
• Add a way for a job to schedule another job on the same thread, with stealing.

Release Process

1. Edit Cargo.toml and bump version number.
2. Run ./release.sh

License: Apache-2.0