concurrentjava

① java並發框架有哪些

Java並發框架java.util.concurrent是JDK5中引入到標准庫中的(採用的是Doug
Lea的並發庫)。該包下的類可以分為這么塊：

Executors

1)介面：

Executor(例子涉及)：用來執行提交的Runnable任務的對象。是一個簡單的標准化介面，用來定義包括線程池、非同步IO、輕量級任務框架等等。任務可以由一個新創建的線程、一個已有任務執行線程、或是線程直接調用execute()來執行，可以串列也可並行執行，取決於使用的是哪個Executor具體類。

ExecutorService(例子涉及)：Executor的子介面，提供了一個更加具體的非同步任務執行框架：提供了管理結束的方法，以及能夠產生Future以跟蹤非同步任務進程的方法。一個ExcutorService管理著任務隊列和任務調度。

ScheledExecutorService(例子涉及)：ExecutorService的子介面，增加了對延遲和定期任務執行的支持。

Callable(例子涉及)：一個返回結果或拋出異常的任務，實現類需要實現其中一個沒有參數的叫做call的方法。Callabe類似於Runnable，但是Runnable不返回結果且不能拋出checked
exception。ExecutorService提供了安排Callable非同步執行的方法。

Future(例子涉及)：代表一個非同步計算的結果(由於是並發執行，結果可以在一段時間後才計算完成，其名字可能也就是代表這個意思吧)，提供了可判斷執行是否完成以及取消執行的方法。

2)實現：

ThreadPoolExecutor和ScheledThreadPoolExecutor：可配置線程池(後者具備延遲或定期調度功能)。

Executors(例子涉及)：提供Executor、ExecutorService、ScheledExecutorService、ThreadFactory以及Callable的工廠方法及工具方法。

FutureTask：對Future的實現

ExecutorCompletionService(例子涉及)：幫助協調若干(成組)非同步任務的處理。

Queues

非阻塞隊列：ConcurrentLinkedQueue類提供了一個高效可伸縮線程安全非阻塞FIFO隊列。

阻塞隊列：BlockingQueue介面，有五個實現類：LinkedBlockingQueue(例子涉及)、ArrayBlockingQueue、SynchronousQueue、PriorityBlockingQueue和DelayQueue。他們對應了不同的應用環境：生產者/消費者、消息發送、並發任務、以及相關並發設計。

Timing

TimeUnit類(例子涉及)：提供了多種時間粒度(包括納秒)用以表述和控制基於超時的操作。

Synchronizers 提供特定用途同步語境

Semaphore(例子涉及)：計數信號量，這是一種經典的並發工具。

CountDownLatch(例子涉及)：簡單的倒計數同步工具，可以讓一個或多個線程等待直到另外一些線程中的一組操作處理完成。

CyclicBarrier(例子涉及)：可重置的多路同步工具，可重復使用(CountDownLatch是不能重復使用的)。

Exchanger：允許兩個線程在匯合點交換對象，在一些pipeline設計中非常有用。

Concurrent Collections

除隊列外，該包還提供了一些為多線程上下文設計的集合實現：ConcurrentHashMap、CopyOnWriteArrayList及CopyOnWriteArraySet。

注意："Concurrent"前綴的類有別於"synchronized"前綴的類。「concurrent」集合是線程安全的，不需要由單排斥鎖控制的(無鎖的)。以ConcurrentHashMap為例，允許任何數量的並發讀及可調數量的並發寫。「Synchronized」類則一般通過一個單鎖來防止對集合的所有訪問，開銷大且伸縮性差。