threadtest.java

java线程学习时

import java.util.ArrayList;
import java.util.List;


public class ThreadTest {
	public static List<Integer> list = new ArrayList<Integer>();
	public static int i = 1;
	public static void main(String[] args) {
		
		Consumer ct = new Consumer();
		Product pt = new Product();
		pt.start();
		ct.start();
	}

}
class Product extends Thread{
	private List<Integer> list = ThreadTest.list;

	public synchronized void produceInt(){
		for(int i = 0 ; i< 10 ; i++){
			list.add(i);
			try {
				Thread.sleep(1000);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
			System.out.println("生产了一个产品"+i);
		}
	}
	public void run() {
		produceInt();
	}
	
}
class Consumer extends Thread{
	private List<Integer> list = ThreadTest.list;

	public synchronized void consumeInt(){
		for(int i = 0 ; i< 10; i++){
			if(list.size()!=0){
				System.out.print(list.size());
				System.out.println("消费了一个产品"+list.get(0));
				list.remove(0);
			}
				
		}
	}
	public void run() {
		consumeInt();
	}
	
}