package com.test3;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
/**
* 线程通信例子(基于可重入锁ReentrantLock,一对Condition实现)
* */
public class PC2 {
/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
Q2 q = new Q2();
new Producer2(q);
new Customer2(q);
}
}
/**
* 阻塞队列
* */
class Q2{
int n;
final Lock lock = new ReentrantLock();
//说明:canGet和canPut可以合并成一个
final Condition canGet = lock.newCondition();
final Condition canPut = lock.newCondition();
boolean valueSet = false;
int get(){
//实现可响应中断的锁
try {
lock.lockInterruptibly();
//值未设置好,循环等待
while(!valueSet){
canGet.await();
}
//取值成功
System.out.println("Got:"+n);
//将设置标志置为false
valueSet = false;
Thread.currentThread().sleep(1000);
//通知设值线程
canPut.signal();
return n;
} catch (InterruptedException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}finally{
lock.unlock();
}
return 0;
}
void put(int n){
try {
//实现可响应中断的锁
lock.lockInterruptibly();
//已经设置好了值,而且未被取走,循环等待
while(valueSet){
canPut.await();
}
this.n = n;
//将设置标志设置为true
valueSet = true;
System.out.println("Put:"+n);
Thread.currentThread().sleep(1000);
//通知取值线程,可以取值
canGet.signal();//相当于notify() ,signalAll()相当于notifyAL
} catch (InterruptedException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
}
}
/**
* 生产者
* */
class Producer2 implements Runnable{
Q2 q;
public Producer2(Q2 q){
this.q = q;
new Thread(this,"Producer").start();
}
@Override
public void run() {
// TODO Auto-generated method stub
int i=0;
while(true){
q.put(i++);
}
}
}
/**
* 消费者
* */
class Customer2 implements Runnable{
Q2 q;
public Customer2(Q2 q){
this.q=q;
new Thread(this,"Customer").start();
}
@Override
public void run() {
// TODO Auto-generated method stub
while(true){
q.get();
}
}
}
分享到:
相关推荐
1、ReentrantLock简介 2、ReentrantLock函数列表 3、重入的实现 4、公平锁与非公平锁 5、ReentrantLock 扩展的功能 6
主要介绍了Java多线程中ReentrantLock与Condition详解,需要的朋友可以参考下
ReentrantLock类可以唤醒指定条件的线程,而object的唤醒是随机的 Condition类和Object类 Condition类的awiat方法和Object类的wait方法等效 Condition类的signal方法和Object类的notify方法等效 Condition类...
多线程编程的核心思想 多线程编程的核心思想是指在多线程环境下如何实现线程安全、...多线程编程的核心思想是通过 Lock 和 Condition 接口来实现线程安全和同步机制,并使用 AQS 底层实现来实现锁和 Condition 接口。
【2018最新最详细】并发多线程教程,课程结构如下 1.并发编程的优缺点 2.线程的状态转换以及基本操作 3.java内存模型以及happens-before规则 4.彻底理解synchronized 5.彻底理解volatile 6.你以为你真的了解final吗...
避免多线程死锁的方法。 尝试非阻塞地获取锁:tryLock(),调用方法后立刻返回; 能被中断地获取锁:lockInterruptibly():在锁的获取中可以中断当前线程 超时获取锁:tryLock(time,unit),超时返回 Condition 类和 ...
Lock 接口概述: 简要介绍 Lock 接口,解释其在多线程编程中的作用和优势。比较 Lock 接口与传统 synchronized 关键字的不同之处。 常用 Lock 接口实现类: 详细讲解 Lock 接口的一些常用实现类,如 ReentrantLock、...
1、本资源包含并发编程基础知识的使用案例,包括:线程创建、Synchronized和Reentrantlock锁的使用、线程安全问题演示、Condition的应用、CountDownLatch的应用、Cyclicbarrier的应用、Semaphore的应用、线程池的...
Lock锁,一种线程同步机制,其主要功能是防止多个线程同时访问同一代码块,从而避免因并发问题引发的数据不一致或其他错误。...总的来说,Lock锁是Java多线程编程中的重要工具,能够有效保障程序运行的正确性和稳定性。
threading.Condition默认情况下会通过持有一个ReentrantLock来协调线程之间的工作,所谓可重入锁,是只一个可以由一个线程递归获取的锁,此锁对象会维护当前锁的所有者(线程)和当前所有者递归获取锁的次数(本文在...
高并发编程第三阶段30讲 使用Condition实现一个多线程下的Producer-Consumer_.mp4 高并发编程第三阶段31讲 JDK8-StampedLock详细介绍-上_.mp4 高并发编程第三阶段32讲 JDK8-StampedLock详细介绍-下.mp4 高...
高并发编程第三阶段30讲 使用Condition实现一个多线程下的Producer-Consumer_.mp4 高并发编程第三阶段31讲 JDK8-StampedLock详细介绍-上_.mp4 高并发编程第三阶段32讲 JDK8-StampedLock详细介绍-下.mp4 高...
书中从并发性和线程安全性的基本概念出发,介绍了如何使用类库提供的基本并发构建块,用于避免并发危险、构造线程安全的类及验证线程安全的规则,如何将小的线程安全类组合成更大的线程安全类,如何利用线程来提高...
25 3:ServicorTo 和 ServicorFrom 互换................................................................................................................25 2.3.3.1. 2.4.1. 如何确定垃圾 ......................
25 3:ServicorTo 和 ServicorFrom 互换................................................................................................................25 2.3.3.1. 2.4.1. 如何确定垃圾 ......................