JAVA多线程通信

package com.frank.thread;/**    * author:pengyan     * date:Jun 16, 2011     * file:ProducerAndCustomerTest.java    */  public class ProducerAndCustomerTest {	public static void main(String[] args) {		//create an object 		Queue q=new Queue();		Productor p=new Productor(q);		Customer c=new Customer(q);		//p and c shared q		p.start();		c.start();	}}class Customer extends Thread{	Queue q;	public Customer(Queue q) {		this.q=q;	}	@Override	public void run() {		while (q.value<10) {//get the value			System.out.println("Customer get "+q.get());		}	}}class Productor extends Thread{	Queue q;	public Productor(Queue q) {		this.q=q;	}	@Override	public void run() {		for (int i = 1; i <=10; i++) {			q.put(i);//product and show info			System.out.println("Productor put "+i);		}	}}class Queue{	int value;//count the mumber	boolean bFull=false;//whether the cup is full	public synchronized void  put(int i){		if (!bFull) {			value=i;//fill the cup 			bFull=true;//it is full			notifyAll();//notify other thread			try {				wait();//wait.......			} catch (InterruptedException e) {				e.printStackTrace();			}		}	}	public synchronized int get(){		if (!bFull) {			try {				wait();//if not full,wait until full			} catch (InterruptedException e) {				e.printStackTrace();			}		}		bFull=false;//after got the cup is empty		notifyAll();//notify the Productor to put		return value;//return the value	}}

 

控制台打印：

Productor put 1

Customer get 1

Customer get 2

Productor put 2

Customer get 3

Productor put 3

Customer get 4

Productor put 4

Customer get 5

Productor put 5

Productor put 6

Customer get 6

Productor put 7

Customer get 7

Customer get 8

Productor put 8

Customer get 9

Productor put 9

Customer get 10

Productor put 10