Java：计时器或 ScheduleExecutorService 用于在繁忙的窗口期间计算命中？

Question

我的问题是：我有一个接受目录中文件的类。每当第一个对象到达时，它就会启动一些计时器来对目录中在接下来的 60 秒内到达的所有文件执行压缩。

这提出了两个要求：

1) 当新文件到达时，我需要能够检查“倒计时”是否已经在运行。我不希望 file2 在 file1 之后 15 秒到达，然后它们在 45 秒后一起压缩，只是在第一个完成后 15 秒触发第二个计划任务（到一个空目录）。

2) 智能批处理/非常量轮询。例如，如果 file1 在 time=0 到达，而 file2 在 time=59s 到达，它们将被一起压缩。但是，如果 file3 直到 time=89s 才到达，而 file4 在 time=129s 到达，我想确保下一个“压缩”操作不会发生在 timer=120s，而是发生在 timer=149s（60 秒后文件 3 到达）。

换句话说：应该只运行一个计时器/倒计时。如果它是压缩后的第一个文件，它应该触发一个新文件，否则它应该被忽略。

我正在研究 java.util.Timer 和 Java.util.concurent.ScheduledExecutorService 作为解决方案，但它们似乎都是为拥有多个进程而构建的，我试图避免这种情况。

有没有更好的解决方案？

Answer 1

这是一个示例代码：

private Thread countDownThread;

public synchronized void onNewFile() {
    startCountDownThreadIfNotYetRunning();
}

public synchronized void resetThread() {
    if(uncompressedFilesExist()) {
        startCountDownThreadIfNotYetRunning();
    }
}

public synchronized void startCountDownThreadIfNotYetRunning() {
    if(countDownThread == null) {
        new Thread(new CompressionTask()).start();
    }
}

private class CompressionTask implements Runnable {
    @Override
    public void run() {
        try {
            Thread.sleep(60 * DateUtils.MILLIS_PER_SECOND);
            compressDirectoryContents();
            resetThread();
        }
        catch (InterruptedException e) { }
    }
}

1. 当onNewFile() 被调用时，它会尝试启动一个新的countDownThread（如果它尚未运行）。

2. 此线程等待 60 秒并开始压缩。

3. 最后一步resetThread() 有点棘手。如果我们简单地调用：

   countDownThread = null;
   

   代码不是线程安全的。首先，对countDownThread 所做的更改可能不会被其他线程看到。此外，如果新文件出现在compressDirectoryContents() 和简单赋值之间，它会丢失。这就是为什么所有操作都是synchronized使用同一个锁。

   因为onNewFile()和resetThread()都被同一个锁保护，所以不可能出现新文件但倒计时线程没有启动。

请注意，您不需要任何花哨的 Timers 或 ScheduleExecutorService - 每分钟创建一个线程并不过分。