Java并发编程 使用锁和状态位来控制线程的执行顺序

news2024/9/27 17:25:51

Java线程生命周期的认识

对于线程的生命周期,在Java和操作系统中,在概念上有一点小小的不同。

在操作系统层面上,线程的生命周期如下:

1.新建
2.就绪
3.阻塞
4.运行
5.终止

在这里插入图片描述

而在Java层面上,则把线程的阻塞状态又划分出了2个状态,一个就是有限时间的等待,和无限时间的等待。

所以在Java层面来看,线程拥有如下几个状态:

1.新建
2.阻塞
3.无限时间等待
4.有限时间等待
5.就绪
6.运行
7.终止

在这里插入图片描述

1.无限等待队列:当调用Object.wait()、Thread.join()等方法时,线程进入无限时间的等待队列中。除非有其它线程执行notify或者notifyAll方法,不然这个线程是不会进入就绪状态。
2.有限等待队列:当调用 Thread.sleep()、Object.wait(long timeout)、Thread.join(long millis)等方法时,则线程就会进入有限时间的等待队列中。当达到指定的等待时间后,线程就会进入到就绪状态中。

知道了关于线程生命周期概念上的认识后,那么我们现在接着来了解下,如果想要控制线程的执行顺序,那么应该以哪些为切入点来实现。

控制线程顺序执行的方式

锁和状态位的认识

为了控制线程按序执行,这里有2个关键的认识需要了解下:

1.锁:通过锁,来保证线程的执行不受并发和并行的影响。这个是使线程执行顺序可控的基础。
2.状态位:通过状态位,起到一个线程通知的作用,从而控制线程的执行顺序。

下面具体说明下锁和状态位。

首先说明下为什么锁是线程执行顺序可控的基础。

首先需要知道,线程的调度是基于操作系统的调度算法的,是不可控的。那么以CPU单核的视角来看,多线程是并发执行的,以CPU多核的视角来看,多线程是并行执行的。

对于在并发和并行下多线程的执行状态,是不可控的乱序的。因为此时线程的执行顺序取决于操作系统的调度算法。所以在这里,我们需要通过锁,来保证当存在有多个线程被同时启动,且需要保证这些线程执行的顺序性的话,则就需要通过锁来保证这个待执行多线程集合中,一次只有一个线程被调度,从而来避免CPU并发和并行时线程执行乱序的现象。

现在接着再说明下状态位的作用。

这里的状态位就相当于是线程通信的这样的一个作用。线程可以通过对这个状态位的判断,来判断是否可以执行。那么这也就意味着,我们可以根据自己的需要,去调整状态位的变化,从而达到控制线程执行状态的效果,也就是让线程在某种顺序下被调度执行。

切换线程状态的方式

知道了关于锁和状态位的相关认识后,接着来了解下切换线程状态的方式。

1.wait():让当前线程进入无限时间等待队列。
2.notifyAll():通知所有处在等待队列的线程进入就绪状态,即可运行状态。

知道了以上这些概念上的认识后,那么我们来尝试实现几种控制线程操作的场景。

实际应用

1.控制两个线程交替执行

要让两个线程交替执行,那么需要有一个通知机制,让这两个线程互相知道它们执行的状态,即执行完成与否。

比如当线程1执行完后,线程2才可以被执行。那么通过这个通知机制,比如从false到true状态的切换,线程2可以通过判断这个变量是否等于true,来判断自己是否可以执行。

这里以变量A来举例说明,变量A表明线程1的执行状态,为true则表明线程1已执行完毕,那么也意味线程2可以执行。所以,当线程1执行完毕后,就需要更新变量A为true,并唤醒正在等待的线程2,并释放锁,使得线程2有机会获得锁,并进入运行状态。

那么被唤醒了的线程2,由于线程1释放了锁,所以线程2可以获取到锁并进入运行状态,并且通过判断变量A的状态,来确定是否继续执行,当确认线程2可以执行,并在执行完成后,线程2更新变量A的状态,为false,表明线程1可以执行,线程2不可以执行,且同时,唤醒线程1,使自己进入等待队列,并释放锁,从而使线程1有机会进入运行状态。

通过这个过程,我们可以看到,在基于变量A做线程通知,及锁的控制下,保证一次只可以有一个线程被调度执行的情况下,我们可以根据自己的需要,去控制线程的执行状态。

实现这个需求的大体思路如下:

1.使用锁,来保证线程1和线程2一次只可以执行一个,以避免并发和并行,导致的乱序问题。
2.使用状态位,true或false,来控制线程1和线程2执行的时机。

下面附上实现代码:

