Struct WorkerPool 

pub struct WorkerPool { /* private fields */ }

Builder for a pool of server workers.

Implementations

impl WorkerPool

pub fn new() -> Self

Creates a worker pool with default settings.

pub fn name<T: AsRef<str>>(self, name: T) -> Self

Sets the worker thread name prefix.

The configured name is used for worker thread names.

pub fn workers(self, num: usize) -> Self

Sets the number of worker threads to start.

By default, the server uses the number of available logical CPUs.

pub fn stop_runtime(self) -> Self

Stops the current ntex runtime when the server manager is dropped.

By default “stop runtime” is disabled.

pub fn stop_on_panic(self) -> Self

Stops the server when one of the workers panics.

By default, “stop on panic” is disabled.

pub fn disable_signals(self) -> Self

Disable signal handling.

By default, signal handling is enabled.

pub fn graceful_shutdown(self) -> Self

Graceful shutdown.

Gracefully shuts down on SIGSEGV or SIGQUIT and app panics. Graceful shutdown is always enabled for SIGTERM. By default, it is disabled for SIGSEGV and SIGQUIT and panics.

pub fn shutdown_timeout<T: Into<Millis>>(self, timeout: T) -> Self

Timeout for graceful worker shutdown.

After receiving a stop signal, workers have this much time to finish serving requests. Workers that are still alive after the timeout are forcefully dropped.

By default, the shutdown timeout is set to 30 seconds.

pub fn enable_affinity(self) -> Self

Enables CPU affinity for worker threads.

By default, affinity is disabled.

pub fn run<F: ServerConfiguration>(self, factory: F) -> Server<F::Item>

Starts processing incoming items and returns a server controller.

Trait Implementations

impl Clone for WorkerPool

fn clone(&self) -> WorkerPool

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for WorkerPool

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for WorkerPool

fn default() -> Self

Returns the “default value” for a type.