Class PrioritizedEsThreadPoolExecutor

All Implemented Interfaces:
Executor, ExecutorService

public class PrioritizedEsThreadPoolExecutor extends EsThreadPoolExecutor
A prioritizing executor which uses a priority queue as a work queue. The jobs that will be submitted will be treated as PrioritizedRunnable and/or PrioritizedCallable, those tasks that are not instances of these two will be wrapped and assign a default Priority.NORMAL priority.

Note, if two tasks have the same priority, the first to arrive will be executed first (FIFO style).