Java多線程併發技術緩存
參考文獻:多線程
http://blog.csdn.net/aboy123/article/details/38307539併發
http://blog.csdn.net/ghsau/article/category/1707779框架
http://www.iteye.com/topic/366591dom
JAVA多線程實現方式主要有三種:繼承Thread類、實現Runnable接口、使用ExecutorService、Callable、Future實現有返回結果的多線程。其中前兩種方式線程執行完後都沒有返回值,只有最後一種是帶返回值的。函數
一、 繼承Thread類實現多線程測試
public class MyThread extends Thread {this public void run() { //重寫run方法spa System.out.println("MyThread.run()");.net } }
//調用代碼 MyThread myThread1 = new MyThread(); MyThread myThread2 = new MyThread(); myThread1.start(); // 啓動線程 myThread2.start(); |
Thread本質上也是實現了Runnable接口的一個實例,它表明一個線程的實例,而且,啓動線程的惟一方法就是經過Thread類的start()實例方法 |
二、 實現Runnable接口方式實現多線程
//若是本身的類已經extends另外一個類,就沒法直接extends Thread,此時,必須實現一個Runnable接口,以下: public class MyThread extends OtherClass implements Runnable { public void run() { System.out.println("MyThread.run()"); } } |
//爲了啓動MyThread,須要首先實例化一個Thread,並傳入本身的MyThread實例: MyThread myThread = new MyThread(); Thread thread = new Thread(myThread); thread.start(); |
三、 使用ExecutorService、Callable、Future實現有返回結果的多線程
ExecutorService、Callable、Future這個對象實際上都是屬於Executor框架中的功能類。可返回值的任務必須實現Callable接口,相似的,無返回值的任務必須Runnable接口。執行Callable任務後,能夠獲取一個Future的對象,在該對象上調用get就能夠獲取到Callable任務返回的Object了,再結合線程池接口ExecutorService就能夠實現有返回結果的多線程了。
// 實現Callable接口
|
四、 Executors類說明:
參考文獻:http://www.iteye.com/topic/366591
Executors類,提供了一系列工廠方法用於建立線程池,返回的線程池都實現了ExecutorService接口。
public static ExecutorService newFixedThreadPool(int nThreads)
建立固定數目線程的線程池。
public static ExecutorService newCachedThreadPool()
建立一個可緩存的線程池,調用execute 將重用之前構造的線程(若是線程可用)。若是現有線程沒有可用的,則建立一個新線程並添加到池中。終止並從緩存中移除那些已有 60 秒鐘未被使用的線程。
public static ExecutorService newSingleThreadExecutor()
建立一個單線程化的Executor。
public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize)
建立一個支持定時及週期性的任務執行的線程池,多數狀況下可用來替代Timer類。
ExecutoreService提供了submit()方法,傳遞一個Callable,或Runnable,返回Future。若是Executor後臺線程池尚未完成Callable的計算,這調用返回Future對象的get()方法,會阻塞直到計算完成。
五、 其餘得到線程執行結果的方式:
http://blog.csdn.net/ghsau/article/details/7451464
基於FutureTask;
在上述實現中,任務callable被提交後返回一個future用於得到執行結果;
FutureTask實現了兩個接口,Runnable和Future,因此它既能夠做爲Runnable被線程執行,又能夠做爲Future獲得Callable的返回值;
19. }
|
基於CompletionService的實現方式
//take 每次得到一個執行完成的future,若是沒有就阻塞,與其功能相同的非阻塞調用時poll
}
|
六、 多線程相關函數:
參考文獻:http://blog.csdn.net/ghsau/article/details/17560467
線程中斷:http://blog.csdn.net/z69183787/article/details/25076033
|
interrupt |
|
interrupted |
|
isInterrupted |
線程讓步
|
yield |
注意: 若是存在synchronized線程同步的話,線程讓步不會釋放鎖(監視器對象)。
線程休眠:
|
sleep |
注意: 若是存在synchronized線程同步的話,線程休眠不會釋放鎖(監視器對象),但會釋放cpu;
線程合併:http://uule.iteye.com/blog/1101994
|
join |
|
join |
|
join |
線程合併是優先執行調用該方法的線程,再執行當前線程。內部是用wait方法實現的
11. } class JoinThread extends Thread {
}
|
七、 線程同步之鎖