summaryrefslogtreecommitdiffstats
path: root/third_party/rust/tokio-threadpool/src/config.rs
diff options
context:
space:
mode:
Diffstat (limited to 'third_party/rust/tokio-threadpool/src/config.rs')
-rw-r--r--third_party/rust/tokio-threadpool/src/config.rs34
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()
+ }
+}