vibeio 0.2.8

A high-performance, cross-platform asynchronous runtime for Rust
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
33
34
35
36
37

use super::BlockingThreadPool;

/// A default implementation of `BlockingThreadPool` using `rusty_pool` crate.
pub struct DefaultBlockingThreadPool {
    inner: rusty_pool::ThreadPool,
}

impl DefaultBlockingThreadPool {
    /// Creates a new `DefaultBlockingThreadPool` with the default maximum number of threads.
    #[inline]
    pub fn new() -> Self {
        Self::with_max_threads(512)
    }

    /// Creates a new `DefaultBlockingThreadPool` with the specified maximum number of threads.
    #[inline]
    pub fn with_max_threads(num_threads: usize) -> Self {
        Self {
            inner: rusty_pool::Builder::new().max_size(num_threads).build(),
        }
    }
}

impl BlockingThreadPool for DefaultBlockingThreadPool {
    #[inline]
    fn spawn(&self, task: Box<dyn FnOnce() + Send + 'static>) {
        self.inner.execute(move || {
            task();
        });
    }
}

impl Default for DefaultBlockingThreadPool {
    fn default() -> Self {
        Self::new()
    }
}