首页 > 其他分享 >介绍几种等待多线程任务执行完毕的方法

介绍几种等待多线程任务执行完毕的方法

时间:2023-04-10 14:00:17浏览次数:35  
标签:执行 几种 任务 完毕 线程 new 多线程

一.引言:
        在我们日常的开发过程中,我们经常会开启多个线程或者创建一个线程池去执行多个并发任务,当所有任务执行完毕后,我们一般会做一个统一的处理。那我们如何知道多个线程的任务已经全部执行完毕了呢?
今天由我来为大家介绍几种方法:

二.join()方法
在这里插入图片描述 

        Thread thread1 = new Thread(new Runnable() {
            @Override
            public void run() {
                while (i<10000){
                    i++;
                }
            }
        });
        thread1.start();
        Thread thread2 = new Thread(new Runnable() {
            @Override
            public void run() {
                while (k<10000){
                    k++;
                }
            }
        });
        thread2.start();
        
        try {
            thread1.join();
            thread2.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
 
        System.out.println("i的值"+i);
        System.out.println("k的值"+k);
运行程序控制台打印i和k的值都是1万,可以得出结论,线程1,线程2都执行完毕了。

分析总结:执行join方法的线程的所在线程,一直在等待执行join方法的线程完成。如果A在B线程中执行了join()方法,那么B线程就会等待A线程执行结束。(通过while循环判断join的线程是否存活。)

三.CountDownLatch类
        代码实现在上述代码的基础上创建一个CountDownLatch对象:在这里插入图片描述 

       Thread thread1 = new Thread(new Runnable() {
            @Override
            public void run() {
                while (i<10000){
                    i++;
                }
                mCountDownLatch.countDown();
            }
        });
        thread1.start();
 
        Thread thread2 = new Thread(new Runnable() {
            @Override
            public void run() {
                while (k<10000){
                    k++;
                }
                mCountDownLatch.countDown();
            }
        });
        thread2.start();
 
        try {
            mCountDownLatch.await();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
 
        System.out.println("i的值"+i);
        System.out.println("k的值"+k);
运行程序,控制台打印结果和上面一样。

分析总结:CountDownLatch内部维持一个计数操作,通过CAS算法,保证操作的原子性。
countDown()会将当前计数-1(通过Unsafe类下compareAndSwapInt方法);
await()方法表示当前线程挂起,一直等待这个计数到0。

四.CyclicBarrier类
        代码如下:
 在这里插入图片描述

  mCyclicBarrier = new CyclicBarrier(2, mRunnable);
        Thread thread1 = new Thread(new Runnable() {
            @Override
            public void run() {
                while (i<10000){
                    i++;
                }
                try {
                    mCyclicBarrier.await();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } catch (BrokenBarrierException e) {
                    e.printStackTrace();
                }
            }
        });
        thread1.start();
 
        Thread thread2 = new Thread(new Runnable() {
            @Override
            public void run() {
                while (k<10000){
                    k++;
                }
                try {
                    mCyclicBarrier.await();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } catch (BrokenBarrierException e) {
                    e.printStackTrace();
                }
            }
        });
        thread2.start();
执行我们应用程序,打印结果和上述结果一致。

分析总结:
        CyclicBarrier可以理解为一个屏障。
        子线程通过调用它的await方法来告诉CyclicBarrier,线程到达屏障。当指定数量的线程
达到屏障后,在执行线程后面的方法。打个比方我们去车站坐车,所有人到达之后,车才会发动。
上诉代码我们通过CyclicBarrier的构造方法,指定等待2个线程到达屏障后(例如我们的车要等待多少人到齐之后才能发动)在执行后续的操作,并且指定之后都到达之后先执行什么操作(一个Runnable对象,例如我们车发动的操作)。

四.自定义个一个计数器 
        代码如下:

在这里插入图片描述

 在这里插入图片描述

 Thread thread1 = new Thread(new Runnable() {
            @Override
            public void run() {
                while (i<10000){
                    i++;
                }
                atomicInteger.incrementAndGet();
                justIsOver();
            }
        });
        thread1.start();
 
        Thread thread2 = new Thread(new Runnable() {
            @Override
            public void run() {
                while (k<10000){
                    k++;
                }
                atomicInteger.incrementAndGet();
                justIsOver();
            }
        });
        thread2.start();
执行我们的应用程序,控制台打印结果如上所示:

分析总结:
通过java提供的原子类AtomicInteger创建一个对象,用来计数。每个线程执行完毕时
调用incrementAndGet把内部的一个计数+1,当它内部的值为2时,就代表我们的两个线程都执行完毕了。

好了,今天我们就介绍这四种方法,还有其他方法,思想大差不差,要么设置一个同步点,要么就设置一个计数器。如果对你提供了帮助,别忘了点个赞再走哦。

 

标签:执行,几种,任务,完毕,线程,new,多线程
From: https://www.cnblogs.com/Free-Thinker/p/17302705.html

相关文章

  • C#中几种换行符
    C#中几种换行符1.Windows中的换行符"\r\n"2.Unix/Linux平台换行符是"\n"。3.MessageBox.Show()的换行符为"\n"4.Console的换行符为"\n"换行符还因平台差异而不同。为保持平台的通用性,可以用系统默认换行符System.Environment.NewLine。 ......
  • 多线程下载m3u8分段视频
    1.说明m3u8是一种传输数据的方式,比如说一集20分钟的完整视频被分割成一千多段一两秒的小视频,客户端播放的时候是感觉是连续,但如果你要下载这集视频,那就要把一千多个小视频全都下载然后自己拼接成一个完整视频。拼接的话很简单,像格式工厂等很多软件都可以轻松完成,但要一个一个下载......
  • java并发编程(2):Java多线程-java.util.concurrent高级工具
    高级多线程控制类Java1.5提供了一个非常高效实用的多线程包:java.util.concurrent,提供了大量高级工具,可以帮助开发者编写高效、易维护、结构清晰的Java多线程程序。ThreadLocal类ThreadLocal类用来保存线程的独立变量。对一个线程类(继承自Thread)当使用ThreadLocal维护变......
  • 几种SQL盲注的脚本
    BOOL型GET传参sql盲注点击查看代码importrequestschars=""foriinrange(32,127):chars+=chr(i)result=""url_template="http://yourip/sqllabs/Less-8/?id=2'andascii(substr(({0}),{1},1))>{2}%23"url_length="......
  • java并发编程(1):Java多线程-基本线程类-基础知识复习笔记
    复习资料:《同步与异步:并发/并行/进程/线程/多cpu/多核/超线程/管程 》基本线程类基本线程类基本线程类指的是Thread类,Runnable接口,Callable接口继承Thread创建线程继承java.lang.Thread类创建线程是最简单的一种方法,也最直接。publicclassMyThread1extendsThread{}种......
  • 【230409-1】记者要为5名志愿者和他们帮助的2位老人拍照,要求排成一排,2位老人相邻但不
    ......
  • 几种常用的Java 算法
    packagejsh.mg.msg.service.msg.test;importjava.util.Arrays;importstaticjava.util.Arrays.binarySearch;/****几种常用的Java算法*/publicclassTestClass{/****二分查找算法*/publicstaticintbinarySearch(int[]arr,inttarge......
  • BlockingQueue读取文本内容,多线程处理数据(线程池版本)
    importjava.io.BufferedReader;importjava.io.FileReader;importjava.io.FileWriter;importjava.io.IOException;importjava.util.concurrent.*;publicclassceshi2{publicstaticvoidmain(String[]args)throwsInterruptedException,ExecutionExcept......
  • BlockingQueue读取文本内容,多线程处理数据
    现在有一个txt文本,每个文本中每行的内容是:id,商品id。要求:启动一个线程去读取文本的内容,把每行的内容通过使用BlockingQueue发送到队列里面,然后多线程,最好是10个线程,从BlockingQueue队列里面取出来,将地址作为请求参数,请求api接口,把返回的内容解析出来,把原内容id,商品id,结果集......
  • Java生成PDF几种方式
    ##1、itextPDF直接填充<!--PDF工具类--><dependency><groupId>com.itextpdf</groupId><artifactId>itextpdf</artifactId><version>5.5.13</version></dependency>......