java - JDK中的先进先出队列

Question

这个问题已经有答案了:

Is there a fixed sized queue which removes excessive elements? (15 个回答)

Is there a Java collection which removes items as more items are added? (a simple cache) [duplicate] (1 个回答)

Size-limited queue that holds last N elements in Java (9 个回答)

已关闭 4 年前。

我想要一个带有 FIFO 的有限队列。因此，如果超过队列的最大大小，则删除第一个元素。

带有 Google 集合的 FIFO 队列:

Queue<Integer> fifo = EvictingQueue.create(2); 
fifo.add(1); 
fifo.add(2); 
fifo.add(3); 
System.out.println(fifo);  // prints [2, 3]

带有 apache 集合的 FIFO 队列:

// FIFO-queue works with apache collections
Queue<Integer> fifo2 = new CircularFifoQueue<>(2);
fifo2.add(1);
fifo2.add(2);
fifo2.add(3);
System.out.println(fifo2); // prints [2, 3]

带有 JDK 集合的 FIFO 队列:

Queue<Integer> fifo3 = new ArrayBlockingQueue<>(2);
fifo3.offer(1);
fifo3.offer(2);
fifo3.offer(3);
System.out.println(fifo3); // prints [1, 2]

ArrayBlockingQueue不像 FIFO 那样工作，只有在队列已满时才会停止插入元素。

是否有类似于 EvictingQueue 工作的 JDK FIFO 队列或CircularFifoQueue ？

如果 JDK 没有提供类似的东西，我应该选择哪一个:EvictingQueue或CircularFifoQueue ？哪个实现得更好？

(请不要提供 fifo 队列的示例实现，我想使用 lib，最好只使用 JDK)

Answer 1

如果您看到 ArrayBlockingQueue 的 Offer 实现，它有一行，因此值 3 甚至没有附加到 items 数组中。

if (count == items.length)
  return false;

所以你可以这样做:

static void append(Queue<Integer> fifo, int i) {
  if (!fifo.offer(i)) {
      fifo.poll();
      fifo.offer(i);
  }
}

// in main:
Queue<Integer> fifo3 = new ArrayBlockingQueue<>(2);
append(fifo3, 1);
append(fifo3, 2);
append(fifo3, 3);
System.out.println(fifo3); // prints [2, 3]