diff options
Diffstat (limited to 'third_party/rust/tokio-threadpool/src/config.rs')
-rw-r--r-- | third_party/rust/tokio-threadpool/src/config.rs | 34 |
1 files changed, 34 insertions, 0 deletions
diff --git a/third_party/rust/tokio-threadpool/src/config.rs b/third_party/rust/tokio-threadpool/src/config.rs new file mode 100644 index 0000000000..94b3c06a0b --- /dev/null +++ b/third_party/rust/tokio-threadpool/src/config.rs @@ -0,0 +1,34 @@ +use callback::Callback; + +use std::any::Any; +use std::fmt; +use std::sync::Arc; +use std::time::Duration; + +/// Thread pool specific configuration values +#[derive(Clone)] +pub(crate) struct Config { + pub keep_alive: Option<Duration>, + // Used to configure a worker thread + pub name_prefix: Option<String>, + pub stack_size: Option<usize>, + pub around_worker: Option<Callback>, + pub after_start: Option<Arc<dyn Fn() + Send + Sync>>, + pub before_stop: Option<Arc<dyn Fn() + Send + Sync>>, + pub panic_handler: Option<Arc<dyn Fn(Box<dyn Any + Send>) + Send + Sync>>, +} + +/// Max number of workers that can be part of a pool. This is the most that can +/// fit in the scheduler state. Note, that this is the max number of **active** +/// threads. There can be more standby threads. +pub(crate) const MAX_WORKERS: usize = 1 << 15; + +impl fmt::Debug for Config { + fn fmt(&self, fmt: &mut fmt::Formatter) -> fmt::Result { + fmt.debug_struct("Config") + .field("keep_alive", &self.keep_alive) + .field("name_prefix", &self.name_prefix) + .field("stack_size", &self.stack_size) + .finish() + } +} |