Question

如何按条件移除scheduledexecutorservice线程池中的任务

Answer 1

java中的定时器功能

在jdk1.5之前，大家都用传统的定时器Timer来实现该功能
如，我们需要定制一个特殊方法，在程序首次载入时就执行，以后每隔一定的时间去执行那个方法
传统的做法如下;

[html] view plain copy
/**
* 定时器的测试（传统方式）
*/
public static void testTimer(){

Timer timer = new Timer();
TimerTask task = new TimerTask() {

@Override
public void run() {
System.out.println("Timer:测试开始！");
}
};
//第一个参数是要执行的任务
//第二个是程序启动后要延迟多长后执行,单位毫秒
//第三个参数是，第一次执行后，以后每隔多长时间后在行
timer.schedule(task, 5000, 3000);
}

jdk1.5出来后，我们就可以改变这种做法，换种方式
如代码：

[html] view plain copy
/**
* 定时器的测试(ScheduledExecutorService)
*/
public static void testExcuters(){
ScheduledExecutorService service = Executors.newScheduledThreadPool(1);

service.scheduleAtFixedRate(new Runnable() {

@Override
public void run() {
System.out.println("ScheduledExecutorService:测试开始");

}
}, 5, 3,TimeUnit.SECONDS);
}

Answer 2

public class ConditionCancelScheduler {
    private static ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor();

    public static void main(String[] args) throws Exception {
        final String jobID = "my_job_1";
        final AtomicInteger count = new AtomicInteger(0);
        final Map<String, Future> futures = new HashMap<>();

        final CountDownLatch countDownLatch = new CountDownLatch(1);
        Future future = scheduler.scheduleWithFixedDelay(new Runnable() {
            @Override
            public void run() {
                System.out.println(count.getAndIncrement());

                if (count.get() > 10) {
                    Future future = futures.get(jobID);
                    if (future != null) future.cancel(true);
                    countDownLatch.countDown();
                }
            }
        }, 0, 1, TimeUnit.SECONDS);

        futures.put(jobID, future);
        countDownLatch.await();

        scheduler.shutdown();
    }
}
拿去调试一下