Избегайте тайм-аута соединения при использовании нескольких потоков и пула соединений

Два решения:

A) Настройте пул соединений с тайм-аутом в несколько дней. Это заблокирует ожидающие задачи до тех пор, пока соединение не будет возвращено. Недостаток: это не будет работать, когда задача зависнет.

Б) Используйте пул потоков и рабочую очередь. Пул потоков должен иметь тот же размер, что и пул соединений (т. е. одно соединение на поток). Поместите всю работу в очередь и пусть задачи извлекают рабочие элементы из очереди, пока очередь не опустеет.

Псевдокод для решения B:

public class Setup
    connPool = createConnectionPool(100);
    queue = createWorkQueue();
    putAllWorkItemsInQueue(queue);
    for (int i=0; i<connPool.size(); i++) {
        t = new WorkerThread(queue)
        list.add(t);
        t.start();
    }
    while (queue.size() != 0) {
        Thread.sleep(1000);
    }
    for (thread in list) {
        thread.interrupt();
    }

public class WorkerThread
    run() {
        while (true) {
            try {
                workUnit = queue.get(); // This blocks
                process(workUnit);
            } catch (InterruptedException e) {
                break;
            }
        }
    }