ThreadPoolExecutor用做延迟任务的bug

 ThreadPoolExecutor executor = new ThreadPoolExecutor(8, 32, 10, TimeUnit.SECONDS,
			new DelayQueue());

我提交一个定时每5秒执行的任务，却发现一开始执行了8次，然后才是每5秒执行一次。
后来发现对于第一个任务，ThreadPoolExecutor 是有个bug的。

executor 是通过runWorker来执行的

final void runWorker(Worker w) {
        Thread wt = Thread.currentThread();
        Runnable task = w.firstTask;
        w.firstTask = null;
        w.unlock(); // allow interrupts
        boolean completedAbruptly = true;
        try {
            while (task != null || (task = getTask()) != null) {

看到没有，有个firstTask，一般情况下回去队列中去取任务的：task = getTask()。但是对于第一个任务是特殊的，第一个任务不通过队列，所以延迟队列也就不起作用了。

评论

3 楼 nimeifan 2014-07-31  

请问你这个任务返回结果吗？“我提交一个定时每5秒执行的任务”是怎么实现的？

2 楼 huangyunbin 2014-01-07  

Shen.Yiyang 写道

定时任务你不会用ScheduledExecutorService吗，小便池上大号，最后说不合适的节奏？

我后来的做法也是采用ScheduledExecutorService的。定时任务是后来加上去的，我开始的想法是在原来的ThreadPoolExecutor 基础上改下，然后就发现了这个坑。

1 楼 Shen.Yiyang 2014-01-07  

定时任务你不会用ScheduledExecutorService吗，小便池上大号，最后说不合适的节奏？