java安全隊列

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

以下是兩個線程：

import java.util.*;

public class Thread_List_Operation {
//假設有這么一個隊列
static List list = new LinkedList();

public static void main(String[] args) {
Thread t;
t = new Thread(new T1());
t.start();
t = new Thread(new T2());
t.start();

}

}

//線程T1,用來給list添加新元素
class T1 implements Runnable{

void getElemt(Object o){
Thread_List_Operation.list.add(o);
System.out.println(Thread.currentThread().getName() + "為隊列添加了一個元素");
}
@Override
public void run() {
for (int i = 0; i < 10; i++) {
getElemt(new Integer(1));
}

}

}

//線程T2,用來給list添加新元素
class T2 implements Runnable{

void getElemt(Object o){
Thread_List_Operation.list.add(o);
System.out.println(Thread.currentThread().getName() + "為隊列添加了一個元素");
}
@Override
public void run() {
for (int i = 0; i < 10; i++) {
getElemt(new Integer(1));
}

}

}

//結果（亂序）
Thread-0為隊列添加了一個元素
Thread-1為隊列添加了一個元素
Thread-0為隊列添加了一個元素
Thread-1為隊列添加了一個元素
Thread-1為隊列添加了一個元素
Thread-1為隊列添加了一個元素
Thread-1為隊列添加了一個元素
Thread-1為隊列添加了一個元素
Thread-1為隊列添加了一個元素
Thread-1為隊列添加了一個元素
Thread-1為隊列添加了一個元素
Thread-1為隊列添加了一個元素
Thread-0為隊列添加了一個元素
Thread-0為隊列添加了一個元素
Thread-0為隊列添加了一個元素
Thread-0為隊列添加了一個元素
Thread-0為隊列添加了一個元素
Thread-0為隊列添加了一個元素
Thread-0為隊列添加了一個元素
Thread-0為隊列添加了一個元素

❷ java實現線程安全的隊列

PrintPreviewDialog pPDlg;
exec_prefix='NONE'PACKAGE='libevent'
PACKAGE_BUGREPORT=''
PACKAGE_NAME=''
PACKAGE_STRING=''
PACKAGE_TARNAME=''
PACKAGE_URL=''
PACKAGE_VERSION=''
PATH_SEPARATOR=':'

❸ JAVA中哪個能同時滿足 先進先出（增減操作非常頻繁）和同步安全的容器集合並在性能上不至於太差

public class ConcurrentLinkedQueue<E>
extends AbstractQueue<E>
implements Queue<E>, Serializable

一個基於鏈接節點的無界線程安全隊列。此隊列按照 FIFO（先進先出）原則對元素進行排序。隊列的頭部 是隊列中時間最長的元素。隊列的尾部 是隊列中時間最短的元素。新的元素插入到隊列的尾部，隊列獲取操作從隊列頭部獲得元素。當多個線程共享訪問一個公共 collection 時，ConcurrentLinkedQueue 是一個恰當的選擇。此隊列不允許使用 null 元素。

此實現採用了有效的「無等待 (wait-free)」演算法，該演算法基於 Maged M. Michael 和 Michael L. Scott 合著的 Simple, Fast, and Practical Non-Blocking and Blocking Concurrent Queue Algorithms 中描述的演算法。

需要小心的是，與大多數 collection 不同，size 方法不是 一個固定時間操作。由於這些隊列的非同步特性，確定當前元素的數量需要遍歷這些元素。

此類及其迭代器實現了 Collection 和 Iterator 介面的所有可選 方法。

內存一致性效果：當存在其他並發 collection 時，將對象放入 ConcurrentLinkedQueue 之前的線程中的操作 happen-before 隨後通過另一線程從 ConcurrentLinkedQueue 訪問或移除該元素的操作。

注意：ConcurrentLinkedQueue的size()是要遍歷一遍集合的！因此，若不能滿足你，可以基於 LinkedList（先進先出），自己加上同步，要性能控制住，需要盡可能小力度加同步 。

❹ 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中，常用的隊列實現是哪個

用的比較多的是線程安全的
arrayblockingqueue
或者是
linkedblockingqueue.

❻ 在java中，什麼是隊列

好比現實生活中排隊先進先出

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

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

❽ java中秒殺使用的隊列

首先說 隊列這種數據結構你應該了解吧 。
可以用JDK自帶的 或者自己實現的也行，你問的如何實現隊列是指的隊列這中數據結構？ 如果是 ，那你還是自己看數據結構那本書，原理都一樣 跟語言無關， 你可用JDK自帶的幾種隊列 查看JDKAPI文檔 實現了Queue介面的各種隊列基本都有，比如 線程安全的 ConcurrentLinkedQueue 這個是一個無界的線程安全的隊列 或者 ArrayBlockingQueue 這個隊列實現是一個有界阻塞隊列 都能夠實現你說的 或者 你用非線程安全的也成 只不過你自己控制線程的安全性就好了；.

❾ java中的隊列都有哪些，有什麼區別

阻塞隊列、普通隊列，非阻塞隊列。

阻塞隊列與普通隊列的而區別在於，當隊列是空時，從隊列中獲取元素的操作會被阻塞，或則當隊列是滿的時，往隊列中增加元素會被阻塞，試圖從空的隊列中取元素的線程或從滿的隊列中添加元素的線程同樣會被阻塞。

❿ Java中的隊列都有哪些，有什麼區別

阻塞隊列與普通隊列的區別在於，當隊列是空的時，從隊列中獲取元素的操作將會被阻塞，或者當隊列是滿時，往隊列里添加元素的操作會被阻塞。試圖從空的阻塞隊列中獲取元素的線程將會被阻塞，直到其他的線程往空的隊列插入新的元素。同樣，試圖往已滿的阻塞隊列中添加新元素的線程同樣也會被阻塞，直到其他的線程使隊列重新變得空閑起來，如從隊列中移除一個或者多個元素，或者完全清空隊列.
從5.0開始，JDK在java.util.concurrent包里提供了阻塞隊列的官方實現。盡管JDK中已經包含了阻塞隊列的官方實現，但是熟悉其背後的原理還是很有幫助的。一下是阻塞隊列的實現:
public class BlockingQueue {

private List queue = new LinkedList();

private int limit = 10;

public BlockingQueue(int limit){

this.limit = limit;

}

public synchronized void enqueue(Object item)

throws InterruptedException {

while(this.queue.size() == this.limit) {

wait();

}

if(this.queue.size() == 0) {

notifyAll();

}

this.queue.add(item);

}

public synchronized Object dequeue()

throws InterruptedException{

while(this.queue.size() == 0){

wait();

}

if(this.queue.size() == this.limit){

notifyAll();

}

return this.queue.remove(0);

}

}