waitnotifytest.java

孙鑫JAVA从入门到精通配套练习程序。所有程序都实际运行过

//演示wait,notify方法使用
class WNTest
{
	public static void main(String[] args)
	{
		Queue q = new Queue();
		Producer p = new Producer(q);
		Consumer c = new Consumer(q);
		p.start();
		c.start();
		
	}
}

class Producer extends Thread
{
	Queue q;
	Producer(Queue q)
	{
		this.q = q;
	}
	public void run()
	{
		for(int i=0; i<10; i++)
		{
			q.put(i);
			System.out.println("Producer put " + i);
		}
	}
	
}

class Consumer extends Thread
{
	Queue q;
	Consumer(Queue q)
	{
		this.q = q;
	}
	public void run()
	{
		while(true)
		{
			System.out.println("Consumer get " + q.get());
		}
	}
}
class Queue
{
	int value;
	boolean bFull = false;
	public synchronized void put(int i)
	{
		if (!bFull)
		{
			value = i;
			notify();
			bFull = true;
		}
		try
		{
			wait();
		}
		catch(InterruptedException ex)
		{
			ex.printStackTrace();
		}
	}
	public synchronized int get()
	{
		if (!bFull)
		{
			try
			{
				wait();
			}
			catch(InterruptedException ex)
			{
				ex.printStackTrace();
			}
		}
		bFull = false;
		notify();
		return value;
	}
}