Очередь потоков Java

Здесь вам нужно понять разницу между Thread и Runnable/Callable Task. поэтому значение The threads in the pool will exist until it is explicitly shutdown. заключается в том, что в любой момент времени в пуле потоков будет 5 потоков, если вы используете Executors.newFixedThreadPool(5); . И работа, которую вы хотите, чтобы эти потоки выполняли, будет представлена ​​как Tasks (Runnable/Callable). Таким образом, по существу, в любой момент времени через этот пул потоков будет выполняться 5 потоков, что в вашем случае будет 5 соединениями.

Предложение, которого вы боитесь:

The threads in the pool will exist until it is explicitly shutdown

описывает только вызовы Executors.newFixedThreadPool(). Чтобы лучше контролировать поведение пула потоков, используйте конструктор ThreadPoolExecutor явно, например

new ThreadPoolExecutor(1, //minimal Pool Size, 10, // maximal Pool Size, 30, TimeUnit.SECONDS // idle thread dies in 30 seconds new ArrayBlockingQueue<Runnable>())

Потоки останутся там (ожидая выполнения других задач), но не будут хранить все данные, которые вы туда поместили. Когда поток в пуле потоков выполнит задачу, он возьмет на себя следующую задачу и больше не будет ссылаться на существующую задачу.

Так что ваши опасения беспочвенны, если вы явно не держите ссылки на задачи.

Используйте ScheduledExecutorService с фиксированным пулом потоков для любого необходимого количества подключений.

Имейте BlockingQueue, в который вы помещаете запросы, рабочие потоки ждут в очереди и обрабатывают запросы по мере их появления.

ExecutorService — это то, что вам нужно . Он предоставляет вам интерфейс (Future) в состояние основного потока, способность обнаруживать исключения и возвращать значение из завершенного потока.

Вот простой пример использования ExecutorSerivce и интерфейса Future.

public class Updater implements Future< boolean > {

    public Updater() { }

    public boolean call() throws Exception {
        System.out.println( "Hello, World!" );
        return true;
    }
}

public class Main {
    public Main() { }

    public static void main( String[] args ) {
        ExecutorService pool = Executors.newFixedThreadPool( 1 );


        boolean again = true;
        do {
            if ( again ) { 
                Future< ? > update = pool.submit( new Updater() );
            }

            /* Do other work while waiting for update to finish */

            if( update.isDone() ) { //may be because of completion or an exception
                try {
                    again = update.get(); // This would block if the Updater was still running
                } catch( ExecutionException ee ) { // This is thrown by get() if an exception occurred in Updater.call()
                    again = false;
                    ee.printStackTrace();
                }
            }
        } while ( true );
    }
}

Приведенный выше пример запустит обновление вашей базы данных, если последнее обновление прошло успешно без каких-либо исключений. Таким образом вы контролируете количество потоков, пытающихся подключиться, и отлавливаете любые ошибки, вызывающие сбой обновления.