mpcthread0.java

在学习Java的多线程时

/**
 *1.如果线程想调用对象的wait( )， notify( )，或notifyAll( )方法，
 *必须先"拥有"(得到)这个对象的锁。
 *
 *2.可以让另一个对象来操控这个对象的锁。要想这么做，第一步是先获取对象的锁。
 *比方说要想调用对象x的notify( )，可以在x的synchronized段里：
 *	synchronized(x) 
 *	{  
 *		x.notify();
 *	}
*/
class ShareData
{
	
	private String buff=null;
	
	private Object psyn=new Object();
	private Object csyn=new Object();
	
	public void addData(String str,String name)
	{
		//生产者将数据放入数据对象时，首先要判断是否有空
		//如果不空时，则要等待消费者将数据拿走
		synchronized(psyn)
		{
			while(buff!=null)
			{
		           try
		           {
		           	 psyn.wait();
		           }
		           catch(InterruptedException e)
		           {
		           	 e.printStackTrace();
		           }
		    }
		    //当空时，某一生产者将数据放入
		    buff=str;
		    System.out.println("线程"+name+"产生了");
		  }
		    //在此通知所有的消费者线程，告之数据已放入
		  synchronized(csyn)
		  {
		    csyn.notify();
		  }
    }
	public String removeData(String name)
	{
		String str=null;
		//消费者从数据对象中拿数据时，首先要判断是否有有数据
		//如果没有，则要等待生产者线程产生相应的数据
		synchronized(csyn)
		{	
			while(buff==null)
			{
	           try{
	           	 csyn.wait();
	           }
	           catch(InterruptedException e){
	           	 e.printStackTrace();
	           }
		    }
		    //当有数据时，则可拿走数据
		    str=buff;
		    buff=null;
		    System.out.println("线程"+name+"消费了");
		 }
		    //在此通知所有的生产者线程，告之数据已拿走了
		 synchronized(psyn)
		 {
		    psyn.notify();
		 }
	    return str;		
	}	
	
}

//生产者线程，其目的是不断的往队列中增加数据
class Procedure extends Thread{
	
	private ShareData buff;
	//在创建线程时，给出数据对象和线程自己的名称
	public Procedure(ShareData buff,String name){
		
		this.buff=buff;
		setName(name);
		start();
		
	}
	
	public void run(){
		int count=0;
		
		while(true){
			
			String str=new String("procedure is"+count++);
			
			String name=getName();
			//每个线程调用数据对象的方法时，都给出自己的名称
			buff.addData(str,name);
			
			try{
				Thread.sleep(2000);
			}
			catch(InterruptedException e){
				e.printStackTrace();
			}
			
		}
		
	}
}
//消费者线程，其目的是不断的从队列中取出数据	
class Consumer extends Thread{
	
	private ShareData buff;
	
	//在创建线程时，给出数据对象和线程自己的名称
	public Consumer(ShareData buff,String name){
		
		this.buff=buff;
		setName(name);
		start();
		
	}
	
	public void run(){
		
		while(true){
			
          String name=getName();
          //每个线程调用数据对象的方法时，都给出自己的名称
		  buff.removeData(name);
		}
		
	}
}

public class MPCThread0 extends Thread{

	public static void main(String args[]) throws InterruptedException
	{
		
		//注意构造对象的方式
		ShareData buff=new ShareData();
		
		Procedure p1=new Procedure(buff,"生产者1");
		Procedure p2=new Procedure(buff,"生产者2");
		Procedure p3=new Procedure(buff,"生产者3");
		Procedure p4=new Procedure(buff,"生产者4");
		
		Consumer c1=new Consumer(buff,"消费者1");
		Consumer c2=new Consumer(buff,"消费者2");
		Consumer c3=new Consumer(buff,"消费者3");
		Consumer c4=new Consumer(buff,"消费者4");
		
		p1.join();
		p2.join();
		p3.join();
		p4.join();
		
		c1.join();
		c2.join();
		c3.join();
		c4.join();
	}	
}