某日发现定时任务线程池中的所有线程全部阻塞：

代码如下：

// 由于任务规模、执行频次较低，直接无界队列。如果高频任务建议new ThreadPoolExecutor
private final ExecutorService royalFlushExecutor = Executors.newFixedThreadPool(RoyalFlush.THREAD_NUM, new NamedThreadFactory("royalFlushExecutor", false));

@Override
public List<StockRoyalFlushDto> fetchRoyalFlushData(List<StockBaseInfoEntity> stockBaseInfoEntities) {
    String currentTime = DateUtil.currentTimeStr();

    List<StockRoyalFlushDto> results = new ArrayList<>();

    List<Future<StockRoyalFlushDto>> futures = new ArrayList<>();

    System.setProperty("https.protocols", "TLSv1,TLSv1.1,TLSv1.2");

    AtomicInteger current = new AtomicInteger(0);
    for (StockBaseInfoEntity stockBaseInfoEntity : stockBaseInfoEntities) {
        String url = String.format(String.format(RoyalFlush.AI_URL, stockBaseInfoEntity.getCode() + RoyalFlush.QUERY));
        futures.add(royalFlushExecutor.submit(() -> {
            log.info("royalFlushData-当前进度:{}/{}-启动时间:{}", current.getAndIncrement(), stockBaseInfoEntities.size(), currentTime);
            return fetchAndParseData(stockBaseInfoEntity, url);
        }));
    }

    for (Future<StockRoyalFlushDto> future : futures) {
        try {
            StockRoyalFlushDto stockRoyalFlushDto = future.get(1, java.util.concurrent.TimeUnit.SECONDS);
            if (stockRoyalFlushDto != null) {
                results.add(stockRoyalFlushDto);
            }
        } catch (Exception e) {
            log.error("royalFlushData-任务执行失败:{} e:{}", e.getMessage(), e.toString());
        }
    }

    return results;
}