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(){
            //something    
        }
}