public class ThreadDemo extends Thread{
	
	

	/**
	 * 繼承Thread
	 * 
	 * @author gavin
	 *
	 */
	
	@Override
	public void run() {
		// TODO 自動生成的方法存根
		//打印10次世界
			try {
				for(int i=0;i<10;i++) {
					System.out.print("世界");
					Thread.sleep(200);//阻塞態(tài) 休息200毫秒
				}		
		} catch (InterruptedException e) {
			// TODO 自動生成的 catch 塊
			e.printStackTrace();
		}
		System.out.println("線程執(zhí)行完成！");				
	}
	
	
	public static void main(String[] args) {
		
		//初始化線程t1 t2
		ThreadDemo t1 = new ThreadDemo();
		ThreadDemo t2 = new ThreadDemo();
		//啟動線程
		t1.start();
		t2.start();
		//注意不是調(diào)用run方法 而是啟動線程 調(diào)用run方法只是執(zhí)行了run方法但不是多線程執(zhí)行
		
		//打印200次你好
		for(int i = 0;i<20;i++) {
			System.out.print("你好");
			try {
				Thread.sleep(200);
			} catch (InterruptedException e) {
				// TODO 自動生成的 catch 塊
				e.printStackTrace();
			}
		}
		
		//結(jié)束態(tài)
		System.out.println("程序運行完成");
		
		
		
		
	}
	
	
	
	

}

/**
 * 實現(xiàn)二： 實現(xiàn)Runnable接口
 * 當類本身有父類的時候 使用實現(xiàn)Runnable接口
 * @author gavin
 *
 */
public class RunnableDemo implements Runnable {

	@Override
	public void run() {
		// TODO 自動生成的方法存根
		//打印10次世界
		try {
			for(int i=0;i<10;i++) {
				System.out.print(Thread.currentThread().getName()+"世界\t");
				if(i%3==0) {
					System.out.println();
				}
				Thread.sleep(200);//阻塞態(tài) 休息200毫秒
			}		
	} catch (InterruptedException e) {
		// TODO 自動生成的 catch 塊
		e.printStackTrace();
	}
	System.out.println(Thread.currentThread().getName()+"線程執(zhí)行完成！");			
		
	}
	
	public static void main(String[] args) {
		
		//實列化當前類 
		RunnableDemo runnableDemo1 = new RunnableDemo();
		
		//創(chuàng)建線程 傳入任務(wù)類
		Thread t1 = new Thread(runnableDemo1);
		Thread t2 = new Thread(runnableDemo1);
		Thread t3 = new Thread(runnableDemo1);
			
		//設(shè)置線程優(yōu)先級
		t1.setPriority(Thread.MAX_PRIORITY);//最高優(yōu)先級
		t2.setPriority(Thread.MIN_PRIORITY);//最低優(yōu)先級
		t3.setPriority(5);//設(shè)置默認優(yōu)先級 優(yōu)先級為5 優(yōu)先級從0-10最高為10
		
		//啟動線程
		t1.start();
		t2.start();
		t3.start();
		
		
	}	

}

synchronized(object){
}

public synchronized void method() {
// do something
}

import java.util.LinkedList;

public class Store {
	
	
	/*
	 * 存儲 隊列實現(xiàn) 
	 * 
	 * @author gavin
	 * */
	
	//創(chuàng)建隊列
	LinkedList<Integer> list = new LinkedList<Integer>();
	
	//設(shè)置最大存儲值
	int max = 10;
	
	//生產(chǎn)者生產(chǎn) 放入隊尾
	public void push(int n) {
		
		synchronized(list) {
			try {
				if(list.size()>=max){
						System.out.println("存滿了");				
					    //線程掛起	
						list.wait();
					}else {
						//隊列沒有存滿 繼續(xù)存
						System.out.println("存入："+n);
						list.add(n);
						//放完之后必須有 因此喚醒取的線程  
						list.notifyAll();					
					}
				
				
			}catch (Exception e) {
					// TODO 自動生成的 catch 塊
					e.printStackTrace();
				}				
		}
		
		
	}
	
	
	//消費者消費 從隊頭取出
	public int pop() {
		try {
			synchronized(list){
				if(list.size()<=0) {
					System.out.println("隊列空了。。。。");
					//空了之后就不能取了 因此線程掛起
					list.wait();
				}else {
					//從對頭取出
					int n = list.poll();
					System.out.println("取出:"+n);
					//取出了就一定不會滿 因此要喚醒線程
					list.notifyAll();
					return n;
					
				}								
			}
						
		}catch (Exception e) {
			// TODO: handle exception
		}	
		
		return 0;
	}
	
	
	
	
	
	
	
	
	

}

/**
 * 生產(chǎn)者
 */

public class Producer  implements Runnable{

	private Store store;
	
	public Producer(Store store) {
		// TODO 自動生成的構(gòu)造函數(shù)存根
		this.store = store;
	}
	
	
	@Override
	public void run() {
		// TODO 自動生成的方法存根
		try {
			//生產(chǎn)需要事件 休息100毫秒再生產(chǎn)
			Thread.sleep(100);
			//產(chǎn)生隨機數(shù)字
			store.push((int)(Math.random()*100));
		}catch (Exception e) {
			// TODO: handle exception
			
		}
		
			
	}
	

}

public class Customer implements Runnable{

	
	private Store store;
	
	public Customer(Store store) {
		// TODO 自動生成的構(gòu)造函數(shù)存根
		this.store = store;
	}
	
	

	@Override
	public void run() {
		// TODO 自動生成的方法存根
		try {
			//消費者消費需要時間 休息200毫秒
			Thread.sleep(200);
			//從隊頭取出
			store.pop();
		}catch (Exception e) {
			// TODO: handle exception
		}
	}

}

package com.qingsu.pcm;

public class TestPcm {

	public static void main(String[] args) {
		Store store = new Store();
		
		while(true) {
			Producer producer = new Producer(store);
			Customer customer = new Customer(store);
			
			Thread t1 = new Thread(producer);
			Thread t2 = new Thread(customer);
			
			t1.start();
			t2.start();
			
		}
		
	}
	
	
}

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class TestPcmTwo {
		
/*
 * 利用線程池創(chuàng)建線程
*/
	
	
	public static void main(String[] args) {
		Store store = new Store();
		
		


		//創(chuàng)建10個線程的線程池
		ExecutorService service = Executors.newFixedThreadPool(10);
		ExecutorService serviceTwo = Executors.newFixedThreadPool(10);
		
		//創(chuàng)建可緩存的線程池
		//可緩存的
		//ExecutorService service = Executors.newCachedThreadPool();
		//ExecutorService serviceTwo = Executors.newCachedThreadPool();
		
		for(int i =0 ;i<11;i++) {
			service.execute(new Producer(store));
			
		}
		for(int i =0 ;i<11;i++) {
			serviceTwo.execute(new Customer(store));			
		}
			
		
		
		
		//關(guān)閉線程池
			service.shutdown();
			serviceTwo.shutdown();	
	}

}