java並發隊列

㈠ 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」類則一般通過一個單鎖來防止對集合的所有訪問，開銷大且伸縮性差。

㈡ java 什麼情況下使用 並發隊列

並發隊列是一個基於鏈接節點的無界線程安全隊列，它採用先進先出的規則對節點進行排序，當我們添加一個元素的時候，它會添加到隊列的尾部，當我們獲取一個元素時，它會返回隊列頭部的元素。它採用了「wait－free」演算法來實現，該演算法在Michael
& Scott演算法上進行了一些修改。

入隊列

入隊列就是將入隊節點添加到隊列的尾部。為了方便理解入隊時隊列的變化，以及head節點和tair節點的變化，每添加一個節點我就做了一個隊列的快照圖。

publicEpoll(){

Node</e><e>h=head;

//p表示頭節點，需要出隊的節點

Node</e><e>p=h;

for(inthops=0;;hops++){

//獲取p節點的元素

Eitem=p.getItem();

//如果p節點的元素不為空，使用CAS設置p節點引用的元素為null,如果成功則返回p節點的元素。

if(item!=null&&p.casItem(item,null)){

if(hops>=HOPS){

//將p節點下一個節點設置成head節點

Node</e><e>q=p.getNext();

updateHead(h,(q!=null)?q:p);

}

returnitem;

}

//如果頭節點的元素為空或頭節點發生了變化，這說明頭節點已經被另外一個線程修改了。那麼獲取p節點的下一個節點

Node</e><e>next=succ(p);

//如果p的下一個節點也為空，說明這個隊列已經空了

if(next==null){

//更新頭節點。

updateHead(h,p);

break;

}

//如果下一個元素不為空，則將頭節點的下一個節點設置成頭節點

p=next;

}

returnnull;

}

首先獲取頭節點的元素，然後判斷頭節點元素是否為空，如果為空，表示另外一個線程已經進行了一次出隊操作將該節點的元素取走，如果不為空，則使用CAS的方式將頭節點的引用設置成null，如果CAS成功，則直接返回頭節點的元素，如果不成功，表示另外一個線程已經進行了一次出隊操作更新了head節點，導致元素發生了變化，需要重新獲取頭節點。

㈢ java 如何實現一個線程安全的隊列

java.util.concurrent ConcurrentLinkedQueue 類提供了高效的、可伸縮的、線程安全的非阻塞 FIFO 隊列。java.util.concurrent 中的五個實現都支持擴展的 BlockingQueue 介面，該介面定義了 put 和 take 的阻塞版本：LinkedBlockingQueue、ArrayBlockingQueue、SynchronousQueue、PriorityBlockingQueue 和 DelayQueue。這些不同的類覆蓋了生產者-使用者、消息傳遞、並行任務執行和相關並發設計的大多數常見使用的上下文。
自己去參考一下jdk5或6的api文檔，裡面已經實現了

㈣ java阻塞隊列、非阻塞隊列和有界隊列、無界隊列的關系

看圖

㈤ java如何創建一個定長線程池，可控制線程最大並發數，超出的線程會在隊列中等待。求代碼

packagetest;
importjava.util.concurrent.ExecutorService;
importjava.util.concurrent.Executors;
{
publicstaticvoidmain(String[]args){
=Executors.newFixedThreadPool(3);
for(inti=0;i<10;i++){
finalintindex=i;
fixedThreadPool.execute(newRunnable(){
publicvoidrun(){
try{
System.out.println(index);
Thread.sleep(2000);
}catch(InterruptedExceptione){
e.printStackTrace();
}
}
});
}
}
}

因為線程池大小為3，每個任務輸出index後sleep 2秒，所以每兩秒列印3個數字。

定長線程池的大小最好根據系統資源進行設置。如Runtime.getRuntime().availableProcessors()

㈥ java線程組，線程池，線程隊列分別是什麼有什麼區別

