Java 如何让线程按顺序执行?

本贴最后更新于 596 天前,其中的信息可能已经时移俗易

一、介绍

本文使用了 8 种方法实现在多线程中让线程按顺序运行的方法,涉及到多线程中许多常用的方法,不止为了知道如何让线程按顺序运行,更是让读者对多线程的使用有更深刻的了解。使用的方法如下:

[1] 使用线程的 join 方法
[2] 使用主线程的 join 方法
[3] 使用线程的 wait 方法
[4] 使用线程的线程池方法
[5] 使用线程的 Condition(条件变量)方法
[6] 使用线程的 CountDownLatch(倒计数)方法
[7] 使用线程的 CyclicBarrier(回环栅栏)方法
[8] 使用线程的 Semaphore(信号量)方法

二、实现

我们下面需要完成这样一个应用场景:

1.早上;2.测试人员、产品经理、开发人员陆续的来公司上班;3.产品经理规划新需求;4.开发人员开发新需求功能;5.测试人员测试新功能。

规划需求,开发需求新功能,测试新功能是一个有顺序的,我们把 thread1 看做产品经理,thread2 看做开发人员,thread3 看做测试人员。

1

使用线程的 join 方法

join(): 是 Theard 的方法,作用是调用线程需等待该 join()线程执行完成后,才能继续用下运行。

应用场景: 当一个线程必须等待另一个线程执行完毕才能执行时可以使用 join 方法。

/** * 通过子程序join使线程按顺序执行 */ public class ThreadJoinDemo { public static void main(String[] args) { final Thread thread1 = new Thread(new Runnable() { @Override public void run() { System.out.println("产品经理规划新需求"); } }); final Thread thread2 = new Thread(new Runnable() { @Override public void run() { try { thread1.join(); System.out.println("开发人员开发新需求功能"); } catch (InterruptedException e) { e.printStackTrace(); } } }); Thread thread3 = new Thread(new Runnable() { @Override public void run() { try { thread2.join(); System.out.println("测试人员测试新功能"); } catch (InterruptedException e) { e.printStackTrace(); } } }); System.out.println("早上:"); System.out.println("测试人员来上班了..."); thread3.start(); System.out.println("产品经理来上班了..."); thread1.start(); System.out.println("开发人员来上班了..."); thread2.start(); } }

运行结果

早上:
测试人员来上班了…
产品经理来上班了…
开发人员来上班了…
产品经理规划新需求
开发人员开发新需求功能
测试人员测试新功能

2

使用主线程的 join 方法

这里是在主线程中使用 join()来实现对线程的阻塞。