public class SynchronizedExample {
    private static final Object lock = new Object();
    private static boolean isThreadAExecuted = false;
    public static void main(String[] args) {
        Thread threadA = new Thread(() -> {
            synchronized (lock) {
                while (!isThreadAExecuted) {
                    try {
                    	// 使线程A进入等待队列
                        lock.wait();
                    } catch (InterruptedException e) {
                        Thread.currentThread().interrupt();
                    }
                }
                System.out.println("Thread A is executing");
                // 通过这个状态位,通知线程B可以执行,自己不可以执行
                isThreadAExecuted = true;
                // 唤醒线程B
                lock.notifyAll();
            }
        });
        Thread threadB = new Thread(() -> {
            synchronized (lock) {
                while (isThreadAExecuted) {
                    try {
                    	// 由于线程A还未执行,所以自己还不可以执行
                        lock.wait();
                    } catch (InterruptedException e) {
                        Thread.currentThread().interrupt();
                    }
                }
                System.out.println("Thread B is executing");
                // 通过这个状态位,通知线程A可以执行,自己不可以执行
                isThreadAExecuted = false;
                // 唤醒线程A
                lock.notifyAll();
            }
        });
        threadA.start();
        threadB.start();
    }
}

2.控制线程2在线程1和3之后执行,且线程1和3顺序不需要控制

那么如果是3个以上的线程呢?比如1、2、3,这3个线程,线程2的执行顺序必须要在1和3之后,而1和3的执行顺序则是可以乱序的。那么在这种情况下,我们实现的思路可以是怎样的呢?

首先我们依然需要使用共享变量,以及锁。

首先需要2个状态位,即变量,分别对应线程1和线程3的执行状态,执行完成与否。线程2可以通过这2个状态位,来决定执行的时机。且当线程2执行完成了之后,可以通过重置这2个状态位,来让线程1和线程3,进入到可运行的状态。

所以实现这个需求的大体思路如下:

1.使用锁,避免并发和并行的影响,以保证线程可以可控的按序执行。
2.使用两个状态位分别对应线程1和3的执行状态。
3.线程1和3通过各自的状态位,来判断是否进入等待还是可执行状态。
4.线程2通过线程1和3的状态位,来判断是否进入等待还是可执行状态。
5.线程2执行完成后,重置线程1和3对应的状态位,从而使自身进入到等待状态,且使线程1和3进入到可运行状态。

下面附上代码:

public class ThreadOrderExample {
    private static final Object lock = new Object();
    private static boolean t1Done = false;
    private static boolean t3Done = false;

