多生产者消费者同步代码 - 黑马程序员技术交流社区

public class PCRDemo{
public static void main(String [] args){
Producer p = new Producer();
Customer c = new Customer();
Thread t1 = new Thread(p);
Thread t2 = new Thread(p);
Thread t3 = new Thread(p);
Thread t4 = new Thread(c);
Thread t5 = new Thread(c);
Thread t6 = new Thread(c);
t1.start();
t2.start();
t3.start();
t4.start();
t5.start();
t6.start();
}
}
class Resource{
private static Resource resource = null;
public boolean empty = true ;
public boolean full = false ;
private String resName = "res";
public int count = 0;
private Resource(){}
public static Resource getInstance(){
if(resource == null){
synchronized(Resource.class){
if(resource == null)
resource = new Resource();
}
}
return resource;
}
public synchronized void produce(){
while (full){
try{
this.wait();
}
catch(Exception e){
throw new RuntimeException("It is full!");
}
}
count ++;
String name = resName+"-"+ count;
System.out.println(Thread.currentThread().getName()+": Produce "+name+" It has "+count+"Resources ");
empty = false;
if(count>=20){
full = true;
}
notifyAll();
try{
Thread.sleep(60);
}
catch(Exception e){
}
}
public synchronized void consume(){
while (empty){
try{
this.wait();
}
catch(Exception e){
}
}
String name = resName+"-"+ count;
count --;
System.out.println(Thread.currentThread().getName()+": Consume "+name+" It has "+count+"Resources ");
full = false;
if(count <= 0){
empty=true;
}
notifyAll();
try{
Thread.sleep(10);
}
catch(Exception e){
}
}
}
class Producer implements Runnable{
private Resource resource = Resource.getInstance();
public void run(){
while (true)
resource.produce();
}
}
class Customer implements Runnable{
private Resource resource = Resource.getInstance();
public void run(){
while (true)
resource.consume();
}
}

复制代码