您好老师问个最近用到的线程池使用的问题
我的工程是springboot的，在unitTest里（@SpringBootTest） 里调用了一个service A（通过@Autowired的）中的方法，A中启用了一个线程池，执行的任务 是往数据库里插入数据。但是总抛出数据源已经被关闭的异常，我理解的是在单测主线程已经结束，所以关闭了数据源这些清理工作，而此时线程池的线程还
没结束，这个时候去调用数据源是null 的，不知道这么理解对不对，另外这个test主线程结束，为啥线程池的线程还没结束（通过打断点看到的）。这个怎么理解，求教

public class Logger {
    ...
    
    volatile boolean stop;

    // 启动写日志线程
    void start() throws IOException {
        ...
        this.es.execute(() -> {
            try {
                // 未刷盘日志数量
                int curIdx = 0;
                long preFT = System.currentTimeMillis();
                while (!stop) {
                       ...
                }
            } catch (InterruptedException e) {
                // 重新设置线程中断状态
                Thread.currentThread().interrupt();
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                ...
            }
        });
    }
    ...
    void stop(){
        stop = true;
        es.shutdown();
    }
}

private BlockingQueue<X> bq = new LinkedBlockingQueue<>(1000);

// 从任务队列中获取批量任务
List<X> pollTasks() throws InterruptedException{
  List<X> ts=new LinkedList<>();

  X t = bq.take();
  while (t != null) {
    ts.add(t);
    t = bq.poll();
  }

  return ts;
}

-----

需求背景：（一个线程往 bq 写数据，三个线程从 bq 读数据）
1. 线程 A 从数据库批量读取数据，每次读 1000 条记录，然后在 for 循环内写入队列 bq.put(x)。
2. 线程 B、线程 C、线程 D 调用 pollTasks() 方法获取数据列表，然后将数据列表做为参数，调用 Y 接口获取一批数据，最后进行业务运算。

-----

跑 demo 时发现 pollTasks() 方法有两个地方需要注意一下（一是：获取的列表数量不均，二是：退化成单元素列表）：
1. 线程 B、C、D 调用 pollTasks() 获得的列表，数据量不均匀，例如线程 B 只读取到 10+ 个元素，而线程 C 却读取了 1000+ 个元素。
2. 如果我上游写入队列 bq 速度较慢（通过一些复杂的运算再写入 bq），这时下游通过 pollTasks() 获取的列表，几乎都是只有一个元素的列表。


列表数据不均，可以增加返回列表的上限，或者增加超时机制。

退化成单元素列表：
1. pollTasks() 的调用方主动等待片刻，再获取数据。
2. 修改 pollTasks() 的实现，返回列表的前提条件是：列表的 size 必须 batchSizeLimit 下限，否则等待超时 System.currentTimeMillis()-startMillis>1000。