    public static void main(String[] args) {
        Thread t1 = new Thread(() -> {
            synchronized (lock) {
                try {
                    if (!t1Done) {
                        System.out.println("Thread 1 is running");
                        // 标记线程1已执行完,从而避免被唤醒而导致的重复执行
                        t1Done = true;
                        lock.notifyAll();
                    }
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        });

        Thread t3 = new Thread(() -> {
            synchronized (lock) {
                try {
                    if (!t3Done) {
                        System.out.println("Thread 3 is running");
                        // 标记线程3已执行完,从而避免被唤醒而导致的重复执行
                        t3Done = true;
                        lock.notifyAll();
                    }
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        });

        Thread t2 = new Thread(() -> {
            synchronized (lock) {
                try {
                    while (!t1Done || !t3Done) {
                        lock.wait();
                    }
                    System.out.println("Thread 2 is running");
                    // 重置线程1和3的执行状态,使其可以进入可运行的状态,从而使线程2进入等待状态,线程1和3进入可运行状态
                    t1Done = false;
                    t3Done = false;
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        });

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

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/1975397.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

详细分析Flask部署云服务器(图文介绍)

目录 前言1. 安装配置2. 代码部署3. 服务配置4. 自启动前言 Nginx信息补充阅读: Nginx从入门到精通(全)Nginx配置静态网页访问(图文界面)本文着重提供思路逻辑 1. 安装配置 最好的方式是安装docker,通过docker安装nginx,推荐阅读:Docker零基础从入门到精通(全)包环…

与用户有关的接口

1.获取用户详细信息 跟着黑马程序员继续学习SpringBoot3Vue3 用户登录成功之后跳转到首页,需要获取用户的详细信息 打开接口文档 使用Token令牌解析得到用户名 我们需要根据用户名查询用户,获取详细信息 但是请求参数是无,由于都需要携…

标题生成器:开启创意写作的新篇章

文章目录 角色与目标标题生成器的功能标题生成器的优势指导原则限制与澄清应用场景对创意写作的影响智能体发布到微信公众号配置公众号菜单配置自动回复自动回复文本链接自动回复二维码图片 标题生成器的未来发展总结 博主介绍:全网粉丝10w、CSDN合伙人、华为云特邀…

C++入门基本语法(1)

一、命名空间namespace 定义变量、函数时,定义的名称可能会和头文件中或者自己重复使用的名称冲突;namespace可以对标识符的名称进行本地化,以避免冲突的问题; ## 例如: ## 出现这种问题的原因: &#x…

MySQL系列之--详细安装教程和启动方法

文章目录 安装教程打开或关闭方式方式1:方式2: 客户端连接方式客户端连接方式1:客户端连接方式2:MySQL环境变量的配置 安装教程 1、mysql官网下载最新的符合本系统的版本 2、点击.msi文件进入安装页面 选择默认的选项开发者安…

品味食家巷蛋奶酪饼,感受西北美食魅力

在广袤的西北大地,美食的丰富多样令人叹为观止。而食家巷蛋奶酪饼,宛如一颗璀璨的明珠,散发着独特的魅力。 这款蛋奶酪饼,是传统工艺与现代口味的完美融合。而当你继续品尝,鸡蛋的鲜嫩和奶酪的浓郁醇厚便会在口中交融…

跟《经济学人》学英文:2024年08月03日这期 GPT, Claude, Llama? How to tell which AI model is best

GPT, Claude, Llama? How to tell which AI model is best Beware model-makers marking their own homework 原文: When Meta, the parent company of Facebook, announced its latest open- source large language model (LLM) on July 23rd, it claimed that…

vue2 使用 tinymce富文本编辑器

注意: 在vue2中使用tinymce有版本限制的,最新版都是支持v3的,官方也说明了; vue2中不能使用tinymce/tinymce-vue 为4以上的版本; 使用步骤: 1、vue项目中安装 tinymce; npm install tinymce5.…

用TensorFlow训练自己的第一个模型

现在学AI的一个优势就是:前人栽树后人乘凉,很多资料都已完善,而且有很多很棒的开源作品可以学习,感谢大佬们 项目 项目源码地址 视频教程地址 我在大佬的基础上基于此模型还加上了根据特征值缓存进行快速识别的方法,…

【教程】Python语言的地球科学常见数据——全球大气再分析数据

a、多年数据的读取 b、趋势分析 c、多时间尺度统计。 ECMWF 中心推出的 ERA5 全球大气再分析数据提供了大量大气、陆地和海洋气候变量的逐小时数据。这些数据在 30km 网格上覆盖了全球,在时间跨度上从 1979 至今。该数据能够提供全球范围的格点气象数据。 将针对该…

react-native从入门到实战系列教程一Switch组件和StatusBar的运用

跨平台通用的组件。这是一个受控组件,你必须使用onValueChange回调来更新value属性以响应用户的操作。如果不更新value属性,组件只会按一开始给定的value值来渲染且保持不变,看上去就像完全点不动。 实现效果 代码实现 import {View, Text,…

力扣hot100-二叉树

文章目录 概要二叉树的基本概念常见的二叉树类型常用的二叉树遍历二叉树的常用技巧 题目:二叉树的中序遍历方法1--递归遍历方法2--使用栈 概要 二叉树(Binary Tree)是一种树形数据结构,其中每个节点最多有两个子节点,…

DC-2靶机试试看 继续打靶!!冲冲冲!!

要更改一下自己的host,这样才可以正确的访问我们的靶机的页面。 下面看看我的思路吧: 前面还是老样子,先发现靶机的ip地址以及收集他开放了哪些端口等等的信息 查看相对应的cms 我用了一些msf的模块没有打下来这个站点 收集相关的信息&…

【计算机人接私活】手把手教你上手挖到第一个漏洞,从底薪3k到月入过万,只有一步之遥!

计算机人想接靠谱的私活?看这篇! 暑假想做兼职赚生活费?看这篇! 挖漏洞找不到门路?看这篇! 挖漏洞必备工具 Up入行网安多年,一直在探索副业项目。 从最初的月薪5k,到现在一个漏…

[米联客-安路飞龙DR1-FPSOC] UDP通信篇连载-01 以太网协议介绍

软件版本:Anlogic -TD5.9.1-DR1_ES1.1 操作系统:WIN10 64bit 硬件平台:适用安路(Anlogic)FPGA 实验平台:米联客-MLK-L1-CZ06-DR1M90G开发板 板卡获取平台:https://milianke.tmall.com/ 登录“米联客”FPGA社区 ht…

SpringBoot 3的两种SPI加载方式

从spring boot 2.7.0发布后, 自动配置类的加载方式就发生了改变,原来从META-INF/spring.factories文件中加载,变为了从META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports文件中加载,对应的加载实…

Ubuntu下python3.12安装, 分布式 LLM 推理 exo 安装调试过程, 运行自己的 AI 集群

创作不易 只因热爱!! 热衷分享,一起成长! “你的鼓励就是我努力付出的动力” —调试有点废,文章有点长,希望大家用心看完,肯定能学废,感谢. 1. Ubuntu下python3.12安装 1.1 导入 Python 的稳定版 PPA,不用编译 sudo add-apt-repository ppa:deadsnakes/ppa sudo…

82.WEB渗透测试-信息收集-框架组件识别利用(6)

免责声明:内容仅供学习参考,请合法利用知识,禁止进行违法犯罪活动! 内容参考于: 易锦网校会员专享课 上一个内容:81.WEB渗透测试-信息收集-框架组件识别利用(5) log4j/log4j2&…

《Excelize权威指南》新书发布

在数据洪流涌动的数字化时代,数据处理与分析已跃升为解锁无限洞察力的金钥匙,赋能商业智慧、重塑医疗健康版图、驱动教育科研创新。然而,当数据量级爆炸式增长,传统工具如 Excel 虽被誉为数据处理领域的常青树,其手动操…