{"id":15896,"date":"2026-04-25T16:40:13","date_gmt":"2026-04-25T08:40:13","guid":{"rendered":"https:\/\/top.duoku.icu\/libs\/15896.html"},"modified":"2026-04-25T19:09:07","modified_gmt":"2026-04-25T11:09:07","slug":"java-%e9%98%9f%e5%88%97%e8%af%a6%e7%bb%86%e4%bd%bf%e7%94%a8%e6%95%99%e7%a8%8b%ef%bc%9a%e4%bb%8e%e5%9f%ba%e7%a1%80%e5%88%b0%e5%b9%b6%e5%8f%91","status":"publish","type":"post","link":"https:\/\/www.srclibs.com\/index.php\/2026\/04\/25\/java-%e9%98%9f%e5%88%97%e8%af%a6%e7%bb%86%e4%bd%bf%e7%94%a8%e6%95%99%e7%a8%8b%ef%bc%9a%e4%bb%8e%e5%9f%ba%e7%a1%80%e5%88%b0%e5%b9%b6%e5%8f%91\/","title":{"rendered":"Java \u961f\u5217\u8be6\u7ec6\u4f7f\u7528\u6559\u7a0b\uff1a\u4ece\u57fa\u7840\u5230\u5e76\u53d1"},"content":{"rendered":"
\"Java<\/div>\n

Java \u961f\u5217\u8be6\u7ec6\u4f7f\u7528\u6559\u7a0b<\/h1>\n

\u4e00\u3001Java \u961f\u5217\u7b80\u4ecb\u548c\u6838\u5fc3\u6982\u5ff5<\/h2>\n

Java \u961f\u5217<\/strong>\u662f Java \u96c6\u5408\u6846\u67b6\u7684\u91cd\u8981\u7ec4\u6210\u90e8\u5206\uff0c\u63d0\u4f9b\u4e86\u9ad8\u6548\u7684 FIFO\uff08\u5148\u8fdb\u5148\u51fa\uff09\u6570\u636e\u7ed3\u6784\u3002<\/p>\n

\u6838\u5fc3\u63a5\u53e3<\/h3>\n\n\n\n\n\n\n
\u63a5\u53e3<\/th>\n\u8bf4\u660e<\/th>\n<\/tr>\n
Queue<\/strong><\/td>\n\u57fa\u7840\u961f\u5217\u63a5\u53e3\uff0c\u63d0\u4f9b FIFO \u64cd\u4f5c<\/td>\n<\/tr>\n
Deque<\/strong><\/td>\n\u53cc\u7aef\u961f\u5217\u63a5\u53e3\uff0c\u652f\u6301\u4e24\u7aef\u63d2\u5165\u548c\u5220\u9664<\/td>\n<\/tr>\n
BlockingQueue<\/strong><\/td>\n\u963b\u585e\u961f\u5217\u63a5\u53e3\uff0c\u7ebf\u7a0b\u5b89\u5168\u7684\u961f\u5217<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n

Queue \u6838\u5fc3\u65b9\u6cd5<\/h3>\n

| \u65b9\u6cd5 | \u884c\u4e3a |
|——|——|
| `add(e)` | \u6dfb\u52a0\u5143\u7d20\uff0c\u5931\u8d25\u629b\u5f02\u5e38 |
| `offer(e)` | \u6dfb\u52a0\u5143\u7d20\uff0c\u5931\u8d25\u8fd4\u56de false |
| `remove()` | \u79fb\u9664\u5143\u7d20\uff0c\u5931\u8d25\u629b\u5f02\u5e38 |
| `poll()` | \u79fb\u9664\u5143\u7d20\uff0c\u5931\u8d25\u8fd4\u56de null |
| `element()` | \u83b7\u53d6\u5143\u7d20\uff0c\u5931\u8d25\u629b\u5f02\u5e38 |
| `peek()` | \u83b7\u53d6\u5143\u7d20\uff0c\u5931\u8d25\u8fd4\u56de null |<\/p>\n

\u4e8c\u3001LinkedList \u961f\u5217\u4f7f\u7528<\/h2>\n

“`java
import java.util.LinkedList;
import java.util.Queue;<\/p>\n

public class LinkedListQueueExample {
public static void main(String[] args) {
Queue queue = new LinkedList<>();<\/p>\n

queue.offer(“A”);
queue.offer(“B”);
queue.offer(“C”);
System.out.println(“Queue: ” + queue);<\/p>\n

String first = queue.peek();
System.out.println(“First: ” + first);<\/p>\n

String removed = queue.poll();
System.out.println(“Removed: ” + removed);
System.out.println(“Size: ” + queue.size());
}
}<\/p>\n

<\/code><\/pre>\n
\u4e09\u3001ArrayDeque \u961f\u5217\u4f7f\u7528<\/h2>\n
<\/code><\/pre>\n
\u00a0<\/p>\n
<\/code><\/pre>\n
java
import java.util.ArrayDeque;
import java.util.Deque;<\/p>\n
public class ArrayDequeExample {
public static void main(String[] args) {
Deque deque = new ArrayDeque<>();<\/p>\n
deque.offerLast(“A”);
deque.offerLast(“B”);
deque.offerFirst(“X”);
deque.offerFirst(“Y”);<\/p>\n
System.out.println(“Deque: ” + deque);<\/p>\n
String last = deque.pollLast();
String first = deque.pollFirst();<\/p>\n
System.out.println(“Last: ” + last);
System.out.println(“First: ” + first);
}
}<\/p>\n
<\/code><\/pre>\n
\u56db\u3001PriorityQueue \u4f18\u5148\u961f\u5217<\/h2>\n
<\/code><\/pre>\n
\u00a0<\/p>\n
<\/code><\/pre>\n
\u81ea\u7136\u6392\u5e8f<\/h3>\n
<\/code><\/pre>\n
\u00a0<\/p>\n
<\/code><\/pre>\n
java
import java.util.PriorityQueue;
import java.util.Queue;<\/p>\n
public class PriorityQueueExample {
public static void main(String[] args) {
Queue queue = new PriorityQueue<>();<\/p>\n
queue.offer(5);
queue.offer(2);
queue.offer(8);
queue.offer(1);
queue.offer(9);<\/p>\n
while (!queue.isEmpty()) {
System.out.println(“Poll: ” + queue.poll());
}
}
}<\/p>\n
<\/code><\/pre>\n
\u81ea\u5b9a\u4e49\u4f18\u5148\u7ea7<\/h3>\n
<\/code><\/pre>\n
\u00a0<\/p>\n
<\/code><\/pre>\n
java
class Task implements Comparable {
private String name;
private int priority;<\/p>\n
public Task(String name, int priority) {
this.name = name;
this.priority = priority;
}<\/p>\n
@Override
public int compareTo(Task other) {
return Integer.compare(other.priority, this.priority);
}<\/p>\n
public String toString() {
return “Task{name='” + name + “‘, priority=” + priority + “}”;
}
}<\/p>\n
public class CustomPriorityQueue {
public static void main(String[] args) {
Queue taskQueue = new PriorityQueue<>();<\/p>\n
taskQueue.offer(new Task(“\u4f4e\u4f18\u5148\u7ea7”, 1));
taskQueue.offer(new Task(“\u9ad8\u4f18\u5148\u7ea7”, 10));
taskQueue.offer(new Task(“\u4e2d\u4f18\u5148\u7ea7”, 5));<\/p>\n
while (!taskQueue.isEmpty()) {
System.out.println(“Processing: ” + taskQueue.poll());
}
}
}<\/p>\n
<\/code><\/pre>\n
\u4e94\u3001BlockingQueue \u963b\u585e\u961f\u5217<\/h2>\n
<\/code><\/pre>\n
\u00a0<\/p>\n
<\/code><\/pre>\n
ArrayBlockingQueue<\/h3>\n
<\/code><\/pre>\n
\u00a0<\/p>\n
<\/code><\/pre>\n
java
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;<\/p>\n
public class ArrayBlockingQueueExample {
public static void main(String[] args) throws InterruptedException {
BlockingQueue queue = new ArrayBlockingQueue<>(5);<\/p>\n
queue.put(“A”);
queue.put(“B”);
queue.put(“C”);<\/p>\n
System.out.println(“Size: ” + queue.size());<\/p>\n
String item = queue.take();
System.out.println(“Taken: ” + item);
}
}<\/p>\n
<\/code><\/pre>\n
LinkedBlockingQueue<\/h3>\n
<\/code><\/pre>\n
\u00a0<\/p>\n
<\/code><\/pre>\n
java
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;<\/p>\n
public class LinkedBlockingQueueExample {
public static void main(String[] args) throws InterruptedException {
BlockingQueue queue = new LinkedBlockingQueue<>();<\/p>\n
queue.offer(“A”);
queue.offer(“B”);
queue.offer(“C”);<\/p>\n
System.out.println(“Poll: ” + queue.poll());
System.out.println(“Poll: ” + queue.poll());
}
}<\/p>\n
<\/code><\/pre>\n
DelayQueue<\/h3>\n
<\/code><\/pre>\n
\u00a0<\/p>\n
<\/code><\/pre>\n
java
import java.util.concurrent.DelayQueue;
import java.util.concurrent.Delayed;
import java.util.concurrent.TimeUnit;<\/p>\n
class DelayedTask implements Delayed {
private String name;
private long delayTime;<\/p>\n
public DelayedTask(String name, long delay, TimeUnit unit) {
this.name = name;
this.delayTime = System.currentTimeMillis() + unit.toMillis(delay);
}<\/p>\n
@Override
public long getDelay(TimeUnit unit) {
return unit.convert(delayTime – System.currentTimeMillis(), TimeUnit.MILLISECONDS);
}<\/p>\n
@Override
public int compareTo(Delayed other) {
return Long.compare(this.delayTime, ((DelayedTask) other).delayTime);
}
}<\/p>\n
public class DelayQueueExample {
public static void main(String[] args) throws InterruptedException {
DelayQueue queue = new DelayQueue<>();<\/p>\n
queue.put(new DelayedTask(“Task 1”, 2, TimeUnit.SECONDS));
queue.put(new DelayedTask(“Task 2”, 1, TimeUnit.SECONDS));<\/p>\n
while (!queue.isEmpty()) {
DelayedTask task = queue.take();
System.out.println(“Processing: ” + task.getName());
}
}
}<\/p>\n
<\/code><\/pre>\n
\u516d\u3001ConcurrentLinkedQueue \u5e76\u53d1\u961f\u5217<\/h2>\n
<\/code><\/pre>\n
\u00a0<\/p>\n
<\/code><\/pre>\n
java
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.Iterator;<\/p>\n
public class ConcurrentLinkedQueueExample {
public static void main(String[] args) {
ConcurrentLinkedQueue queue = new ConcurrentLinkedQueue<>();<\/p>\n
for (int i = 0; i < 10; i++) {
queue.offer(“Item-” + i);
}<\/p>\n
Iterator iterator = queue.iterator();
while (iterator.hasNext()) {
System.out.println(“Item: ” + iterator.next());
}
}
}<\/p>\n
<\/code><\/pre>\n
\u4e03\u3001\u751f\u4ea7\u8005\u548c\u6d88\u8d39\u8005\u6a21\u5f0f<\/h2>\n
<\/code><\/pre>\n
\u00a0<\/p>\n
<\/code><\/pre>\n
java
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;<\/p>\n
class ProducerConsumer {
private final BlockingQueue queue = new LinkedBlockingQueue<>(10);<\/p>\n
class Producer implements Runnable {
private int id;<\/p>\n
public Producer(int id) {
this.id = id;
}<\/p>\n
@Override
public void run() {
try {
for (int i = 0; i < 5; i++) {
int item = id * 10 + i;
queue.put(item);
System.out.println(“Produced: ” + item);
Thread.sleep(100);
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}<\/p>\n
class Consumer implements Runnable {
@Override
public void run() {
try {
while (true) {
int item = queue.take();
System.out.println(“Consumed: ” + item);
if (item % 50 == 0 && item != 0) {
break;
}
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}<\/p>\n
public class Main {
public static void main(String[] args) throws InterruptedException {
ProducerConsumer pc = new ProducerConsumer();<\/p>\n
Thread p1 = new Thread(pc.new Producer(1));
Thread p2 = new Thread(pc.new Producer(2));
Thread c = new Thread(pc.new Consumer());<\/p>\n
p1.start();
p2.start();
c.start();<\/p>\n
p1.join();
p2.join();
c.join();
}
}<\/p>\n
<\/code><\/pre>\n
\u516b\u3001\u961f\u5217\u9009\u62e9\u6700\u4f73\u5b9e\u8df5<\/h2>\n
<\/code><\/pre>\n
\u00a0<\/p>\n
<\/code><\/pre>\n
\u9009\u62e9\u6307\u5357<\/h3>\n
<\/code><\/pre>\n
| \u573a\u666f | \u63a8\u8350\u961f\u5217 | \u539f\u56e0 | |——|———-|——| | \u5355\u7ebf\u7a0b FIFO | LinkedList | \u7b80\u5355\u3001\u9ad8\u6548 | | \u53cc\u7aef\u64cd\u4f5c | ArrayDeque | \u6027\u80fd\u66f4\u597d | | \u4f18\u5148\u7ea7\u5904\u7406 | PriorityQueue | \u81ea\u52a8\u6392\u5e8f | | \u591a\u7ebf\u7a0b\u540c\u6b65 | BlockingQueue | \u7ebf\u7a0b\u5b89\u5168 | | \u9ad8\u5e76\u53d1\u65e0\u754c | ConcurrentLinkedQueue | \u65e0\u9501\u9ad8\u6027\u80fd |<\/p>\n
<\/code><\/pre>\n
\u4f7f\u7528\u5efa\u8bae<\/h3>\n
<\/code><\/pre>\n
\u00a0<\/p>\n
<\/code><\/pre>\n
java
\/\/ \u2705 \u63a8\u8350\uff1a\u4f7f\u7528\u63a5\u53e3\u7c7b\u578b
Queue queue = new ArrayBlockingQueue<>(10);
Queue queue = new PriorityQueue<>();<\/p>\n
\/\/ \u274c \u4e0d\u63a8\u8350\uff1a\u4f7f\u7528\u5b9e\u73b0\u7c7b
ArrayBlockingQueue queue = new ArrayBlockingQueue<>(10);<\/p>\n
\/\/ \u2705 \u63a8\u8350\uff1a\u8bbe\u7f6e\u5408\u7406\u5bb9\u91cf
BlockingQueue queue = new ArrayBlockingQueue<>(100);<\/p>\n
\/\/ \u274c \u4e0d\u63a8\u8350\uff1a\u65e0\u754c\u961f\u5217\u5bfc\u81f4 OOM
BlockingQueue queue = new LinkedBlockingQueue<>();<\/p>\n
\/\/ \u2705 \u63a8\u8350\uff1a\u5904\u7406\u963b\u585e\u5f02\u5e38
try {
queue.take();
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}<\/p>\n
\/\/ \u2705 \u63a8\u8350\uff1a\u4f7f\u7528\u8d85\u65f6
boolean added = queue.offer(item, 5, TimeUnit.SECONDS);
“`<\/p>\n
—<\/p>\n
\u603b\u7ed3<\/h2>\n
\u672c\u6587\u6db5\u76d6\u4e86 Java \u961f\u5217\u7684\uff1a<\/p>\n
    \n
  • \u2705 \u6838\u5fc3\u6982\u5ff5<\/strong> – Queue\u3001Deque\u3001BlockingQueue<\/li>\n
  • \u2705 LinkedList \u961f\u5217<\/strong> – \u57fa\u7840\u961f\u5217\u4f7f\u7528<\/li>\n
  • \u2705 ArrayDeque \u961f\u5217<\/strong> – \u53cc\u7aef\u961f\u5217\u64cd\u4f5c<\/li>\n
  • \u2705 PriorityQueue<\/strong> – \u4f18\u5148\u961f\u5217\u4f7f\u7528<\/li>\n
  • \u2705 BlockingQueue<\/strong> – \u963b\u585e\u961f\u5217\u5b9e\u73b0<\/li>\n
  • \u2705 ConcurrentLinkedQueue<\/strong> – \u5e76\u53d1\u961f\u5217<\/li>\n
  • \u2705 \u751f\u4ea7\u6d88\u8d39<\/strong> – \u751f\u4ea7\u8005\u6d88\u8d39\u8005\u6a21\u5f0f<\/li>\n
  • \u2705 \u6700\u4f73\u5b9e\u8df5<\/strong> – \u961f\u5217\u9009\u62e9\u5efa\u8bae<\/li>\n<\/ul>\n
    \n
    #Java #\u961f\u5217 #\u5e76\u53d1 #\u591a\u7ebf\u7a0b #\u96c6\u5408\u6846\u67b6<\/p>\n<\/div>\n
    —<\/p>\n
    \u6587\u7ae0\u5df2\u5b8c\u6210\uff01<\/strong><\/p>\n
    \u6587\u4ef6\u8def\u5f84\uff1a<\/strong> `\/home\/node\/.openclaw\/agents\/creator\/workspace\/content\/Java \u961f\u5217\u8be6\u7ec6\u4f7f\u7528\u6559\u7a0b_20260425_1621.md`<\/p>\n
    \u8bf7\u544a\u8bc9\u6211\u4e0b\u4e00\u6b65\u64cd\u4f5c\uff08\u914d\u56fe\u3001\u53d1\u5e03\u7b49\uff09\uff01<\/p>\n","protected":false},"excerpt":{"rendered":"
    Java \u961f\u5217\u8be6\u7ec6\u4f7f\u7528\u6559\u7a0b \u4e00\u3001Java \u961f\u5217\u7b80\u4ecb\u548c\u6838\u5fc3\u6982\u5ff5 Java \u961f\u5217\u662f Java \u96c6\u5408\u6846\u67b6\u7684\u91cd\u8981\u7ec4\u6210\u90e8…<\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[],"tags":[],"class_list":["post-15896","post","type-post","status-publish","format-standard","hentry"],"_links":{"self":[{"href":"https:\/\/www.srclibs.com\/index.php\/wp-json\/wp\/v2\/posts\/15896","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.srclibs.com\/index.php\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.srclibs.com\/index.php\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.srclibs.com\/index.php\/wp-json\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"https:\/\/www.srclibs.com\/index.php\/wp-json\/wp\/v2\/comments?post=15896"}],"version-history":[{"count":1,"href":"https:\/\/www.srclibs.com\/index.php\/wp-json\/wp\/v2\/posts\/15896\/revisions"}],"predecessor-version":[{"id":15897,"href":"https:\/\/www.srclibs.com\/index.php\/wp-json\/wp\/v2\/posts\/15896\/revisions\/15897"}],"wp:attachment":[{"href":"https:\/\/www.srclibs.com\/index.php\/wp-json\/wp\/v2\/media?parent=15896"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.srclibs.com\/index.php\/wp-json\/wp\/v2\/categories?post=15896"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.srclibs.com\/index.php\/wp-json\/wp\/v2\/tags?post=15896"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}