Java基础 浅谈线程补充 -------lock实现消费者和生产者以及精确唤醒

本文主要是介绍Java基础 浅谈线程补充 -------lock实现消费者和生产者以及精确唤醒,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

我们一直使用synchronized来聊经典模式消费者与生产者,在同步安全的时候我们除了讲解synchronized以外,还讲解了lock,对数据进行安全进行保护。那么问题就来了,是否可以通过lock实现消费者和生产者呢?

答案肯定是能,但是应该好奇是如何实现?

先看代码


class Data{private int num=0;Lock lock= new ReentrantLock();public void increment(){lock.lock();try {while (num!=0) {lock.wait();} }catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();} finally {lock.unlock();} num++;System.out.println(Thread.currentThread().getName()+"现在是number="+num);lock.notifyAll();}public void decrement(){lock.lock();try {while (num==0) {lock.wait();} }catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();} finally {lock.unlock();} num--;System.out.println(Thread.currentThread().getName()+"现在是number="+num);lock.notinofyAll();}} public class Test {public static void main(String[] args) {Data  data=new Data();new Thread(()->{for (int i=0;i<10;i++){data.decrement();}},"线程A").start();new Thread(()->{for(int i=0;i<10;i++) {data.increment();}} , "线程b").start() ;}
}
//输出
Exception in thread "线程A" Exception in thread "线程b" 线程b现在是number=1java.lang.IllegalMonitorStateExceptionat java.lang.Object.wait(Native Method)at java.lang.Object.wait(Unknown Source)at test.Data.decrement(Test.java:66)at test.Test.lambda$0(Test.java:22)at java.lang.Thread.run(Unknown Source)
java.lang.IllegalMonitorStateExceptionat java.lang.Object.notifyAll(Native Method)at test.Data.increment(Test.java:58)at test.Test.lambda$1(Test.java:31)at java.lang.Thread.run(Unknown Source)

只是简单的讲synchronized换程了lock和unlock,代码编辑器提示可以使用wait方法呢notinofyAll方法,所以第一反应,这个简单,可以直接依葫芦画瓢,然而输出的确实打脸了。

这个异常时一个非法异常,说明在编译没有异常,而是一个运行异常。还有就是为什么可以编译使用lock调用wait?

这个需要看jdk帮助文档:

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-f8GZHwVG-1604646302129)(C:\Users\jhfan\AppData\Roaming\Typora\typora-user-images\image-20201105164725110.png)]

可以看出这继承了object,所以可以使用object中的方法。

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-FLQCmPiA-1604646302153)(C:\Users\jhfan\AppData\Roaming\Typora\typora-user-images\image-20201105165027174.png)]

我们在看 ReentrantLock详细放的时候发现了这个,所以我们可以再看condition是如何实现等待和唤醒功能的。

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-xZ3XzM9S-1604646302157)(C:\Users\jhfan\AppData\Roaming\Typora\typora-user-images\image-20201105165426933.png)]

完美不但对功能进行了一个简单解析,而且还给予了一个例子模板,可以从中找出三个方法await(),signal().signalAll()。

其中await等待,可以设置时间,signal唤醒一个等待的线程,signalAll唤醒所有等待的线程。

现在我们就可以通过lock实现消费者和生产者

public class Test {public static void main(String[] args) {Data  data=new Data();new Thread(()->{for (int i=0;i<10;i++){data.decrement();}},"线程A").start();new Thread(()->{for(int i=0;i<10;i++) {data.increment();}} , "线程b").start() ;}
}class Data{private int num=0;Lock lock= new ReentrantLock();Condition notFull  = lock.newCondition(); Condition notEmpty = lock.newCondition(); public void increment(){lock.lock();try {while (num!=0) {notEmpty.await();} num++;System.out.println(Thread.currentThread().getName()+"现在是number="+num);notFull.signalAll();}catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();} finally {lock.unlock();} }public void decrement(){lock.lock();try {while (num==0) {notFull.await();} num--;System.out.println(Thread.currentThread().getName()+"现在是number="+num);notEmpty.signalAll();}catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();} finally {lock.unlock();} }
} 
//输出
线程b现在是number=1
线程A现在是number=0
线程b现在是number=1
线程A现在是number=0
线程b现在是number=1
线程A现在是number=0
线程b现在是number=1
线程A现在是number=0
线程b现在是number=1
线程A现在是number=0
线程b现在是number=1
线程A现在是number=0
线程b现在是number=1
线程A现在是number=0
线程b现在是number=1
线程A现在是number=0
线程b现在是number=1
线程A现在是number=0
线程b现在是number=1
线程A现在是number=0

可见输出可以完成用synchronized实现的消费者和生产者的例子。但是通过上面我们可以察觉一件事,那就是conditon,可以实现精确唤醒,比如increment中的condition等待的是notEmpty,而唤醒的时候使用的是notFull。

所以可以实现精确唤醒,具体看代码。

