線程池的參考網(wǎng)址：http://www.cnblogs.com/exe19/p/5359885.html
四種線程參考網(wǎng)址：http://blog.csdn.net/hupitao/article/details/24453083
volatile
volatile的作用是： 作為指令關(guān)鍵字稠曼，確保本條指令不會(huì)因編譯器的優(yōu)化而省略损合，且要求每次直接讀值.
簡(jiǎn)單地說就是防止編譯器對(duì)代碼進(jìn)行優(yōu)化.比如如下程序：
XBYTE[2]=0x55;
XBYTE[2]=0x56;
XBYTE[2]=0x57;
XBYTE[2]=0x58;
對(duì)外部硬件而言，上述四條語句分別表示不同的操作垫挨，會(huì)產(chǎn)生四種不同的動(dòng)作，但是編譯器卻會(huì)對(duì)上述四條語句進(jìn)行優(yōu)化敞临，認(rèn)為只有XBYTE[2]=0x58（即忽略前三條語句蛉迹，只產(chǎn)生一條機(jī)器代碼）。如果鍵入volatile英岭，則編譯器會(huì)逐一的進(jìn)行編譯并產(chǎn)生相應(yīng)的機(jī)器代碼（產(chǎn)生四條代碼）.
Java中的ReentrantLock和synchronized兩種鎖定機(jī)制的對(duì)比
- 實(shí)現(xiàn)多線程和并發(fā)性湾盒，使用的類庫核心類庫包含一個(gè) Thread類，可以用它來構(gòu)建诅妹、啟動(dòng)和操縱線程
- Java 語言包括了跨線程傳達(dá)并發(fā)性約束的構(gòu)造 —— synchronized 和 volatile
synchronized回顧
- 代碼塊聲明為 synchronized罚勾，有兩個(gè)重要后果，通常是指該代碼具有 原子性（atomicity）和 可見性（visibility）
- 原子性意味著一個(gè)線程一次只能執(zhí)行由一個(gè)指定監(jiān)控對(duì)象（lock）保護(hù)的代碼吭狡，從而防止多個(gè)線程在更新共享狀態(tài)時(shí)相互沖突
- 可見性則更為微妙尖殃；它要對(duì)付內(nèi)存緩存和編譯器優(yōu)化的各種反常行為
- 總結(jié)就是:被鎖定的成員將繼續(xù)寧執(zhí)行完后，才能再次執(zhí)行后面的代碼划煮，volatile也類似這樣
synchronized (lockObject) {
// update object state
}
如此看來同步相當(dāng)好了送丰，是么？那么為什么 JSR 166 小組花了這么多時(shí)間來開發(fā) java.util.concurrent.lock框架呢弛秋？
-->>答案很簡(jiǎn)單－同步是不錯(cuò)器躏，但它并不完美。它有一些功能性的限制 —— 它無法中斷一個(gè)正在等候獲得鎖的線程蟹略，也無法通過投票得到鎖登失，如果不想等下去，也就沒法得到鎖挖炬。同步還要求鎖的釋放只能在與獲得鎖所在的堆棧幀相同的堆棧幀中進(jìn)行揽浙，多數(shù)情況下，這沒問題（而且與異常處理交互得很好），但是馅巷，確實(shí)存在一些非塊結(jié)構(gòu)的鎖定更合適的情況膛虫。
ReentrantLock回顧
- java.util.concurrent.lock中的 Lock框架是鎖定的一個(gè)抽象，它允許把鎖定的實(shí)現(xiàn)作為 Java 類钓猬，而不是作為關(guān)鍵字(語言特性)
- 這就為 Lock的多種實(shí)現(xiàn)留下了空間稍刀，各種實(shí)現(xiàn)可能有不同的調(diào)度算法、性能特性或者鎖定語義
- ReentrantLock類實(shí)現(xiàn)了 Lock逗噩，它擁有與 synchronized相同的并發(fā)性和內(nèi)存語義掉丽，但是添加了類似鎖投票、定時(shí)鎖等候和可中斷鎖等候的一些特性
- 它還提供了在激烈爭(zhēng)用情況下更佳的性能异雁。（換句話說捶障，當(dāng)許多線程都想訪問共享資源時(shí)，JVM 可以花更少的時(shí)候來調(diào)度線程纲刀，把更多時(shí)間用在執(zhí)行線程上项炼。）
- 它有一個(gè)與鎖相關(guān)的獲取計(jì)數(shù)器，如果擁有鎖的某個(gè)線程再次得到鎖示绊，那么獲取計(jì)數(shù)器就加1锭部，然后鎖需要被釋放兩次才能獲得真正釋放。(注意釋放鎖）
Lock lock = new ReentrantLock();
lock.lock();
try {
// update object state
}
finally {
lock.unlock();
}
多線程池ThreadPoolExecutor
public class ThreadPoolExecutor extends AbstractExecutorService {
.....
public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,
BlockingQueue<Runnable> workQueue);
public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,
BlockingQueue<Runnable> workQueue,ThreadFactory threadFactory);
public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,
BlockingQueue<Runnable> workQueue,RejectedExecutionHandler handler);
public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,
BlockingQueue<Runnable> workQueue,ThreadFactory threadFactory,RejectedExecutionHandler handler);
...
}
線程池案例
public class Test {
public static void main(String[] args) {
ThreadPoolExecutor executor = new ThreadPoolExecutor(5, 10, 200, TimeUnit.MILLISECONDS,new ArrayBlockingQueue<Runnable>(5));
for(int i=0;i<15;i++){
MyTask myTask = new MyTask(i);
executor.execute(myTask);
System.out.println("線程池中線程數(shù)目："+executor.getPoolSize()+"面褐，隊(duì)列中等待執(zhí)行的任務(wù)數(shù)目："+
executor.getQueue().size()+"拌禾，已執(zhí)行玩別的任務(wù)數(shù)目："+executor.getCompletedTaskCount());
}
executor.shutdown();
}
}
class MyTask implements Runnable {
private int taskNum;
public MyTask(int num) {
this.taskNum = num;
}
@Override
public void run() {
System.out.println("正在執(zhí)行task "+taskNum);
try {
Thread.currentThread().sleep(4000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("task "+taskNum+"執(zhí)行完畢");
}
}
--- 從執(zhí)行結(jié)果可以看出，當(dāng)線程池中線程的數(shù)目大于5時(shí)展哭，便將任務(wù)放入任務(wù)緩存隊(duì)列里面湃窍，當(dāng)任務(wù)緩存隊(duì)列滿了之后，便創(chuàng)建新的線程匪傍。如果上面程序中您市，將for循環(huán)中改成執(zhí)行20個(gè)任務(wù)，就會(huì)拋出任務(wù)拒絕異常了役衡。
--- 不過在java doc中茵休，并不提倡我們直接使用ThreadPoolExecutor，而是使用Executors類中提供的幾個(gè)靜態(tài)方法來創(chuàng)建線程池：
其實(shí)是對(duì)的實(shí)現(xiàn)（提供默認(rèn)值）
Executors.newCachedThreadPool(); //創(chuàng)建一個(gè)緩沖池手蝎，緩沖池容量大小為Integer.MAX_VALUE榕莺，可靈活回收空閑線程，線程池為無限大柑船，當(dāng)執(zhí)行第二個(gè)任務(wù)時(shí)第一個(gè)任務(wù)已經(jīng)完成帽撑，會(huì)復(fù)用執(zhí)行第一個(gè)任務(wù)的線程，而不用每次新建線程鞍时。
Executors.newSingleThreadExecutor(); //創(chuàng)建一個(gè)單線程化的線程池，它只會(huì)用唯一的工作線程來執(zhí)行任務(wù)，保證所有任務(wù)按照指定順序(FIFO, LIFO, 優(yōu)先級(jí))執(zhí)行
Executors.newFixedThreadPool(int); //創(chuàng)建一個(gè)定長(zhǎng)線程池逆巍，可控制線程最大并發(fā)數(shù)及塘，超出的線程會(huì)在隊(duì)列中等待。
Executors.newScheduledThreadPool (int); //創(chuàng)建一個(gè)定長(zhǎng)線程池锐极，支持定時(shí)及周期性任務(wù)執(zhí)行笙僚。
