common.java

来自「运用JSP+tomcat及各种数据库编辑的一些较常用的应用程序」· Java 代码 · 共 86 行

package com.test;

public class common
{
	private char ch;
	private boolean available = false;

	synchronized char get()
	{
		while(available==false)
		{
			try
			{
				wait();
			}catch(InterruptedException e){}
			available = false;
			notify();
			return ch;
		}
		return ch;
	}

	synchronized void put(char newch)
	{
		while(available==true)
		{
			try
			{
				wait();
			}catch(InterruptedException e){}
			ch = newch;
			available = true;
			notify();
		}
	}

	//生产者线程
	static class producer extends Thread
	{
		private common comm;

		public producer(common thiscomm)
		{
			comm = thiscomm;
		}

		public void run()
		{
			for(char c='a';c<='e';c++)
			{
				System.out.println("生产的数据是："+c);
				comm.put(c);
			}
		}
	};

	//消费者线程
	static class consumer extends Thread
	{
		private common comm;

		public consumer(common thiscomm)
		{
			comm = thiscomm;
		}

		public void run()
		{
			char c;
			for(int i=0;i<5;i++)
			{
				c = comm.get();
				System.out.println("消费者得到的数据是："+c);
			}
		}
	};

	public static void main(String arg[])
	{
		common comm = new common();
		producer p = new producer(comm);
		consumer s = new consumer(comm);
		p.start();
		s.start();
	}
};