CountDownLatch阻塞主线程

心已赠人 2022-12-20 05:54 84阅读 0赞

@Test
        public void test() { 
            ExecutorService service = Executors.newFixedThreadPool(3);
            final CountDownLatch latch = new CountDownLatch(3);
            for (int i = 0; i < 3; i++) { 
                Runnable runnable = new Runnable() { 
                    @Override
                    public void run() { 
                        try { 
                            System.out.println("子线程" + Thread.currentThread().getName() + "开始执行");
                            Thread.sleep((long) (Math.random() * 10000));
                            System.out.println("子线程"+Thread.currentThread().getName()+"执行完成");
                            latch.countDown();//当前线程调用此方法，则计数减一
                        } catch (InterruptedException e) { 
                            e.printStackTrace();
                        }
                    }
                };
                service.execute(runnable);
            }
    
            try { 
                System.out.println("主线程"+Thread.currentThread().getName()+"等待子线程执行完成...");
                latch.await();//阻塞当前线程，直到计数器的值为0
                System.out.println("主线程"+Thread.currentThread().getName()+"开始执行...");
            } catch (InterruptedException e) { 
                e.printStackTrace();
            }
        }

发表评论取消回复

表情：

评论列表（有 0 条评论，84人围观）

还没有评论，来说两句吧...

相关阅读

相关获取双异步返回值时，如何保证主线程不阻塞？

CompletableFuture的异步执行通过ForkJoinPool实现，ForkJoinPool在于可以充分利用多核CPU的优势，把一个任务拆分成多个小任务，把多个...

梦里梦外;/ 2024年05月28日 10:26/ 0 赞/ 35 阅读

相关 CountDownLatch测试，并发测试，主线程等待子线程全部执行完后执行测试

1、测试下面结果按理说应该为1000000，但是因为并发导致结果错误。 package demo; import java.util.concurr

桃扇骨/ 2023年10月06日 14:29/ 0 赞/ 11 阅读

相关 CountDownLatch阻塞主线程

@Test public void test() { ExecutorService service = Executors.

心已赠人/ 2022年12月20日 05:54/ 0 赞/ 85 阅读

相关一心多用多线程-阻塞队列（5）-CountDownLatch

五、倒数执行机制-CountDownLatch Latch：门闩的意思。根据该类名的意思，我们就可以知道该类在多线中扮演的就是一个倒数门闩的角色，怎么理解呢？首先呢，

秒速五厘米/ 2022年07月15日 05:52/ 0 赞/ 165 阅读

相关一心多用多线程-阻塞队列（5）-CountDownLatch

五、倒数执行机制-CountDownLatch Latch：门闩的意思。根据该类名的意思，我们就可以知道该类在多线中扮演的就是一个倒数门闩的角色，怎么理解呢？首先呢，

古城微笑少年丶/ 2022年07月15日 05:52/ 0 赞/ 141 阅读

相关 unOnUiThread更新主线程

unOnUiThread更新主线程更新UI采用Handler\+Thread，需要发送消息，接受处理消息（在回调方法中处理），比较繁琐。除此之外，还可以使用runOnU

布满荆棘的人生/ 2022年06月15日 09:26/ 0 赞/ 159 阅读

相关 Java主线程等待子线程执行完毕-CountDownLatch

主线程代码 //Main主线程 publicclassMainThread { publicstaticvoid ma

太过爱你忘了你带给我的痛/ 2022年06月14日 08:17/ 0 赞/ 211 阅读

相关 Java主线程

当Java程序启动时，一个线程立刻运行，该线程通常叫做程序的主线程（main thread），因为它是程序开始时就执行的。主线程的重要性体现在两方面： · 它是产生其他子线程

た入场券/ 2022年05月21日 09:28/ 0 赞/ 194 阅读

相关 CountDownLatch 阻塞队列使用

Latch：门闩的意思。根据该类名的意思，我们就可以知道该类在多线中扮演的就是一个倒数门闩的角色，怎么理解呢？首先呢，我们新建一个CountDownLacth对象时我们需

水深无声/ 2022年05月15日 05:43/ 0 赞/ 145 阅读

相关 Kafka producer异步发送在某些情况会阻塞主线程

最近发现一个Kafka producer异步发送在某些情况会阻塞主线程，后来在排查解决问题过程中发现这可以算是Kafka的一个说明不恰当的地方。问题说明在很多场景下

傷城~/ 2021年06月22日 15:37/ 0 赞/ 299 阅读