Java: ArrayBlockingQueue vs. LinkedBlockingQueue

Question

Penso che, nella maggior parte dei casi, lo ArrayBlockingQueue funzionerà meglio dello LinkedBlockingQueue. Tuttavia, questo è il caso quando c'è sempre abbastanza spazio nell'array ... Se si riempie, non è molto prevedibile se andrà altrettanto bene, poiché bloccherà il thread che sta cercando di spingere i dati nella coda ..

Quindi, la mia domanda è: Esiste un'implementazione di middle-ground di BlockingQueue? Supponiamo, uno ArrayListBlockingQueue o uno BucketListBlockingQueue? Qualcosa come un elenco di matrici, in modo che la coda possa aumentare in modo dinamico la capacità, pur avendo ancora un vantaggio ragionevole dall'utilizzo di array per archiviare i dati in modo definitivo?

Answer 1

I miei 2 centesimi:

Per cominciare, la linea di fondo è che non si interessa davvero la differenza qui perché anche quando si utilizza un LinkedBlockingQueue pianura, la prestazione è abbastanza buono quando si consegnano alcuni sistemi di micro-secondo livello. Quindi la differenza di prestazioni qui non è poi così bella.

Se si sta scrivendo un sistema ad alte prestazioni mission-critical e si utilizzano code per passare messaggi tra thread, è sempre possibile stimare la dimensione della coda necessaria per [Dimensione coda] = [Ritardo massimo accettabile] * [Velocità messaggio massima ]. Tutto ciò che può crescere oltre tale capacità significa che soffri di un problema di consumo lento. In un'applicazione mission critical, tale ritardo indica che il sistema non funziona correttamente. Potrebbe essere necessario qualche processo manuale per assicurarsi che il sistema funzioni correttamente.

Nel caso in cui il sistema non sia di importanza critica, è sufficiente sospendere (bloccare) l'editore fino a quando alcuni utenti non sono disponibili.

Answer 2

1. LinkedBlockingQueue (LinkedList Attuazione ma non esattamente JDK Attuazione LinkedList Esso utilizza statica classe interna Nodo per mantenere i collegamenti tra gli elementi) di classe

Constructor for LinkedBlockingQueue 
public LinkedBlockingQueue(int capacity) 
{ 
     if (capacity < = 0) throw new IllegalArgumentException(); 
     this.capacity = capacity; 
     last = head = new Node<E>(null); // Maintains a underlying linkedlist. (Use when size is not known) 
} 

nodo utilizzato per mantenere i collegamenti

static class Node<E> { 
    E item; 
    Node<E> next; 
    Node(E x) { item = x; } 
} 

2. ArrayBlockingQueue (Array Attuazione)

costruzione per ArrayBlockingQueue

public ArrayBlockingQueue(int capacity, boolean fair) 
{ 
      if (capacity < = 0) 
       throw new IllegalArgumentException(); 
      this.items = new Object[capacity]; // Maintains a underlying array 
      lock = new ReentrantLock(fair); 
      notEmpty = lock.newCondition(); 
      notFull = lock.newCondition(); 
} 

IMHO più grande differenza tra ArrayBlockingQueue e LinkedBlockingQueue risulta dal costruttore si ha sottostante array e altri LinkedList.

ArrayBlockingQueue utilizza single-lock double condition algorithm e LinkedBlockingQueue è variante dell'algoritmo "due serratura coda" e ha 2 chiusure 2 condizioni (takeLock, putLock)

Finora diedi confronto tra questi 2 implementazioni Tornando alla domanda iniziale, Una domanda simile è stata posta nel concurrency mailing list in questo doug Lea parla di DynamicArrayBlockingQueue che è implementation provided by Dawid Kurzyniec.