public interface PriorityTaskSchedulers
Schedulerimplementations relevant to the Axon Server connector.
static reactor.core.scheduler.Scheduler forPriority(ExecutorService delegate, long priority, AtomicLong taskSequence)
Schedulerthat is compatible with an
ExecutorServicethat needs tasks that are submitted to be a
PriorityTaskso that they can be prioritized.
delegate- The delegate
ExecutorServiceto use when submitting tasks.
priority- The priority that any tasks submitted to the delegate will have.
taskSequence- The task sequence used for ordering items with the same priority.
Schedulerobject that is compatible with
Copyright © 2010–2023. All rights reserved.