生产者与消费者多线程实现，首先的问题就是同步，就是关于临界资源的访问
我们首先来定义一个临界资源类，这里设为Q
class Q
{ int z=4;
}
这个int型的z就是我假设的临界资源的个数
然后是生产者的put动作
synchronized void put()
{
if(z>0)//当临界资源的个数大于0时，生产者等待wait，否则，生产者进行生产，生产之后唤醒notifyAll()挂起的消费者
{
try{wait();}catch(Exception e){}
}
else
{
System.out.print(Thread.currentThread()+" ");
System.out.println(++z);
try{notifyAll();}catch(Exception e){}
}
}
然后是消费者进行消费的过程get
synchronized void get()
{
if(z<=0)//当临界资源的个数等于或者小于0时，消费者进程等待
{
try{wait();}catch(Exception e){}
}
else
{
System.out.print(Thread.currentThread().getName()+" ");
System.out.println(z--);
if(z==0)//当一个消费者消费完之后检查了一下临界资源，发现资源为0，那么唤醒生产者来进行生产
{
notify();
}
}
}
然后是生产者和消费者类的定义
这里的生产者和消费者都是Thread类的子类，故都要完成run方法，这里run方法一般为无限循环
class producer extends Thread
{
Q q;
public producer(Q q)
{
this.q=q;
}
public void run()
{
while(true)
{
q.put();
}
}
}
class consumer extends Thread
{
Q q;
public consumer(Q q)
{
this.q=q;
}
public void run()
{
while(true)
{
q.get();
}
}
}
这里需要注意，因为只能生产一个临界资源对象，这里我们放在主函数里面，所以，需要构造生产者和消费者的构造函数，并将临界资源作为参数传递进来，进行put与get操作
整个函数定义如下：
public class a
{
public static void main(String[]args)
{ Q q=new Q();
Thread t1,t2,t3;
t1=new producer(q);
t2=new consumer(q);
t3=new consumer(q);
t1.start();
t2.start();
t3.start();
}
}
class Q
{
int z=4;
synchronized void put()
{
if(z>0)
{
try{wait();}catch(Exception e){}
}
else
{
System.out.print(Thread.currentThread()+" ");
System.out.println(++z);
try{notifyAll();}catch(Exception e){}
}
}
synchronized void get()
{
if(z<=0)
{
try{wait();}catch(Exception e){}
}
else
{
System.out.print(Thread.currentThread().getName()+" ");
System.out.println(z--);
if(z==0)
{
notify();
}
}
}
}
class producer extends Thread
{
Q q;
public producer(Q q)
{
this.q=q;
}
public void run()
{
while(true)
{
q.put();
}
}
}
class consumer extends Thread
{
Q q;
public consumer(Q q)
{
this.q=q;
}
public void run()
{
while(true)
{
q.get();
}
}
}