V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
huskyui
V2EX  ›  Java

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

  •  
  •   huskyui · 2021-06-29 23:19:54 +08:00 · 1494 次点击
    这是一个创建于 1233 天前的主题,其中的信息可能已经有所发展或是发生改变。
    final static ExecutorService executor = new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60, TimeUnit.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();
    }
    
    
    5 条回复    2021-06-30 09:45:49 +08:00
    546L5LiK6ZOt
        1
    546L5LiK6ZOt  
       2021-06-29 23:40:00 +08:00
    为啥同时用 CountDownLatch 和 Future ?看你代码,感觉 CountDownLatch 是多余的。
    huskyui
        2
    huskyui  
    OP
       2021-06-30 00:29:21 +08:00
    @546L5LiK6ZOt 用这个,主要是为了在规定时间内返回结果
    546L5LiK6ZOt
        3
    546L5LiK6ZOt  
       2021-06-30 01:07:47 +08:00 via iPhone
    @huskyui future 不也可以达到这个效果吗?
    kifile
        4
    kifile  
       2021-06-30 09:05:40 +08:00
    这个明显就线池处理不过来,超时了呀。不是你说让他 10s 执行完毕,他就能 10s 执行完毕的
    huskyui
        5
    huskyui  
    OP
       2021-06-30 09:45:49 +08:00
    @546L5LiK6ZOt 是多个任务,在规定时间内结束,最后改为了线程池的 invokeAll(taskList,timeout,unit)
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   实用小工具   ·   3762 人在线   最高记录 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 23ms · UTC 04:16 · PVG 12:16 · LAX 20:16 · JFK 23:16
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.