callable 和 countDownLatch 使用出现的 bug，求助，指出当前代码的问题

final static ExecutorService executor = new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60, TimeUit.SECONDS, new SynchronousQueue<>()); public static void main(String[] args) { // 模拟 1000 并发请求，会发现下面的 get 时 会有几率报错。在压测的时候，10w 请求，大概 1000+个错误 for (int i = 0; i < 1000; i++) { executor.submit(() -> { // 每一个请求真正执行的业务逻辑 demo start CountDownLatch latch = new CountDownLatch(1); Future<String> submit = executor.submit(() -> { latch.countDown(); /** * 目前猜测，上下两句不是 原子操作 * */ return "abc"; }); try { latch.await(10, TimeUnit.MILLISECONDS); } catch (InterruptedException e) { e.printStackTrace(); } try { // 或者调整 timeout 值，将其调大值，在 10ms 或者更大 System.out.println( submit.get(0, TimeUnit.MILLISECONDS)); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } catch (TimeoutException e) { e.printStackTrace(); } // 每一个请求真正执行的业务逻辑 demo end }); } } 

最后线上改成了这个

future.cancel(true); if (!future.isCancelled()) { future.get(); }