public Consumer(Resource resource) {
this.resource = resource;
}
@Override
public void run() {
while (true) {
try {
Thread.sleep(500);
} catch (InterruptedException e) {
e.printStackTrace();
}
//调用消费方法
resource.get();
}
}
}
Lock实现生产消费实现生产消费
public class LockPC {
public static void main(String[] args) {
Resource resource = new Resource();
Producer producer = new Producer(resource);
Consumer consumer = new Consumer(resource);
ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(4, 4, 0, TimeUnit.SECONDS, new LinkedBlockingQueue(),
Executors.defaultThreadFactory(), new ThreadPoolExecutor.AbortPolicy());
threadPoolExecutor.execute(producer);
threadPoolExecutor.execute(consumer);
threadPoolExecutor.execute(producer);
threadPoolExecutor.execute(consumer);
threadPoolExecutor.shutdown();
}
/**
* 产品资源
*/
static class Resource {
private String name;
private int count;
boolean flag;
//获取lock锁,lock锁的获取和释放需要代码手动操作
ReentrantLock lock = new ReentrantLock();
//从lock锁获取一个condition,用于生产者线程在此等待和唤醒
Condition producer = lock.newCondition();
//从lock锁获取一个condition,用于消费者线程在此等待和唤醒
Condition consumer = lock.newCondition();
void set(String name) {
//获得锁
lock.lock();
try {
while (flag) {
try {
System.out.println("有产品了--" + Thread.currentThread().getName() + "生产等待");
//该生产者线程,在producer上等待
producer.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
++count;
this.name = name;
System.out.println(Thread.currentThread().getName() + "生产了" + this.name + +count);
flag = !flag;
//唤醒在consumer上等待的消费者线程,这样不会唤醒等待的生产者
consumer.signalAll();
} finally {
//释放锁
lock.unlock();
}
剩余10页未读，继续阅读
weixin_38747444
- 粉丝: 9
- 资源: 912
我的内容管理
展开
最新资源
- 十种常见电感线圈电感量计算公式详解
- 军用车辆：CAN总线的集成与优势
- CAN总线在汽车智能换档系统中的作用与实现
- CAN总线数据超载问题及解决策略
- 汽车车身系统CAN总线设计与应用
- SAP企业需求深度剖析：财务会计与供应链的关键流程与改进策略
- CAN总线在发动机电控系统中的通信设计实践
- Spring与iBATIS整合：快速开发与比较分析
- CAN总线驱动的整车管理系统硬件设计详解
- CAN总线通讯智能节点设计与实现
- DSP实现电动汽车CAN总线通讯技术
- CAN协议网关设计：自动位速率检测与互连
- Xcode免证书调试iPad程序开发指南
- 分布式数据库查询优化算法探讨
- Win7安装VC++6.0完全指南：解决兼容性与Office冲突
- MFC实现学生信息管理系统：登录与数据库操作
资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！
点击此处反馈
