java如何实现多线程的顺序执行

更新时间：2021年05月16日 11:50:23 作者：Hoonick

多线程是java的一种重要技术，但是多线程的运行是没有绝对的顺序的，那么java如何实现多线程的顺序执行，下面就一起来了解一下

场景

编写一个程序，启动三个线程，三个线程的name分别是A，B，C；，每个线程将自己的ID值在屏幕上打印5遍，打印顺序是ABCABC...

使用 synchronized 实现

public class MyService
{
    private int flag = 1;
    
    public synchronized void printA(){
        
        while (flag != 1)
        {
            try
            {
                this.wait();
            }
            catch (InterruptedException e)
            {
                e.printStackTrace();
            }
        }
        System.out.print(Thread.currentThread().getName());
        flag = 2;
        this.notifyAll();
    }
    public synchronized void printB(){
        while (flag != 2)
        {
            try
            {
                this.wait();
            }
            catch (InterruptedException e)
            {
                e.printStackTrace();
            }
        }
        System.out.print(Thread.currentThread().getName());
        flag = 3;
        this.notifyAll();
    }
    public synchronized void printC(){
        while (flag != 3)
        {
            try
            {
                this.wait();
            }
            catch (InterruptedException e)
            {
                e.printStackTrace();
            }
        }
        System.out.print(Thread.currentThread().getName());
        flag = 1;
        this.notifyAll();
    }
}

这里的判断条件中用的是 while 而不是 if , 这两者之间有什么区别呢？线程从 wait 状态被唤醒,并且获得锁以后会继续往下执行，比如 A 调用nofityAll() 唤醒 B，C，这时 B与C谁会先获得锁是不确定的。如果是C先获得了锁，那么C就继续往下执行打印，这与我们的期望的不符。所以这里我们使用了一个 while，当C获得锁以后再去判断一下flag，如果这时还不是它执行的时候，它就再次进入wait状态。此时A与C都是wait状态，获得锁的一定是B，从而实现我们期望的顺序打印。

测试类

package testABC;

public class TestMain
{
    public static void main(String[] args)
    {
//编写一个程序，启动三个线程，三个线程的ID分别是A，B，C；，每个线程将自己的ID值在屏幕上打印5遍，打印顺序是ABCABC...
//        MyService service = new MyService();
        MyService2 service = new MyService2();
        
        Thread A = new Thread(new Runnable()
        {
            @Override
            public void run()
            {
                for (int i = 0; i < 5; i++)
                {
                    service.printA();
                }
            }
        });
        A.setName("A");
        Thread B = new Thread(new Runnable()
        {
            @Override
            public void run()
            {
                for (int i = 0; i < 5; i++)
                {
                    service.printB();
                }
            }
        });
        B.setName("B");
        Thread C = new Thread(new Runnable()
        {
            @Override
            public void run()
            {
                for (int i = 0; i < 5; i++)
                {
                    service.printC();
                }
            }
        });
        C.setName("C");
        
        A.start();
        B.start();
        C.start();
    }
}

使用 Lock 实现

import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class MyService2
{
    private int flag = 1;
    private Lock lock = new ReentrantLock();
    private Condition conditionA = lock.newCondition();
    private Condition conditionB = lock.newCondition();
    private Condition conditionC = lock.newCondition();

    public void printA()
    {
        try
        {
            lock.lock();
            if (flag != 1)
            {
                try
                {
                    conditionA.await();
                }
                catch (InterruptedException e)
                {
                    e.printStackTrace();
                }
            }
            System.out.print(Thread.currentThread().getName());
            flag = 2;
            conditionB.signal();
        }
        finally
        {
            lock.unlock();
        }

    }

    public void printB()
    {
        try
        {
            lock.lock();
            if (flag != 2)
            {
                try
                {
                    conditionB.await();
                }
                catch (InterruptedException e)
                {
                    e.printStackTrace();
                }
            }
            System.out.print(Thread.currentThread().getName());
            flag = 3;
            conditionC.signal();
        }
        finally
        {
            lock.unlock();
        }

    }

    public void printC()
    {
        try
        {
            lock.lock();
            if (flag != 3)
            {
                try
                {
                    conditionC.await();
                }
                catch (InterruptedException e)
                {
                    e.printStackTrace();
                }
            }
            System.out.print(Thread.currentThread().getName());
            flag = 1;
            conditionA.signal();
        }
        finally
        {
            lock.unlock();
        }
    }
}

