public interface PriorityTaskSchedulers
Scheduler
implementations relevant to the Axon Server connector.Modifier and Type | Method and Description |
---|---|
static reactor.core.scheduler.Scheduler |
forPriority(ExecutorService delegate,
long priority,
AtomicLong taskSequence)
Creates a
Scheduler that is compatible with an ExecutorService that needs tasks that are
submitted to be a PriorityTask so that they can be prioritized. |
static reactor.core.scheduler.Scheduler forPriority(ExecutorService delegate, long priority, AtomicLong taskSequence)
Scheduler
that is compatible with an ExecutorService
that needs tasks that are
submitted to be a PriorityTask
so that they can be prioritized.delegate
- The delegate ExecutorService
to 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.Scheduler
object that is compatible with
PriorityTask
.PriorityExecutorService
Copyright © 2010–2023. All rights reserved.