Struct TaskPool 

pub struct TaskPool {
    pub id: String,
    pub pool_size: usize,
    pub strategy: LoadBalancingStrategy,
    /* private fields */
}

A pool of worker tasks for load balancing

Fields

id: String

Pool identifier

pool_size: usize

Number of workers in the pool

strategy: LoadBalancingStrategy

Load balancing strategy

Implementations

impl TaskPool

pub fn new( id: impl Into<String>, pool_size: usize, strategy: LoadBalancingStrategy, ) -> Self

Create a new task pool

pub async fn get_next_worker(&self) -> usize

Get the next worker index based on the load balancing strategy

pub fn build_pool<T, F>(&self, task_factory: F) -> Supervisor

where T: SupervisedTask + 'static, F: Fn(usize) -> T,

Build a supervisor with pooled workers

pub fn info(&self) -> PoolInfo

Get pool information