Java Lock锁多线程中实现流水线任务
作者:DescribeMe 发布时间:2023-08-09 17:44:02
标签:Java,Lock,锁,多线程
下面程序代码通过使用Lock锁执行简单的流水线任务:
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
/**
* @author lzq
* @data 2020/4/29 0029 - 下午 9:48
*/
public class TestLock {
public static void main(String[] args) {
DataSource dataSource=new DataSource();
new Thread(() -> {
for (int i=0;i<10;i++){
dataSource.a();
}
},"A").start();
new Thread(() -> {
for (int i=0;i<10;i++){
dataSource.b();
}
},"B").start();
new Thread(() -> {
for (int i=0;i<10;i++){
dataSource.c();
}
},"C").start();
}
}
class DataSource{
private int x=1;
private Lock lock=new ReentrantLock();
private Condition condition1=lock.newCondition();
private Condition condition2=lock.newCondition();
private Condition condition3=lock.newCondition();
public void a(){
lock.lock();
try {
while(x!=1){
condition1.await();
}
System.out.println(Thread.currentThread().getName()+":aaa");
x=2;
condition2.signal();
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
public void b(){
lock.lock();
try {
while(x!=2){
condition2.await();
}
System.out.println(Thread.currentThread().getName()+":bbb");
x=3;
condition3.signal();
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
public void c(){
lock.lock();
try {
while(x!=3){
condition3.await();
}
System.out.println(Thread.currentThread().getName()+":ccc");
x=1;
condition1.signal();
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
}
执行结果如下:
对于上面代码简单分析:代码中包含简单的生产者消费者流程和Lock实现三部曲,即重复判断条件,执行逻辑,唤醒其他线程和产生锁,加锁,解锁。注意这里一点,条件判断一定要重复判断,不然可能会导致线程假醒影响结果。
因为当线程处于等待状态时,线程会释放资源,等到被唤醒的时候,从上次await的地方醒来继续执行,这时条件判断成立,执行await,其他线程再修改条件使得本线程被唤醒,此时本线程不会继续判断,而是继续执行,如果使用循环判断就能检验出条件被修改。
来源:https://www.cnblogs.com/darkfire/p/12805249.html
0
投稿
猜你喜欢
- 一、概述:System.Collections.Concurrent 命名空间提供多个线程安全集合类。当有多个线程并发访问集合时,应使用这些
- 在APP项目的开发过程中,经常会用到分享图片的功能,有时候还需要根据当前用户信息获取指定的分享图片,比如要求在用户分享图中显示用户名、Uid
- 集成使用1、添加 gradle 依赖implementation "com.ctrip.framework.apollo:apol
- java中的复杂查询sql语句实现:这样的查询栏,在页面中很常见,这就是复杂查询的条件,我们可以填写一个条件或多个条件,也可以一个都不填写,
- 上篇文章给大家介绍了springboot对接第三方微信授权及获取用户的头像和昵称等等1 账户注销1.1 在SecurityConfig中加入
- 本文实例讲述了Java date format时间格式化操作。分享给大家供大家参考,具体如下:import java.util.Date;i
- 在传统的同步开发模式下,当我们调用一个函数时,通过这个函数的参数将数据传入,并通过这个函数的返回值来返回最终的计算结果。但在多线程的异步开发
- 前言Jetpack Compose(简称 Compose )是 Google 官方推出的基于 Kotlin 语言的 Android 新一代
- 一直以为这个方法是java8的,今天才知道是是1.7的时候,然后翻了一下源码。这片文章中会总结一下与a.equals(b)的区别,然后对源码
- 0x00:前言参考之前的《MyBatis 中 SqlMapConfig 配置文件详解》记了一下 MyBatis 中的核心配置文件各个标签的作
- 本文实例讲述了Java基于正则实现的日期校验功能。分享给大家供大家参考,具体如下:private void checkDate() thro
- Sentinel数据双向同步上面实现了Nacos单向同步配置规则到Sentinel,但是只是单向的,没有实现Sentinel向Nacos同步
- 目录1.下面有关JSP内置对象的描述,说法错误的是?2.Java语言与其它语言相比,独有的特点是( )3.下面哪个选项正确创建socket连
- 本文实例讲述了Java之JFrame输出Helloworld的方法。分享给大家供大家参考。具体如下:JAVA的GUI程序的基本思路是以JFr
- 1、spring 框架解决字符串编码问题:过滤器 CharacterEncodingFilter(filter-name)2、在web.xm
- 本文实例讲述了C#把数组中的某个元素取出来放到第一个位置的实现方法。分享给大家供大家参考。具体分析如下:如何取出数组中符合某种条件的元素,然
- 同线程回收对象上一小节剖析了从recycler中获取一个对象, 这一小节分析在创建和回收是同线程的前提下, recycler是如何进行回收的
- 在logback.xml中加上该配置,包名如:com.xxx<logger name="packageName"
- WebServiceHelper代码:using Microsoft.CSharp;using System;using System.Co
- 前言:学习过我的mall项目的应该知道,mall-admin模块是使用SpringSecurity+JWT来实现登录认证的,而mall-po