/*
需求:
使用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){}
}
}
}
我不知道你那里怎么回事 虽说逻辑可能有些问题 不过在我这着没有报错