在一个主线程中,要求有大量子线程执行完之后,…

2020-04-19 16:01:08来源:博客园 阅读 ()

新老客户大回馈,云服务器低至5折

在一个主线程中,要求有大量子线程执行完之后,主线程才执行完成?多种方式,考虑效率。

1、在主函数中使用join()方法

    t1.start();
    t2.start();
    t3.start();

    t1.join();//不会导致t1和t2和t3的顺序执行
    t2.join();
    t3.join();
System.out.println("Main finished");

 

2、CountDownLatch,一个同步辅助类,在完成一组正在其他线程中执行的操作之前,它允许一个或多个线程一直等待。

public class WithLatch{
    public static void main(String[] args){
        CountDownLatch latch = new CountDownLatch(3);
        for(int i=0;i<3;i++){
            new ChildThread(i,latch).start();
        }
        try{
            latch.await();
        }catch(InterruptedException e){
            e.printStackTrace();
        }
        System.out.println("Main finished");
    }
    static calss ChildThread extends Thread{
        private int id = -1;
        private CountDownLatch latch = null;

        public ChildThread(int id, CountDownLatch latch){
            this.id = id;
            this.latch = latch;
        }
        public void run(){
            try{
                Thread.sleep(Math.abs(new Random().nextInt(5000)));
                System.out.println(String.format("Child Thread %d finished",id));
            }catch(InterruptedExcepion e){
                e.printStackTrace();
            }finally{
                latch.countDown();
            }
        }
    }
}

 

3、使用线程池

public class WithExecutor{
    public static void main(String[] args) throws InterruptedExcepion{
        ExecutorService pool = Executors.newFixedThreadPool(3);
        List<Callable<Void>> list = new ArrayList<Callable<Void>>();
        for(int i=0;i<3;i++){
            list.add(new ChildThread(i));
        }
        try{
            pool.invokeAll(list);
        }finally{
            pool.shutdown();
        }
        System.out.println("Main finished");
    }

    static class ChildThread implements Callable<Void>{
        private int id =  -1;
    
        public ChildThread (int id){
            this.id = id;
        }
        public Void call() throws Exception{
            try{
                Thread.sleep(Math.abs(new Random().nextInt(5000)));
                System.out.println(String.format("Child Thread %d finished",id));
            }catch(InterruptedException e){
                e.printStackTrace();
            }
            return null;
        }
    }
}

 


原文链接:https://www.cnblogs.com/HuiH/p/12733909.html
如有疑问请与原作者联系

标签:

版权申明:本站文章部分自网络,如有侵权,请联系:west999com@outlook.com
特别注意:本站所有转载文章言论不代表本站观点,本站所提供的摄影照片,插画,设计作品,如需使用,请与原作者联系,版权归原作者所有

上一篇:Vue中el-form标签中的自定义el-select下拉框标签

下一篇:java学到什么程度可以找到工作?