在Java中,可以使用java.util.concurrent
包中的ArrayBlockingQueue
或LinkedBlockingQueue
類來實現具有容量限制的隊列。這兩個類都允許你在創建隊列時指定最大容量。
以下是如何使用ArrayBlockingQueue
和LinkedBlockingQueue
創建具有容量限制的隊列的示例:
ArrayBlockingQueue
:import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
public class Main {
public static void main(String[] args) {
int capacity = 5; // 設置隊列容量
BlockingQueue<Integer> queue = new ArrayBlockingQueue<>(capacity);
// 向隊列中添加元素
try {
queue.put(1);
queue.put(2);
queue.put(3);
} catch (InterruptedException e) {
e.printStackTrace();
}
// 從隊列中移除并返回元素
try {
System.out.println(queue.take());
System.out.println(queue.take());
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
LinkedBlockingQueue
:import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.BlockingQueue;
public class Main {
public static void main(String[] args) {
int capacity = 5; // 設置隊列容量
BlockingQueue<Integer> queue = new LinkedBlockingQueue<>(capacity);
// 向隊列中添加元素
try {
queue.put(1);
queue.put(2);
queue.put(3);
} catch (InterruptedException e) {
e.printStackTrace();
}
// 從隊列中移除并返回元素
try {
System.out.println(queue.take());
System.out.println(queue.take());
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
在這兩個示例中,我們創建了一個容量為5的隊列。當隊列滿時,put()
方法將阻塞,直到隊列中有空閑空間。當隊列為空時,take()
方法將阻塞,直到隊列中有可用元素。這樣可以確保隊列的容量不會超過指定的限制。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。