7 releases
Uses old Rust 2015
0.2.1 | May 6, 2016 |
---|---|
0.2.0 | May 6, 2016 |
0.1.4 | Mar 12, 2016 |
#794 in Concurrency
821 downloads per month
Used in 5 crates
(4 directly)
7KB
138 lines
A stoppable, thin wrapper around std::Thread.
Uses std::sync::atomic::AtomicBool
and std::thread
to create stoppable
threads.
The interface is very similar to that of std::thread::Thread
(or rather
std::thread::JoinHandle
) except that every closure passed in must accept
a stopped
parameter, allowing to check whether or not a stop was
requested.
Since all stops must have gracefully, i.e. by requesting the child thread to stop, partial values can be returned if needed.
Example:
use stoppable_thread;
let handle = stoppable_thread::spawn(|stopped| {
let mut count: u64 = 0;
while !stopped.get() {
count += 1
}
count
});
// work in main thread
// stop the thread. we also want to collect partial results
let child_count = handle.stop().join().unwrap();