JAVA多线程通信
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 qp.start();c.start();}}class Customer extends Thread{Queue q;public Customer(Queue q) {this.q=q;}@Overridepublic void run() {while (q.value<10) {//get the valueSystem.out.println("Customer get "+q.get());}}}class Productor extends Thread{Queue q;public Productor(Queue q) {this.q=q;}@Overridepublic void run() {for (int i = 1; i <=10; i++) {q.put(i);//product and show infoSystem.out.println("Productor put "+i);}}}class Queue{int value;//count the mumberboolean bFull=false;//whether the cup is fullpublic synchronized void put(int i){if (!bFull) {value=i;//fill the cup bFull=true;//it is fullnotifyAll();//notify other threadtry {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 emptynotifyAll();//notify the Productor to putreturn 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