ScheduledExecutorService-任务停止运行

Question

专用ScheduledExecutorService池=新ScheduledThreadPoolExecutor（20）

我在执行任务

public void run() {
    if (queue.isEmpty()) return;

    ArrayDeque<Profile> current = new ArrayDeque<Profile>();
    this.queue.drainTo(current, 20);

    MySQLStatement statement = this.wrapper.prepare();

    while (!current.isEmpty()) {
        if (statement.isClosed()) return;

        Profile profile = current.poll();
        statement.addBatch(profile.getId().toString(), ProfileBuilder.toJson(profile));
    }

    statement.executeBatchAsync();
}

使用ScheduledExecutorService

pool.scheduleAtFixedRate(new VerboseRunnable(runnable = new MySQLRunnable(this)), 250, 50, TimeUnit.MILLISECONDS);  

MySQLRunnable在使用完整队列运行某些时间后停止工作，但当队列为空时，它或多或少会无限运行
首先，我认为停止可能是因为静默捕获的异常，所以我添加了VerboseRunnable

public void run() {
    try {
        runnable.run();
    } catch (Throwable e) {
        System.err.println("Error in runnable!");
        e.printStackTrace();
        throw new RuntimeException(e);
    }
}

但它仍然停止运行。此外，ScheduledFuture告诉我任务既没有完成也没有取消。

任何帮助都会很好。




Answer 1

在使用资源时，应始终小心关闭资源，尤其是连接、语句和结果集等I/O资源。在池环境中，您很容易耗尽连接池，后续任务最终将阻塞，等待可能永远不可用的连接（如果幸运的话，取决于实现等，连接可能会在几分钟后…或更长时间后开始关闭）。