DefaultAggregateSchedulerSupplier
class DefaultAggregateSchedulerSupplier(val name: String, val parallelism: Int = Schedulers.DEFAULT_POOL_SIZE) : AggregateSchedulerSupplier, ParallelismCapable, Named
Default implementation of AggregateSchedulerSupplier that creates dedicated schedulers for each aggregate.
This implementation maintains a cache of schedulers, creating a new parallel scheduler for each unique aggregate on first access. Subsequent requests for the same aggregate return the cached scheduler, ensuring consistent thread allocation and resource reuse.
The scheduler names follow the pattern "{supplier-name}-{aggregate-name}" for easy identification in thread dumps and monitoring tools.
See also
Schedulers.newParallel