在Java中,可以使用以下方式實現BlockingQueue:
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
public class MyClass {
public static void main(String[] args) {
// 創建一個容量為10的ArrayBlockingQueue
BlockingQueue<String> blockingQueue = new ArrayBlockingQueue<>(10);
// 向隊列中插入元素
blockingQueue.put("Element 1");
blockingQueue.put("Element 2");
// 從隊列中獲取元素
String element = blockingQueue.take();
System.out.println(element);
}
}
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
public class MyClass {
public static void main(String[] args) {
// 創建一個容量為10的LinkedBlockingQueue
BlockingQueue<String> blockingQueue = new LinkedBlockingQueue<>(10);
// 向隊列中插入元素
blockingQueue.put("Element 1");
blockingQueue.put("Element 2");
// 從隊列中獲取元素
String element = blockingQueue.take();
System.out.println(element);
}
}
以上是兩種常用的BlockingQueue實現方式,根據需求選擇適合的實現方式。