Struct DedicatedWorkerThreadSpawner

pub struct DedicatedWorkerThreadSpawner<T, F>
where
    F: Fn(T) + Send + Sync + 'static,
{ /* private fields */ }

Spawns worker threads dedicated to a single dispatcher, with all threads using the same handler function. Optimizes for single-receiver scenarios by avoiding select overhead.

Implementations

impl<T: Send + 'static> DedicatedWorkerThreadSpawner<T, fn(_: T)>

Handle for initializing a group of dedicated worker threads.

pub fn new() -> Self

Creates a new spawner with a no-op handler function.

impl<T: Send + 'static, F> DedicatedWorkerThreadSpawner<T, F>

where F: Fn(T) + Send + Sync + Clone + 'static,

pub fn set_cores(self, cores: Vec<CoreId>) -> Self

Sets the CPU cores that worker threads will be pinned to.

pub fn set_batch_size(self, batch_size: usize) -> Self

Sets the batch size for processing messages.

pub fn set_dispatcher(self, dispatcher: Arc<ChannelDispatcher<T>>) -> Self

Sets the single dispatcher that all worker threads will process subscriptions from.

pub fn set_handler<G>(self, handler: G) -> DedicatedWorkerThreadSpawner<T, G>

where G: Fn(T) + Send + Sync + Clone + 'static,

Sets the handler function that will process all subscriptions. Changes the function type parameter.

pub fn run(self) -> DedicatedWorkerHandle<T>

where F: 'static,

Spawns worker threads on configured cores. Returns a handle for managing the worker group. Uses a barrier to ensure all threads are ready before returning.

Trait Implementations

impl<T: Send + 'static> Default for DedicatedWorkerThreadSpawner<T, fn(_: T)>

fn default() -> Self

Returns the “default value” for a type.