1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17
use crate::Executor; use futures::Future; /// A thread pool runtime for futures. #[cfg_attr(docsrs, doc(cfg(feature = "thread-pool")))] pub type ThreadPool = futures::executor::ThreadPool; impl Executor for futures::executor::ThreadPool { fn new() -> Result<Self, futures::io::Error> { futures::executor::ThreadPool::new() } fn spawn(&self, future: impl Future<Output = ()> + Send + 'static) { self.spawn_ok(future); } }