ScheduledExecutorService-忽略已在运行的runnable

Question

我正在使用计划执行服务

私有的执行池=新的执行池（1）；

以固定速率运行runnable

pool。scheduleAtFixedRate（新的CoolRunnable（），10，10，时间单位）。毫秒）

这个线程池等待前一次执行完成，但我希望它每10毫秒运行一次runnable，不管前一次执行是否完成。

我该怎么做？

编辑：修复了用连接池替换MySQL连接的问题。正常的连接方法是同步的，这就是为什么Runnable必须互相等待的原因。




Answer 1

为此，您需要每隔10秒向ExecutorService提交一个任务。此ExecutorService将负责运行以下任务：

ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor();
ExecutorService workers = Executors.newCachedThreadPool();

scheduler.scheduleAtFixedRate(new Runnable {
    @Override
    public void run() {
        workers.submit(new CoolRunnable());
    }
}, 10, TimeUnit.SECONDS);

如果旧的线程仍在工作，使用cachedThreadpool将创建新的线程。这样做要小心：如果任务运行时间更长，每10秒添加一个新任务可能会创建大量并发线程。