java - 发生某种情况后停止线程 ScheduledThreadPoolExecutor

Question

我想要一些线程池，它每隔固定的时间运行一些任务(这个线程池一直在获取任务)。每个任务都会调用一些 API 来获取一些值，该值可以为 null。我希望仅当返回值为空时任务才再次运行(在固定时间后)。否则，我不希望再次运行此任务。有什么办法可以实现这一点吗？我唯一想到的是使用 ScheduledThreadPoolExecutor 并从内部终止特定线程，但我没有找到一种方法来做到这一点，而且我不确定这是一个好的做法。

谢谢!

Answer 1

您可以按一个任务安排任务，并在安排下一个任务之前检查您的状况:

public class Solver {

    final long delay = 500L;

    String getSomeValue() {
        if (Math.random() < 0.8) return "not-null";
        return null;
    }

    void init() {
        ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(8);
        Runnable runnable = new Runnable() {
            @Override
            public void run() {
                long time = System.currentTimeMillis();
                String value = getSomeValue();
                System.out.println("" + value + " " + System.currentTimeMillis());
                if (value == null) {
                    executor.schedule(this, delay - (System.currentTimeMillis() - time), TimeUnit.MILLISECONDS);
                }
            }
        };
        executor.schedule(runnable, delay, TimeUnit.MILLISECONDS);
    }

    public static void main(String[] args) {
        new Solver().init();
    }

}