task broken in scheduler while threadpool size was little than the count of client

[wsky]

if (!this.executeTask(task)) {
                    this.setRejectedTask(task);
                    return;
                }

task rejected by threadpool, but scheuler redispatch from the head of queue

Iterator<Entry<T, Queue<Runnable>>> iterator = this.tasks.entrySet().iterator();
            while (iterator.hasNext()) {
//...
}

[wsky]

use CallerRunsPolicy can avoid it

scheduler.setThreadPool(new ThreadPoolExecutor(
                10, 10,
                300, TimeUnit.SECONDS,
                new SynchronousQueue<Runnable>(),Executors.defaultThreadFactory(), 
new CallerRunsPolicy()));