Java并发案例04---生产者消费者问题03--使用ReentrantLock
2024-08-31 04:31:45
/**
* 面试题：写一个固定容量同步容器，拥有put和get方法，以及getCount方法，
* 能够支持2个生产者线程以及10个消费者线程的阻塞调用
*
* 使用wait和notify/notifyAll来实现
*
* 使用Lock和Condition来实现
* 对比两种方式，Condition的方式可以更加精确的指定哪些线程被唤醒
*
* @author maple
*/
//同步互斥，等待队列， 基于AQS
package yxxy.c_021;
import java.util.LinkedList;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class MyContainer2<T> {
final private LinkedList<T> lists = new LinkedList<>();
final private int MAX = 10; //最多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) { //想想为什么用while而不是用if？
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) {
MyContainer2<String> c = new MyContainer2<>();
//启动消费者线程
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);
}, "p" + i).start();
}
}
}
最新文章
- orcle函数
- async & await 的前世今生
- DOS命令(可查看本机IP地址各个网卡号)
- redis（一） 安装以及基本数据类型操作
- 「轉」Java的内存机制
- 搭建andiord sdk和安装eclipse adt插件的个人小体会
- JSP-05- JSP总结
- $this->success('注册成功！');
- HDU 3501 Calculation 2
- 【java提高】---数组增删 list删除 map删除
- netcore编程之后面对不习惯的xshell黑屏部署，是时候使用jenkins自动化发布工具了
- 禁止root登陆sshd/并修改默认端口号
- Python常用字符编码（转）
- urllib的实现---cookie处理
- node爬虫扒小说
- hadoop 学习笔记
- Linux 系统管理命令
- Web 自动化测试框架 sweetest 介绍
- ln: operation not permitted
- Mysql命令drop database：删除数据库