ScheduledExecutorService - задача прекращает работу

Question

private ScheduledExecutorService pool = new 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

Вы всегда должны быть осторожны, чтобы закрыть ресурсы по мере их использования, особенно ресурсы ввода-вывода, такие как соединения, операторы и результирующие наборы. В объединенной среде вы можете очень легко исчерпать пул соединений, а последующие задачи в конечном итоге блокируются, ожидая подключения, которое никогда не будет доступно (если вам повезет, в зависимости от реализации и т. Д., Возможно, соединения начнутся закрывшись после нескольких минут ... или дольше).