Struct WorkerPool 

pub struct WorkerPool { /* private fields */ }

Limits concurrent handler tasks for a subscription.

Implementations

impl WorkerPool

pub fn new(max_concurrent: usize) -> Self

Create a pool with at most max_concurrent in-flight handlers.

pub fn from_env() -> Self

Pool size from PHOTON_HANDLER_POOL_SIZE (default 64).

pub async fn acquire(&self) -> Result<OwnedSemaphorePermit>

Acquire a permit before running a handler task.

Errors

Returns PhotonError::Internal if the semaphore has been closed.