public class Test {public static void main(String[] args) {Step  step=new Step();new Thread(()->{for (int i = 0; i <10; i++) {step.step_first();}},"线程A").start();new Thread(()->{for (int i = 0; i <10; i++) {step.step_second();}},"线程b").start();new Thread(()->{for (int i = 0; i <10; i++) {step.step_thrid();}},"线程c").start();}}class Step{int num=1;Lock lock= new ReentrantLock();Condition step1  = lock.newCondition();Condition step2  = lock.newCondition();Condition step3  = lock.newCondition();public void step_first() {lock.lock();try {while(num!=1) {step1.await();}System.out.println(Thread.currentThread().getName());num=2;step2.signalAll();} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();} finally {lock.unlock();}}public void step_second() {lock.lock();try {while(num!=2) {step2.await();}System.out.println(Thread.currentThread().getName());num=3;step3.signalAll();} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();} finally {lock.unlock();}}public void step_thrid() {lock.lock();try {while(num!=3) {step3.await();}System.out.println(Thread.currentThread().getName());num=1;step1.signalAll();} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();} finally {lock.unlock();}}
}
//输出
线程A
线程b
线程c
线程A
线程b
线程c
线程A
线程b
线程c
线程A
线程b
线程c
线程A
线程b
线程c
线程A
线程b
线程c
//后面一样

可以看出同各国condition可以实现精准唤醒。a,b,c相互交替,这个可以实现比如购物支付这样的功能。

这篇关于Java基础 浅谈线程补充 -------lock实现消费者和生产者以及精确唤醒的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1073129

相关文章

Spring Security常见问题及解决方案

《SpringSecurity常见问题及解决方案》SpringSecurity是Spring生态的安全框架,提供认证、授权及攻击防护,支持JWT、OAuth2集成,适用于保护Spring应用,需配置... 目录Spring Security 简介Spring Security 核心概念1. ​Securit

Python实现终端清屏的几种方式详解

《Python实现终端清屏的几种方式详解》在使用Python进行终端交互式编程时,我们经常需要清空当前终端屏幕的内容,本文为大家整理了几种常见的实现方法,有需要的小伙伴可以参考下... 目录方法一:使用 `os` 模块调用系统命令方法二:使用 `subprocess` 模块执行命令方法三:打印多个换行符模拟

SpringBoot+EasyPOI轻松实现Excel和Word导出PDF

《SpringBoot+EasyPOI轻松实现Excel和Word导出PDF》在企业级开发中,将Excel和Word文档导出为PDF是常见需求,本文将结合​​EasyPOI和​​Aspose系列工具实... 目录一、环境准备与依赖配置1.1 方案选型1.2 依赖配置(商业库方案)二、Excel 导出 PDF

Python实现MQTT通信的示例代码

《Python实现MQTT通信的示例代码》本文主要介绍了Python实现MQTT通信的示例代码,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一... 目录1. 安装paho-mqtt库‌2. 搭建MQTT代理服务器(Broker)‌‌3. pytho

SpringBoot改造MCP服务器的详细说明(StreamableHTTP 类型)

《SpringBoot改造MCP服务器的详细说明(StreamableHTTP类型)》本文介绍了SpringBoot如何实现MCPStreamableHTTP服务器,并且使用CherryStudio... 目录SpringBoot改造MCP服务器(StreamableHTTP)1 项目说明2 使用说明2.1

spring中的@MapperScan注解属性解析

《spring中的@MapperScan注解属性解析》@MapperScan是Spring集成MyBatis时自动扫描Mapper接口的注解,简化配置并支持多数据源,通过属性控制扫描路径和过滤条件,利... 目录一、核心功能与作用二、注解属性解析三、底层实现原理四、使用场景与最佳实践五、注意事项与常见问题六

Spring的RedisTemplate的json反序列泛型丢失问题解决

《Spring的RedisTemplate的json反序列泛型丢失问题解决》本文主要介绍了SpringRedisTemplate中使用JSON序列化时泛型信息丢失的问题及其提出三种解决方案,可以根据性... 目录背景解决方案方案一方案二方案三总结背景在使用RedisTemplate操作redis时我们针对

Java中Arrays类和Collections类常用方法示例详解

《Java中Arrays类和Collections类常用方法示例详解》本文总结了Java中Arrays和Collections类的常用方法,涵盖数组填充、排序、搜索、复制、列表转换等操作,帮助开发者高... 目录Arrays.fill()相关用法Arrays.toString()Arrays.sort()A

Spring Boot Maven 插件如何构建可执行 JAR 的核心配置

《SpringBootMaven插件如何构建可执行JAR的核心配置》SpringBoot核心Maven插件,用于生成可执行JAR/WAR,内置服务器简化部署,支持热部署、多环境配置及依赖管理... 目录前言一、插件的核心功能与目标1.1 插件的定位1.2 插件的 Goals(目标)1.3 插件定位1.4 核

如何使用Lombok进行spring 注入

《如何使用Lombok进行spring注入》本文介绍如何用Lombok简化Spring注入,推荐优先使用setter注入,通过注解自动生成getter/setter及构造器,减少冗余代码,提升开发效... Lombok为了开发环境简化代码,好处不用多说。spring 注入方式为2种,构造器注入和setter