Table of Contents
ToggleConcurrentLinkedQueue in Java with Examples
其佇列可以隨著元素的增加而動態增長,但是,如果沒有足夠的記憶體,則會拋出 OutOfMemoryError,是執行緒安全的無界佇列, Java ConcurrentLinkedQueue Examples 介紹常見的 forEach 、 iterator 、 spliterator 、 trySplit 、 drainTo 等方法,本篇增加了範例,並透過單元測試來驗證產出結果。
檔案目錄
./
+- src
+- test
| +- org
| +- ruoxue
| +- java_147
| +- queue
| +- concurrentlinkedqueue
| +- ConcurrentLinkedQueueWithExamplesTest.java
單元測試
Queue Java 提供循環訪問、佇列匯出、轉成陣列等操作列表中的元素。
forEach
建立一個 ConcurrentLinkedQueue ,內有三個元素,迴圈取得元素。
@Test
public void forEach() {
Queue<String> queue = new ConcurrentLinkedQueue<String>();
queue.add("Papaya");
queue.add("Strawberry");
queue.add("Watermelon");
queue.forEach(e -> System.out.println(e));
}
Papaya
Strawberry
Watermelon
forEachRemaining
建立一個 ConcurrentLinkedQueue ,內有三個元素,迴圈取得剩餘元素。
@Test
public void forEachRemaining() {
Queue<String> queue = new ConcurrentLinkedQueue<String>();
queue.add("Papaya");
queue.add("Strawberry");
queue.add("Watermelon");
Iterator<String> it = queue.iterator();
int i = 0;
while (it.hasNext()) {
System.out.println(it.next());
if (i == 1) {
break;
}
i++;
}
System.out.println("----------");
it.forEachRemaining(e -> {
System.out.println(e);
});
}
Papaya
Strawberry
----------
Watermelon
iterator
Queue Java 建立一個 ConcurrentLinkedQueue ,內有三個元素,迴圈取得元素。
@Test
public void iterator() {
Queue<String> queue = new ConcurrentLinkedQueue<String>();
queue.add("Papaya");
queue.add("Strawberry");
queue.add("Watermelon");
Iterator<String> it = queue.iterator();
while (it.hasNext()) {
System.out.println(it.next());
}
}
Papaya
Strawberry
Watermelon
spliterator
Queue Java 建立一個 ConcurrentLinkedQueue ,內有三個元素,使用 spliterator 取得元素,等同於 iterator.hasNext 和 iterator.next。
@Test
public void spliterator() {
Queue<String> queue = new ConcurrentLinkedQueue<String>();
queue.add("Papaya");
queue.add("Strawberry");
queue.add("Watermelon");
Spliterator<String> sit = queue.spliterator();
sit.tryAdvance(e -> System.out.println(e));
System.out.println("----------");
sit.forEachRemaining(e -> System.out.println(e));
System.out.println("----------");
sit = queue.spliterator();
while (sit.tryAdvance(e -> System.out.println(e))) {
}
}
Papaya
----------
Strawberry
Watermelon
----------
Papaya
Strawberry
Watermelon
trySplit
Queue Java 建立一個 ConcurrentLinkedQueue ,內有三個元素,使用 spliterator 取得元素,trySplit 將目前的拆分器分為兩個新的拆分器並行處理。
@Test
public void trySplit() {
Queue<String> queue = new ConcurrentLinkedQueue<String>();
queue.add("Papaya");
queue.add("Strawberry");
queue.add("Watermelon");
Spliterator<String> sit = queue.spliterator();
Spliterator<String> sit2 = sit.trySplit();
System.out.println(sit.getExactSizeIfKnown());
sit.forEachRemaining(e -> System.out.println(e));
System.out.println("----------");
System.out.println(sit2.getExactSizeIfKnown());
sit2.forEachRemaining(e -> System.out.println(e));
}
-1
Strawberry
Watermelon
----------
1
Papaya
toArray
Java ConcurrentLinkedQueue 建立一個 ConcurrentLinkedQueue ,內有三個元素, 轉換成 String 陣列。
@Test
public void toArray() {
int expectedSize = 3;
Queue<String> queue = new ConcurrentLinkedQueue<String>();
queue.add("Papaya");
queue.add("Strawberry");
queue.add("Watermelon");
String[] array = new String[queue.size()];
queue.toArray(array);
for (String e : array) {
System.out.println(e);
}
assertEquals(expectedSize, array.length);
}
Papaya
Strawberry
Watermelon
streamToArray
Java ConcurrentLinkedQueue 建立一個 ConcurrentLinkedQueue ,內有三個元素,使用 Stream ,轉換成 String 陣列。
@Test
public void streamToArray() {
int expectedSize = 3;
Queue<String> queue = new ConcurrentLinkedQueue<String>();
queue.add("Papaya");
queue.add("Strawberry");
queue.add("Watermelon");
String[] array = queue.stream().toArray(String[]::new);
for (String e : array) {
System.out.println(e);
}
assertEquals(expectedSize, array.length);
}
Papaya
Strawberry
Watermelon
ConcurrentLinkedQueueWithExamplesTest.java
Java ConcurrentLinkedQueue 新增單元測試,驗證是否符合預期。
package org.ruoxue.java_147.queue.concurrentlinkedqueue;
import static org.junit.Assert.*;
import java.util.Iterator;
import java.util.Queue;
import java.util.Spliterator;
import java.util.concurrent.ConcurrentLinkedQueue;
import org.junit.Test;
public class ConcurrentLinkedQueueWithExamplesTest {
@Test
public void forEach() {
Queue<String> queue = new ConcurrentLinkedQueue<String>();
queue.add("Papaya");
queue.add("Strawberry");
queue.add("Watermelon");
queue.forEach(e -> System.out.println(e));
}
@Test
public void forEachRemaining() {
Queue<String> queue = new ConcurrentLinkedQueue<String>();
queue.add("Papaya");
queue.add("Strawberry");
queue.add("Watermelon");
Iterator<String> it = queue.iterator();
int i = 0;
while (it.hasNext()) {
System.out.println(it.next());
if (i == 1) {
break;
}
i++;
}
System.out.println("----------");
it.forEachRemaining(e -> {
System.out.println(e);
});
}
@Test
public void iterator() {
Queue<String> queue = new ConcurrentLinkedQueue<String>();
queue.add("Papaya");
queue.add("Strawberry");
queue.add("Watermelon");
Iterator<String> it = queue.iterator();
while (it.hasNext()) {
System.out.println(it.next());
}
}
@Test
public void spliterator() {
Queue<String> queue = new ConcurrentLinkedQueue<String>();
queue.add("Papaya");
queue.add("Strawberry");
queue.add("Watermelon");
Spliterator<String> sit = queue.spliterator();
sit.tryAdvance(e -> System.out.println(e));
System.out.println("----------");
sit.forEachRemaining(e -> System.out.println(e));
System.out.println("----------");
sit = queue.spliterator();
while (sit.tryAdvance(e -> System.out.println(e))) {
}
}
@Test
public void trySplit() {
Queue<String> queue = new ConcurrentLinkedQueue<String>();
queue.add("Papaya");
queue.add("Strawberry");
queue.add("Watermelon");
Spliterator<String> sit = queue.spliterator();
Spliterator<String> sit2 = sit.trySplit();
System.out.println(sit.getExactSizeIfKnown());
sit.forEachRemaining(e -> System.out.println(e));
System.out.println("----------");
System.out.println(sit2.getExactSizeIfKnown());
sit2.forEachRemaining(e -> System.out.println(e));
}
@Test
public void toArray() {
int expectedSize = 3;
Queue<String> queue = new ConcurrentLinkedQueue<String>();
queue.add("Papaya");
queue.add("Strawberry");
queue.add("Watermelon");
String[] array = new String[queue.size()];
queue.toArray(array);
for (String e : array) {
System.out.println(e);
}
assertEquals(expectedSize, array.length);
}
@Test
public void streamToArray() {
int expectedSize = 3;
Queue<String> queue = new ConcurrentLinkedQueue<String>();
queue.add("Papaya");
queue.add("Strawberry");
queue.add("Watermelon");
String[] array = queue.stream().toArray(String[]::new);
for (String e : array) {
System.out.println(e);
}
assertEquals(expectedSize, array.length);
}
}
心得分享
Java Queue Examples 此佇列是 Java 集合框架的成員之一,基於鏈結實現安全無界的佇列,使用先進先出的策略,以排隊的人為例,第一個加入排隊的人,將首先完成其工作, Java ConcurrentLinkedQueue 提供了幾種 ConcurrentLinkedQueue 常見方法的操作範例。