引言

使用Condition实现生产者-消费者模型，并与wait和notify实现的效果相对比。

wait/notify模拟生产者-消费者

面试题：写一个固定容量同步容器，拥有put和get方法，以及getCount方法能够支持2个生产线程以及10个消费者线程的阻塞调用。

在《Effective Java》一书中提到：wait()方法（）绝大多数情况下都是和while一起使用的。这是因为，当wait()执行完成后，会立刻释放当前锁，如果这时其他线程立刻获得锁并对变量进行操作，会出现数据不一致的情况，使用while可以确保数据不会出现不一致的情况。

public class ProducerConsumer1<T> {final private LinkedList<T> lists = new LinkedList<>();final private int MAX = 10;// 最多10个元素private int count = 0;public synchronized void put(T t) {while (lists.size() == this.MAX) {// 想想为什么用while而不是iftry {this.wait();} catch (InterruptedException e) {e.printStackTrace();}}lists.add(t);count++;this.notifyAll();// 通知消费者线程进行消费}public synchronized T get() {T t = null;while (lists.size() == 0) {try {this.wait();} catch (InterruptedException e) {e.printStackTrace();}}t = lists.removeFirst();count--;this.notifyAll();// 通知生产者进行生产return t;}public static void main(String[] args) {ProducerConsumer1<String> c = new ProducerConsumer1<>();// 启动消费者线程for (int i = 0; i < 10; i++) {new Thread(() -> {for (int j = 0; j < 5; j++) {System.out.println(c.get());}}, "c" + i).start();}try {TimeUnit.SECONDS.sleep(2);} catch (InterruptedException e) {e.printStackTrace();}for (int i = 0; i < 2; i++) {new Thread(() -> {for (int j = 0; j < 25; j++) {c.put(Thread.currentThread().getName() + " " + j);}}).start();}}
}

Condition模拟生产者-消费者

使用Lock和Condition来实现类似需求时，可以更加精确的指定哪些线程被唤醒，这比notifyAll()效率更高一些。

将上面的程序代码进行改写：

public class ProducerConsumer2<T> {final private LinkedList<T> lists = new LinkedList<>();final private int MAX = 10;private int count = 0;private Lock lock = new ReentrantLock();private Condition producer = lock.newCondition();private Condition consumer = lock.newCondition();public void put(T t) {try {lock.lock();while (lists.size() == MAX) {producer.await();}lists.add(t);++count;consumer.signalAll(); // 通知消费者线程进行消费} catch (InterruptedException e) {e.printStackTrace();} finally {lock.unlock();}}public T get() {T t = null;try {lock.lock();while (lists.size() == 0) {consumer.await();}t = lists.removeFirst();count--;producer.signalAll();// 通知生产者进行生产} catch (InterruptedException e) {e.printStackTrace();} finally {lock.unlock();}return t;}public static void main(String[] args) {ProducerConsumer2<String> c = new ProducerConsumer2<>();// 启动消费者线程for (int i = 0; i < 10; i++) {new Thread(() -> {for (int j = 0; j < 5; j++) {System.out.println(c.get());}}, "c" + i).start();}try {TimeUnit.SECONDS.sleep(2);} catch (InterruptedException e) {e.printStackTrace();}for (int i = 0; i < 2; i++) {new Thread(() -> {for (int j = 0; j < 25; j++) {c.put(Thread.currentThread().getName()+ " " + j);}}).start();}}
}

鸣谢

《马士兵老师高并发编程系列》

Java 多线程 —— AQS 原理相关推荐

Java多线程 - AQS详解
介绍 AQS是java.util.concurrent.locks下类AbstractQueuedSynchronizer的简称,是用于通过Java源码来构建多线程的锁和同步器的一系列框架,用于Ja ...
面试突然问Java多线程底层原理，我哭了！
兄弟们,不要踩坑啊,我原本打算在金九银十之前换份工作,结果出去第一面就被干懵了! 面试官上来就问我了解不了解多线程,我感觉我还可以,我就和他说:必须的! 不过,他直接问了多线程的底层原理,这我都是一知 ...
Java 多线程 —— AQS 详解
引言 AQS 是AbstractQuenedSynchronizer 的缩写,抽象的队列式同步器,它是除了java自带的synchronized关键字之外的锁机制.是 JUC 下的重要组件. 相关产物 ...
字节跳动学习笔记：java多线程实现原理
01 Mysql 1. 数据库三范式及判断.E-R图 2. innodb和myisam存储引擎的区别 3. 索引分类(主键.唯一索引.全文索引.覆盖索引等等),最左前缀原则,哪些条件无法使用索引 4. ...
java多线程aqs实现工具类_Java并发多线程 - 并发工具类JUC
(adsbygoogle = window.adsbygoogle || []).push({}); 安全共享对象策略 1.线程限制 : 一个被线程限制的对象,由线程独占,并且只能被占有它的线程修改 ...
java resume过时方法_学点开发|关于Java多线程用法解析
在进行学习之前,我们先来了解下,什么是Java多线程: 多线程是实现并发机制的一种有效手段.进程和线程一样,都是实现并发的一个基本单位.为了让大家更清晰读懂关于Java多线程用法,由以下几点入手学,帮 ...
7个连环问揭开java多线程背后的弯弯绕
摘要:很多java入门新人一想到java多线程, 就会觉得很晕很绕,什么可见不可见的,也不了解为什么sync怎么就锁住了代码. 本文分享自华为云社区<java多线程背后的弯弯绕绕到底是什么? 7 ...
[遇见时光]Java多线程
原博:http://www.codeceo.com/article/java-mult-thread.html,本博文加入自己的理解.更详细参考http://blog.csdn.net/evankak ...
Java多线程系列(十)：源码剖析AQS的实现原理
在并发编程领域,AQS号称是并发同步组件的基石,很多并发同步组件都是基于AQS实现,所以想掌握好高并发编程,你需要掌握好AQS. 本篇主要通过对AQS的实现原理.数据模型.资源共享方式.获取锁的过程, ...

Java 多线程 —— AQS 原理

引言

wait/notify模拟生产者-消费者

Condition模拟生产者-消费者

鸣谢

Java 多线程 —— AQS 原理相关推荐

最新文章

热门文章