当使用LOCK时可以不使用while因为condition可以唤醒指定的线程。同时注意必须先调用 conditionA.signal(); 再调用 lock.unlock(); ，否则会抛 java.lang.IllegalMonitorStateException 异常。因为在调用unlock之后，当前线程已不是此监视器对象condition的持有者。也就是说要在此线程持有锁定对象时，才能使用此锁定对象。

关于此异常的博文：关于java.lang.IllegalMonitorStateException

api中的解释

public class IllegalMonitorStateExceptionextends RuntimeException

抛出的异常表明某一线程已经试图等待对象的监视器，或者试图通知其他正在等待对象的监视器而本身没有指定监视器的线程。

从以下版本开始：

JDK1.0

另请参见：
Object.notify(), Object.notifyAll(), Object.wait(), Object.wait(long), Object.wait(long, int), 序列化表格

也就是当前的线程不是此对象监视器的所有者。也就是要在当前线程锁定对象，才能用锁定的对象此行这些方法，需要用到synchronized ，锁定什么对象就用什么对象来执行

notify(), notifyAll(),wait(), wait(long), wait(long, int)操作，否则就会报IllegalMonitorStateException异常。

例如 :

exapmle 1,锁定方法所属的实例对象:

public synchronized void method（）{
    //然后就可以调用：this.notify()...
    //或者直接调用notify()...
}

exapmle 2,锁定方法所属的实例的Class:

public Class Test{
 public static synchronized void method（）{
    //然后调用：Test.class.notify()...
 }
}

exapmle 3,锁定其他对象:

public Class Test{
public Object lock = new Object();
 public static void method（）{
    synchronized (lock) {
     //需要调用 lock.notify();
    } 
 }
}

到此这篇关于java如何实现多线程的顺序执行的文章就介绍到这了,更多相关java 多线程顺序执行内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

SpringBoot任务之详解邮件任务
今天给大家整理的文章是SpringBoot邮件任务的相关知识点,文中有非常详细的介绍及代码示例,对正在学习SpringBoot任务的小伙伴们很有帮助,需要的朋友可以参考下
2021-06-06
win7下安装 JDK 基本流程
这篇文章主要介绍了win7下安装 JDK 基本流程,需要的朋友可以参考下
2014-05-05
解决dubbo错误ip及ip乱入问题的方法
今天小编就为大家分享一篇关于解决dubbo错误ip及ip乱入问题的方法，小编觉得内容挺不错的，现在分享给大家，具有很好的参考价值，需要的朋友一起跟随小编来看看吧
2019-03-03
Java发起http请求的完整步骤记录
这篇文章主要给大家介绍了关于Java发起http请求的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2021-02-02
Java 是如何利用接口避免函数回调的方法
本篇文章主要介绍了Java 是如何利用接口避免函数回调的方法，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2018-02-02
PowerJob的HashedWheelTimer工作流程源码解读
这篇文章主要为大家介绍了PowerJob的HashedWheelTimer工作流程源码解读,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
2024-01-01
java的泛型你真的了解吗
这篇文章主要为大家详细介绍了java的泛型，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下，希望能够给你带来帮助
2022-03-03
IDEA项目中配置Maven镜像源(下载源)的详细过程
Maven是一个能使我们的java程序开发节省时间和精力,是开发变得相对简单,还能使开发规范化的工具,下面这篇文章主要给大家介绍了关于IDEA项目中配置Maven镜像源(下载源)的详细过程,需要的朋友可以参考下
2024-02-02
Java8的Lambda表达式你真的会吗
这篇文章主要介绍了Java8的Lambda表达式你真的会吗,本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2021-01-01
Spring Cloud动态配置刷新@RefreshScope与@Component的深度解析
在现代微服务架构中,动态配置管理是一个关键需求,Spring Cloud 提供了 @RefreshScope 注解,允许应用在运行时动态更新配置,而无需重启服务,本文深入探析Spring Cloud动态配置刷新@RefreshScope与@Component,感兴趣的朋友一起看看吧
2025-04-04