/*
需求:
使用lock接口实现商品的生产和销售的动态平衡
思路:
1、创建被共同操作的数据类Resource,并通过多态引用分别创建lock和condition子类对象以及资源的获取和赋值方法
2、创建两个相反操作即生产和销售的类同时实现Runnable接口,并覆盖run方法
3、在主函数中,创建资源对象,并作为共同参数分别传递给生产和销售两个线程实现类的构造函数
4、分别将生产和销售类的对象作为参数,传给两个线程,并各自开启线程
/
package com.horse146;
import java.util.concurrent.locks.;
class ProducerConsumerDemo
{
public static void main(String[] args) //主函数
{
Resource r=new Resource();
Producer p=new Producer(r);
Consumer c=new Consumer(r);
Thread t1=new Thread(p);
Thread t2=new Thread(c);
t1.start();
t2.start();
}
}
class Resource //被共同操作的数据类
{
String name;
int id;
boolean flag;
Lock lock=new ReentrantLock();//创建锁对象
Condition pro=lock.newCondition();
//用上面创建的锁对象,调用其newCondition方法,创建Condition子类对象,实现对lock锁的等待唤醒操作
Condition con=lock.newCondition();
public void set(String name)throws InterruptedException{//创建赋值方法,并针对等待异常抛出
lock.lock();
try{
while(flag)
pro.await();//lock锁下面的Pro线程等待
this.name=name+"----"+id;
System.out.println(Thread.currentThread().getName()+"生产出"+this.name);
flag=true;
con.signal();//lock锁下面的con线程唤醒
}
finally{
lock.unlock();//解锁
}
}
public void get()throws InterruptedException{//创建取值方法,对针对等待异常抛出
lock.lock();
try{
while(!flag)
con.await();
System.out.println(Thread.currentThread().getName()+"消费了"+this.name);
flag=false;
pro.signal();//Pro线程唤醒
}
finally{
lock.unlock();
}
}
}
class Producer implements Runnable//生产者类实现Runnable接口
{
private Resource r;
Producer(Resource r){
this.r=r;
}
public void run(){
while(true){
try{r.set("商品");}
catch(InterruptedException e){}
}
}
}
class Consumer implements Runnable//消费者类实现Runnable接口
{
private Resource r;
Consumer(Resource r){
this.r=r;
}
public void run(){
while(true){
try{r.get();}
catch(InterruptedException e){}
}
}
}
Java中多线程同步锁报无效指针异常是何原因,求大神解答!
- 写回答
- 好问题 0 提建议
- 追加酬金
- 关注问题
- 邀请回答
-
1条回答 默认 最新
- qq_23660243 2015-08-25 03:34关注
我不知道你那里怎么回事 虽说逻辑可能有些问题 不过在我这着没有报错
本回答被题主选为最佳回答 , 对您是否有帮助呢?解决 无用评论 打赏 举报
悬赏问题
- ¥15 根据以下文字信息,做EA模型图
- ¥15 删除虚拟显示器驱动 删除所有 Xorg 配置文件 删除显示器缓存文件 重启系统 可是依旧无法退出虚拟显示器
- ¥15 vscode程序一直报同样的错,如何解决?
- ¥15 关于使用unity中遇到的问题
- ¥15 开放世界如何写线性关卡的用例(类似原神)
- ¥15 关于并联谐振电磁感应加热
- ¥60 请查询全国几个煤炭大省近十年的煤炭铁路及公路的货物周转量
- ¥15 请帮我看看我这道c语言题到底漏了哪种情况吧!
- ¥60 关机时蓝屏并显示KMODE_EXCEPTION_NOT_HANDLED,怎么修?
- ¥66 如何制作支付宝扫码跳转到发红包界面