synctest.java

接着上次传入一些Java学习中的实验

//this java is only the yield() of the all process.
package problem;
public class SyncTest{							//定义一个类。
	public static void main(String args[]) 
	 {
	 	Stack stack=new Stack("stack1");		//produce a class object.
	 	
	 	Producer producer1=new Producer (stack,"producer1"); //produce a class object.
	 	
	 	Consumer consumer1=new Consumer(stack,"consumer1"); //produce a class object.
	 	
	 }
}

class Producer extends Thread{								//extends a thread class use for Producer
	private Stack theStack;									//a class Stack object.
	public  Producer(Stack s,String name){					//a strator for the class
		super(name);
		theStack=s;
		start();
	}
	

public void run(){											
	String goods;
	for(int i=0;i<200;i++)
	 {
	 	goods="goods "+(theStack.getPoint()+1);
	 	theStack.push(goods);
	 	System.out.println(getName()+":push "+goods+"  to: "+theStack.getName());
	 	yield();		
	 	
	 }
  }
}
class Consumer extends Thread{
	 private Stack theStack;
	 public Consumer(Stack s ,String name){
	 	super(name);
	 	theStack=s;
	 	start();
	 	
	 }
	 public void run(){
   		String goods;
   		for(int i=0;i<200;i++){
   		
   		 goods=theStack.pop();
   		 System.out.println(getName()+":pop "+goods+" from: "+theStack.getName());
   		 yield();
   		 }
   	}
}
class Stack{
	private String name;
	private String[] buffer=new String[100];
	
	int point=1;
	public Stack(String name){this.name=name;}
	public String getName(){return name;}
	
	public int getPoint(){return point;}
	
	
	
	public String pop(){
	synchronized(this){	String goods =buffer[point];
		buffer[point]=null;
		Thread.yield();
		point--;
		return goods;
	}
	}
	public void push(String goods)
	 {
	 	point++;
	 	Thread.yield();
	 	buffer[point]=goods;
	 }
	
	
	}