使用多个线程和连接池时避免连接超时

两种解决方案:

a)将连接池配置为超时几天。这将阻止挂起的任务,直到返回连接。缺点:当任务挂起时,这不起作用。

b)使用线程池和工作队列。线程池必须与连接池大小相同(即每个线程一个连接)。将所有工作放入队列中,让任务从队列中提取工作项,直到队列为空。

解决方案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;
            }
        }
    }