你好，我可以給你詳細解釋一下：
線程組表示一個線程的集合。此外，線程組也可以包含其他線程組。線程組構成一棵樹，在樹中，除了初始線程組外，每個線程組都有一個父線程組。
允許線程訪問有關自己的線程組的信息，但是不允許它訪問有關其線程組的父線程組或其他任何線程組的信息。
線程池：我們可以把並發執行的任務傳遞給一個線程池，來替代為每個並發執行的任務都啟動一個新的線程。只要池裡有空閑的線程，任務就會分配給一個線程執行。在線程池的內部，任務被插入一個阻塞隊列（Blocking Queue ），線程池裡的線程會去取這個隊列里的任務。當一個新任務插入隊列時，一個空閑線程就會成功的從隊列中取出任務並且執行它。

線程池經常應用在多線程伺服器上。每個通過網路到達伺服器的連接都被包裝成一個任務並且傳遞給線程池。線程池的線程會並發的處理連接上的請求。以後會再深入有關 Java 實現多線程伺服器的細節。
線程隊列：是指線程處於擁塞的時候形成的調度隊列
排隊有三種通用策略：
直接提交。工作隊列的默認選項是 SynchronousQueue，它將任務直接提交給線程而不保持它們。在此，如果不存在可用於立即運行任務的線程，則試圖把任務加入隊列將失敗，因此會構造一個新的線程。此策略可以避免在處理可能具有內部依賴性的請求集時出現鎖。直接提交通常要求無界 maximumPoolSizes 以避免拒絕新提交的任務。當命令以超過隊列所能處理的平均數連續到達時，此策略允許無界線程具有增長的可能性。
無界隊列。使用無界隊列（例如，不具有預定義容量的 LinkedBlockingQueue）將導致在所有corePoolSize 線程都忙時新任務在隊列中等待。這樣，創建的線程就不會超過 corePoolSize。（因此，maximumPoolSize的值也就無效了。）當每個任務完全獨立於其他任務，即任務執行互不影響時，適合於使用無界隊列；例如，在 Web頁伺服器中。這種排隊可用於處理瞬態突發請求，當命令以超過隊列所能處理的平均數連續到達時，此策略允許無界線程具有增長的可能性。
有界隊列。當使用有限的 maximumPoolSizes時，有界隊列（如 ArrayBlockingQueue）有助於防止資源耗盡，但是可能較難調整和控制。隊列大小和最大池大小可能需要相互折衷：使用大型隊列和小型池可以最大限度地降低 CPU 使用率、操作系統資源和上下文切換開銷，但是可能導致人工降低吞吐量。如果任務頻繁阻塞（例如，如果它們是 I/O邊界），則系統可能為超過您許可的更多線程安排時間。使用小型隊列通常要求較大的池大小，CPU使用率較高，但是可能遇到不可接受的調度開銷，這樣也會降低吞吐量。

㈦ java中如何對某個方法或者某個代碼塊使用阻塞隊列來保證並發情況下線程是安全的

synchronize加在函數方法或者代碼塊，就能按你說的保證線程安全，原理是多線程進入時候系統會只允許一個線程執行那些語句

㈧ JAVA如何用隊列實現並發

如果是搶資源，在不作弊的情況下 按照先來先得的規則 ，那麼比較簡單的實現就是隊列 ，不管請求的並發多高，如果用線程來實現為用戶服務，也就是說 來一個人請求資源那麼就啟動一個線程，那CPU執行線程總是有順序的，比如 當前三個人（路人甲路人乙路人丙）請求A資源 ，那服務端就起了三個線程為這三個人服務，假設 這三個人不太幸運在請求的時候沒有及時的獲得CPU時間片，那麼他們三個相當於公平競爭CPU資源，而CPU選擇運行線程是不確定順序的 ，又假設 選中了路人丙的線程運行那麼將其放入隊列就好了,路人乙，路人丙以此類推 ，那可能會想為什麼不及時的處理呢 ，因為後續的操作可能是耗時操作對於線程的佔用時間較長那請求資源的人多了服務端就可能掛了

㈨ java：spring的定時任務是 無限隊列嗎，並發的情況下會不會發生oom

肯定會啊，定時任務也是線程池，池子滿了就好擠出去