ThreadPoolExecutor executor = ThreadPoolBuilder.builder().workQueue(new PriorityBlockingQueue())
        .threadPoolId("1").corePoolSize(1).maximumPoolSize(1)
        .threadFactory("d").build();
while (true) {
    executor.submit(new Task());
}
...
static class implements Runnable, Comparable {

    public int compareTo(Object o) {
        return 0;
    }

    public void run() {
        // что-то
    }
}