/** * 通过主程序join使线程按顺序执行 */ public class ThreadMainJoinDemo { public static void main(String[] args) throws Exception { final Thread thread1 = new Thread(new Runnable() { @Override public void run() { System.out.println("产品经理正在规划新需求..."); } }); final Thread thread2 = new Thread(new Runnable() { @Override public void run() { System.out.println("开发人员开发新需求功能"); } }); final Thread thread3 = new Thread(new Runnable() { @Override public void run() { System.out.println("测试人员测试新功能"); } }); System.out.println("早上:"); System.out.println("产品经理来上班了"); System.out.println("测试人员来上班了"); System.out.println("开发人员来上班了"); thread1.start(); //在父进程调用子进程的join()方法后,父进程需要等待子进程运行完再继续运行。 System.out.println("开发人员和测试人员休息会..."); thread1.join(); System.out.println("产品经理新需求规划完成!"); thread2.start(); System.out.println("测试人员休息会..."); thread2.join(); thread3.start(); } }

复制

运行结果

产品经理来上班了
测试人员来上班了
开发人员来上班了
开发人员和测试人员休息会…
产品经理正在规划新需求…
产品经理新需求规划完成!
测试人员休息会…
开发人员开发新需求功能
测试人员测试新功能

3

使用线程的 wait 方法

wait(): 是 Object 的方法,作用是让当前线程进入等待状态,同时,wait()也会让当前线程释放它所持有的锁。“直到其他线程调用此对象的 notify() 方法或 notifyAll() 方法”,当前线程被唤醒(进入“就绪状态”)

notify()和 notifyAll(): 是 Object 的方法,作用则是唤醒当前对象上的等待线程;notify()是唤醒单个线程,而 notifyAll()是唤醒所有的线程。

wait(long timeout): 让当前线程处于“等待(阻塞)状态”,“直到其他线程调用此对象的 notify()方法或 notifyAll() 方法,或者超过指定的时间量”,当前线程被唤醒(进入“就绪状态”)。

应用场景: Java 实现生产者消费者的方式。

public class ThreadWaitDemo { private static Object myLock1 = new Object(); private static Object myLock2 = new Object(); /** * 为什么要加这两个标识状态? * 如果没有状态标识,当t1已经运行完了t2才运行,t2在等待t1唤醒导致t2永远处于等待状态 */ private static Boolean t1Run = false; private static Boolean t2Run = false; public static void main(String[] args) { final Thread thread1 = new Thread(new Runnable() { @Override public void run() { synchronized (myLock1){ System.out.println("产品经理规划新需求..."); t1Run = true; myLock1.notify(); } } }); final Thread thread2 = new Thread(new Runnable() { @Override public void run() { synchronized (myLock1){ try { if(!t1Run){ System.out.println("开发人员先休息会..."); myLock1.wait(); } synchronized (myLock2){ System.out.println("开发人员开发新需求功能"); myLock2.notify(); } } catch (InterruptedException e) { e.printStackTrace(); } } } }); Thread thread3 = new Thread(new Runnable() { @Override public void run() { synchronized (myLock2){ try { if(!t2Run){ System.out.println("测试人员先休息会..."); myLock2.wait(); } System.out.println("测试人员测试新功能"); } catch (InterruptedException e) { e.printStackTrace(); } } } }); System.out.println("早上:"); System.out.println("测试人员来上班了..."); thread3.start(); System.out.println("产品经理来上班了..."); thread1.start(); System.out.println("开发人员来上班了..."); thread2.start(); } }

运行结果:这里输出会有很多种顺序,主要是因为线程进入的顺序,造成锁住线程的顺序不一致。

早上:
测试人员来上班了…
产品经理来上班了…
开发人员来上班了…
测试人员先休息会…
产品经理规划新需求…
开发人员开发新需求功能
测试人员测试新功能

4

使用线程的线程池方法

JAVA 通过 Executors 提供了四种线程池

  • 单线程化线程池(newSingleThreadExecutor);
  • 可控最大并发数线程池(newFixedThreadPool);
  • 可回收缓存线程池(newCachedThreadPool);
  • 支持定时与周期性任务的线程池(newScheduledThreadPool)。

单线程化线程池(newSingleThreadExecutor): 优点,串行执行所有任务。

submit(): 提交任务。

shutdown(): 方法用来关闭线程池,拒绝新任务。

应用场景: 串行执行所有任务。如果这个唯一的线程因为异常结束,那么会有一个新的线程来替代它。此线程池保证所有任务的执行顺序按照任务的提交顺序执行。

import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; /** * 通过SingleThreadExecutor让线程按顺序执行 */ public class ThreadPoolDemo { static ExecutorService executorService = Executors.newSingleThreadExecutor(); public static void main(String[] args) throws Exception { final Thread thread1 = new Thread(new Runnable() { @Override public void run() { System.out.println("产品经理规划新需求"); } }); final Thread thread2 = new Thread(new Runnable() { @Override public void run() { System.out.println("开发人员开发新需求功能"); } }); Thread thread3 = new Thread(new Runnable() { @Override public void run() { System.out.println("测试人员测试新功能"); } }); System.out.println("早上:"); System.out.println("产品经理来上班了"); System.out.println("测试人员来上班了"); System.out.println("开发人员来上班了"); System.out.println("领导吩咐:"); System.out.println("首先,产品经理规划新需求..."); executorService.submit(thread1); System.out.println("然后,开发人员开发新需求功能..."); executorService.submit(thread2); System.out.println("最后,测试人员测试新功能..."); executorService.submit(thread3); executorService.shutdown(); } }

运行结果

早上:
产品经理来上班了
测试人员来上班了
开发人员来上班了
领导吩咐:
首先,产品经理规划新需求…
然后,开发人员开发新需求功能…
最后,测试人员测试新功能…
产品经理规划新需求
开发人员开发新需求功能
测试人员测试新功能

5

使用线程的 Condition(条件变量) 方法

Condition(条件变量): 通常与一个锁关联。需要在多个 Contidion 中共享一个锁时,可以传递一个 Lock/RLock 实例给构造方法,否则它将自己生成一个 RLock 实例。

  • Condition 中 await()方法类似于 Object 类中的 wait()方法。
  • Condition 中 await(long time,TimeUnit unit)方法类似于 Object 类中的 wait(long time)方法。
  • Condition 中 signal()方法类似于 Object 类中的 notify()方法。
  • Condition 中 signalAll()方法类似于 Object 类中的 notifyAll()方法。

应用场景: Condition 是一个多线程间协调通信的工具类,使得某个,或者某些线程一起等待某个条件(Condition),只有当该条件具备( signal 或者 signalAll 方法被调用)时 ,这些等待线程才会被唤醒,从而重新争夺锁。

import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; /** * 使用Condition(条件变量)实现线程按顺序运行 */ public class ThreadConditionDemo { private static Lock lock = new ReentrantLock(); private static Condition condition1 = lock.newCondition(); private static Condition condition2 = lock.newCondition(); /** * 为什么要加这两个标识状态? * 如果没有状态标识,当t1已经运行完了t2才运行,t2在等待t1唤醒导致t2永远处于等待状态 */ private static Boolean t1Run = false; private static Boolean t2Run = false; public static void main(String[] args) { final Thread thread1 = new Thread(new Runnable() { @Override public void run() { lock.lock(); System.out.println("产品经理规划新需求"); t1Run = true; condition1.signal(); lock.unlock(); } }); final Thread thread2 = new Thread(new Runnable() { @Override public void run() { lock.lock(); try { if(!t1Run){ System.out.println("开发人员先休息会..."); condition1.await(); } System.out.println("开发人员开发新需求功能"); t2Run = true; condition2.signal(); } catch (InterruptedException e) { e.printStackTrace(); } lock.unlock(); } }); Thread thread3 = new Thread(new Runnable() { @Override public void run() { lock.lock(); try { if(!t2Run){ System.out.println("测试人员先休息会..."); condition2.await(); } System.out.println("测试人员测试新功能"); lock.unlock(); } catch (InterruptedException e) { e.printStackTrace(); } } }); System.out.println("早上:"); System.out.println("测试人员来上班了..."); thread3.start(); System.out.println("产品经理来上班了..."); thread1.start(); System.out.println("开发人员来上班了..."); thread2.start(); } }

运行结果:这里输出会有很多种顺序,主要是因为线程进入的顺序,造成锁住线程的顺序不一致

早上:
测试人员来上班了…
产品经理来上班了…
开发人员来上班了…
测试人员先休息会…
产品经理规划新需求
开发人员开发新需求功能
测试人员测试新功能

6

使用线程的 CuDownLatch(倒计数) 方法

CountDownLatch: 位于 java.util.concurrent 包下,利用它可以实现类似计数器的功能。

应用场景: 比如有一个任务 C,它要等待其他任务 A,B 执行完毕之后才能执行,此时就可以利用 CountDownLatch 来实现这种功能了。

import java.util.concurrent.CountDownLatch; /** * 通过CountDownLatch(倒计数)使线程按顺序执行 */ public class ThreadCountDownLatchDemo { /** * 用于判断线程一是否执行,倒计时设置为1,执行后减1 */ private static CountDownLatch c1 = new CountDownLatch(1); /** * 用于判断线程二是否执行,倒计时设置为1,执行后减1 */ private static CountDownLatch c2 = new CountDownLatch(1); public static void main(String[] args) { final Thread thread1 = new Thread(new Runnable() { @Override public void run() { System.out.println("产品经理规划新需求"); //对c1倒计时-1 c1.countDown(); } }); final Thread thread2 = new Thread(new Runnable() { @Override public void run() { try { //等待c1倒计时,计时为0则往下运行 c1.await(); System.out.println("开发人员开发新需求功能"); //对c2倒计时-1 c2.countDown(); } catch (InterruptedException e) { e.printStackTrace(); } } }); Thread thread3 = new Thread(new Runnable() { @Override public void run() { try { //等待c2倒计时,计时为0则往下运行 c2.await(); System.out.println("测试人员测试新功能"); } catch (InterruptedException e) { e.printStackTrace(); } } }); System.out.println("早上:"); System.out.println("测试人员来上班了..."); thread3.start(); System.out.println("产品经理来上班了..."); thread1.start(); System.out.println("开发人员来上班了..."); thread2.start(); } }

运行结果

早上:
测试人员来上班了…
产品经理来上班了…
开发人员来上班了…
产品经理规划新需求
开发人员开发新需求功能
测试人员测试新功能

7

使用 CyclicBarrier (回环栅栏)实现线程按顺序执行

CyclicBarrier(回环栅栏): 通过它可以实现让一组线程等待至某个状态之后再全部同时执行。叫做回环是因为当所有等待线程都被释放以后,CyclicBarrier 可以被重用。我们暂且把这个状态就叫做 barrier,当调用 await()方法之后,线程就处于 barrier 了。

应用场景: 公司组织春游,等待所有的员工到达集合地点才能出发,每个人到达后进入 barrier 状态。都到达后,唤起大家一起出发去旅行。

import java.util.concurrent.BrokenBarrierException; import java.util.concurrent.CyclicBarrier; /** * 使用CyclicBarrier(回环栅栏)实现线程按顺序运行 */ public class CyclicBarrierDemo { static CyclicBarrier barrier1 = new CyclicBarrier(2); static CyclicBarrier barrier2 = new CyclicBarrier(2); public static void main(String[] args) { final Thread thread1 = new Thread(new Runnable() { @Override public void run() { try { System.out.println("产品经理规划新需求"); //放开栅栏1 barrier1.await(); } catch (InterruptedException e) { e.printStackTrace(); } catch (BrokenBarrierException e) { e.printStackTrace(); } } }); final Thread thread2 = new Thread(new Runnable() { @Override public void run() { try { //放开栅栏1 barrier1.await(); System.out.println("开发人员开发新需求功能"); //放开栅栏2 barrier2.await(); } catch (InterruptedException e) { e.printStackTrace(); } catch (BrokenBarrierException e) { e.printStackTrace(); } } }); final Thread thread3 = new Thread(new Runnable() { @Override public void run() { try { //放开栅栏2 barrier2.await(); System.out.println("测试人员测试新功能"); } catch (InterruptedException e) { e.printStackTrace(); } catch (BrokenBarrierException e) { e.printStackTrace(); } } }); System.out.println("早上:"); System.out.println("测试人员来上班了..."); thread3.start(); System.out.println("产品经理来上班了..."); thread1.start(); System.out.println("开发人员来上班了..."); thread2.start(); } }

运行结果

早上:
测试人员来上班了…
产品经理来上班了…
开发人员来上班了…
产品经理规划新需求
开发人员开发新需求功能
测试人员测试新功能

8

使用线程的 Sephmore(信号量) 实现线程按顺序执行

Sephmore(信号量): Semaphore 是一个计数信号量,从概念上将,Semaphore 包含一组许可证,如果有需要的话,每个 acquire()方法都会阻塞,直到获取一个可用的许可证,每个 release()方法都会释放持有许可证的线程,并且归还 Semaphore 一个可用的许可证。然而,实际上并没有真实的许可证对象供线程使用,Semaphore 只是对可用的数量进行管理维护。

acquire(): 当前线程尝试去阻塞的获取 1 个许可证,此过程是阻塞的,当前线程获取了 1 个可用的许可证,则会停止等待,继续执行。

release(): 当前线程释放 1 个可用的许可证。

应用场景: Semaphore 可以用来做流量分流,特别是对公共资源有限的场景,比如数据库连接。假设有这个的需求,读取几万个文件的数据到数据库中,由于文件读取是 IO 密集型任务,可以启动几十个线程并发读取,但是数据库连接数只有 10 个,这时就必须控制最多只有 10 个线程能够拿到数据库连接进行操作。这个时候,就可以使用 Semaphore 做流量控制。

import java.util.concurrent.Semaphore; /** * 使用Sephmore(信号量)实现线程按顺序运行 */ public class SemaphoreDemo { private static Semaphore semaphore1 = new Semaphore(1); private static Semaphore semaphore2 = new Semaphore(1); public static void main(String[] args) { final Thread thread1 = new Thread(new Runnable() { @Override public void run() { System.out.println("产品经理规划新需求"); semaphore1.release(); } }); final Thread thread2 = new Thread(new Runnable() { @Override public void run() { try { semaphore1.acquire(); System.out.println("开发人员开发新需求功能"); semaphore2.release(); } catch (InterruptedException e) { e.printStackTrace(); } } }); Thread thread3 = new Thread(new Runnable() { @Override public void run() { try { semaphore2.acquire(); thread2.join(); semaphore2.release(); System.out.println("测试人员测试新功能"); } catch (InterruptedException e) { e.printStackTrace(); } } }); System.out.println("早上:"); System.out.println("测试人员来上班了..."); thread3.start(); System.out.println("产品经理来上班了..."); thread1.start(); System.out.println("开发人员来上班了..."); thread2.start(); } }

运行结果

早上:
测试人员来上班了…
产品经理来上班了…
开发人员来上班了…
产品经理规划新需求
开发人员开发新需求功能
测试人员测试新功能

  • Java

    Java 是一种可以撰写跨平台应用软件的面向对象的程序设计语言,是由 Sun Microsystems 公司于 1995 年 5 月推出的。Java 技术具有卓越的通用性、高效性、平台移植性和安全性。

    3198 引用 • 8215 回帖 • 1 关注
  • 线程
    123 引用 • 111 回帖 • 3 关注

相关帖子

欢迎来到这里!

我们正在构建一个小众社区,大家在这里相互信任,以平等 • 自由 • 奔放的价值观进行分享交流。最终,希望大家能够找到与自己志同道合的伙伴,共同成长。

注册 关于
请输入回帖内容 ...

推荐标签 标签

  • Ant-Design

    Ant Design 是服务于企业级产品的设计体系,基于确定和自然的设计价值观上的模块化解决方案,让设计者和开发者专注于更好的用户体验。

    17 引用 • 23 回帖 • 3 关注
  • FreeMarker

    FreeMarker 是一款好用且功能强大的 Java 模版引擎。

    23 引用 • 20 回帖 • 462 关注
  • Linux

    Linux 是一套免费使用和自由传播的类 Unix 操作系统,是一个基于 POSIX 和 Unix 的多用户、多任务、支持多线程和多 CPU 的操作系统。它能运行主要的 Unix 工具软件、应用程序和网络协议,并支持 32 位和 64 位硬件。Linux 继承了 Unix 以网络为核心的设计思想,是一个性能稳定的多用户网络操作系统。

    952 引用 • 944 回帖
  • Sphinx

    Sphinx 是一个基于 SQL 的全文检索引擎,可以结合 MySQL、PostgreSQL 做全文搜索,它可以提供比数据库本身更专业的搜索功能,使得应用程序更容易实现专业化的全文检索。

    1 引用 • 222 关注
  • GitHub

    GitHub 于 2008 年上线,目前,除了 Git 代码仓库托管及基本的 Web 管理界面以外,还提供了订阅、讨论组、文本渲染、在线文件编辑器、协作图谱(报表)、代码片段分享(Gist)等功能。正因为这些功能所提供的便利,又经过长期的积累,GitHub 的用户活跃度很高,在开源世界里享有深远的声望,并形成了社交化编程文化(Social Coding)。

    210 引用 • 2040 回帖
  • 新人

    让我们欢迎这对新人。哦,不好意思说错了,让我们欢迎这位新人!
    新手上路,请谨慎驾驶!

    52 引用 • 228 回帖 • 1 关注
  • etcd

    etcd 是一个分布式、高可用的 key-value 数据存储,专门用于在分布式系统中保存关键数据。

    6 引用 • 26 回帖 • 546 关注
  • Mobi.css

    Mobi.css is a lightweight, flexible CSS framework that focus on mobile.

    1 引用 • 6 回帖 • 759 关注
  • Typecho

    Typecho 是一款博客程序,它在 GPLv2 许可证下发行,基于 PHP 构建,可以运行在各种平台上,支持多种数据库(MySQL、PostgreSQL、SQLite)。

    12 引用 • 67 回帖 • 449 关注
  • wolai

    我来 wolai:不仅仅是未来的云端笔记!

    2 引用 • 14 回帖 • 2 关注
  • Android

    Android 是一种以 Linux 为基础的开放源码操作系统,主要使用于便携设备。2005 年由 Google 收购注资,并拉拢多家制造商组成开放手机联盟开发改良,逐渐扩展到到平板电脑及其他领域上。

    335 引用 • 324 回帖
  • Hexo

    Hexo 是一款快速、简洁且高效的博客框架,使用 Node.js 编写。

    22 引用 • 148 回帖 • 16 关注
  • CongSec

    本标签主要用于分享网络空间安全专业的学习笔记

    1 引用 • 1 回帖 • 29 关注
  • 安全

    安全永远都不是一个小问题。

    203 引用 • 818 回帖
  • QQ

    1999 年 2 月腾讯正式推出“腾讯 QQ”,在线用户由 1999 年的 2 人(马化腾和张志东)到现在已经发展到上亿用户了,在线人数超过一亿,是目前使用最广泛的聊天软件之一。

    45 引用 • 557 回帖 • 2 关注
  • ZeroNet

    ZeroNet 是一个基于比特币加密技术和 BT 网络技术的去中心化的、开放开源的网络和交流系统。

    1 引用 • 21 回帖 • 648 关注
  • Flutter

    Flutter 是谷歌的移动 UI 框架,可以快速在 iOS 和 Android 上构建高质量的原生用户界面。 Flutter 可以与现有的代码一起工作,它正在被越来越多的开发者和组织使用,并且 Flutter 是完全免费、开源的。

    39 引用 • 92 回帖
  • 链书

    链书(Chainbook)是 B3log 开源社区提供的区块链纸质书交易平台,通过 B3T 实现共享激励与价值链。可将你的闲置书籍上架到链书,我们共同构建这个全新的交易平台,让闲置书籍继续发挥它的价值。

    链书社

    链书目前已经下线,也许以后还有计划重制上线。

    14 引用 • 257 回帖 • 1 关注
  • WiFiDog

    WiFiDog 是一套开源的无线热点认证管理工具,主要功能包括:位置相关的内容递送;用户认证和授权;集中式网络监控。

    1 引用 • 7 回帖 • 611 关注
  • 脑图

    脑图又叫思维导图,是表达发散性思维的有效图形思维工具 ,它简单却又很有效,是一种实用性的思维工具。

    32 引用 • 99 回帖
  • IBM

    IBM(国际商业机器公司)或万国商业机器公司,简称 IBM(International Business Machines Corporation),总公司在纽约州阿蒙克市。1911 年托马斯·沃森创立于美国,是全球最大的信息技术和业务解决方案公司,拥有全球雇员 30 多万人,业务遍及 160 多个国家和地区。

    17 引用 • 53 回帖 • 146 关注
  • 微服务

    微服务架构是一种架构模式,它提倡将单一应用划分成一组小的服务。服务之间互相协调,互相配合,为用户提供最终价值。每个服务运行在独立的进程中。服务于服务之间才用轻量级的通信机制互相沟通。每个服务都围绕着具体业务构建,能够被独立的部署。

    96 引用 • 155 回帖
  • 996
    13 引用 • 200 回帖 • 3 关注
  • Vue.js

    Vue.js(读音 /vju ː/,类似于 view)是一个构建数据驱动的 Web 界面库。Vue.js 的目标是通过尽可能简单的 API 实现响应的数据绑定和组合的视图组件。

    267 引用 • 666 回帖 • 1 关注
  • Rust

    Rust 是一门赋予每个人构建可靠且高效软件能力的语言。Rust 由 Mozilla 开发,最早发布于 2014 年 9 月。

    58 引用 • 22 回帖 • 7 关注
  • Solidity

    Solidity 是一种智能合约高级语言,运行在 [以太坊] 虚拟机(EVM)之上。它的语法接近于 JavaScript,是一种面向对象的语言。

    3 引用 • 18 回帖 • 437 关注
  • 资讯

    资讯是用户因为及时地获得它并利用它而能够在相对短的时间内给自己带来价值的信息,资讯有时效性和地域性。

    56 引用 • 85 回帖 • 1 关注