Struct SharedWorkerThreadSpawner

pub struct SharedWorkerThreadSpawner<T>
where
    T: Send + 'static,
{ /* private fields */ }

Spawns worker threads that share multiple dispatchers, with each thread handling subscriptions from all configured dispatchers using different handlers per dispatcher type.

Implementations

impl<T> SharedWorkerThreadSpawner<T>

where T: Send + Clone + 'static,

Handle for initializing a group of shared worker threads.

pub fn new() -> Self

Creates a new spawner with no cores, dispatchers, or handlers configured.

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 add_dispatcher<F>( self, dispatcher: Arc<ChannelDispatcher<T>>, handler: F, ) -> Self

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

Adds a dispatcher-handler pair. Each dispatcher’s subscriptions will be processed by its corresponding handler.

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

Spawns worker threads on the configured cores. Each thread processes subscriptions from all dispatchers using a select operation to handle whichever channel has data available. Returns a handle for managing the worker group and uses a barrier to ensure all threads are ready.

Trait Implementations

impl<T> Default for SharedWorkerThreadSpawner<T>

where T: Send + Clone + 'static,

fn default() -> Self

Returns the “default value” for a type.