{"id":3894,"date":"2025-07-13T11:48:49","date_gmt":"2025-07-13T03:48:49","guid":{"rendered":"https:\/\/www.laixuexila.com\/?p=3894"},"modified":"2025-07-13T11:48:49","modified_gmt":"2025-07-13T03:48:49","slug":"%e5%9f%ba%e4%ba%8e%e6%95%b0%e7%bb%84%e7%9a%84%e9%98%bb%e5%a1%9e%e9%98%9f%e5%88%97-arrayblockingqueue-%e5%8e%9f%e7%90%86","status":"publish","type":"post","link":"https:\/\/www.laixuexila.com\/index.php\/2025\/07\/13\/%e5%9f%ba%e4%ba%8e%e6%95%b0%e7%bb%84%e7%9a%84%e9%98%bb%e5%a1%9e%e9%98%9f%e5%88%97-arrayblockingqueue-%e5%8e%9f%e7%90%86\/","title":{"rendered":"\u57fa\u4e8e\u6570\u7ec4\u7684\u963b\u585e\u961f\u5217 ArrayBlockingQueue \u539f\u7406"},"content":{"rendered":"\n<p><code>ArrayBlockingQueue<\/code> \u662f Java \u5e76\u53d1\u5305 <code>java.util.concurrent<\/code> \u4e2d\u4e00\u4e2a\u91cd\u8981\u7684<strong>\u6709\u754c\u963b\u585e\u961f\u5217<\/strong>\u5b9e\u73b0\uff0c\u5b83\u57fa\u4e8e\u4e00\u4e2a<strong>\u6570\u7ec4\u7ed3\u6784<\/strong>\u6784\u5efa\uff0c\u5e7f\u6cdb\u7528\u4e8e<strong>\u751f\u4ea7\u8005-\u6d88\u8d39\u8005\u6a21\u578b<\/strong>\u7b49\u591a\u7ebf\u7a0b\u73af\u5883\u3002<\/p>\n\n\n\n<hr class=\"wp-block-separator has-alpha-channel-opacity\"\/>\n\n\n\n<h2 class=\"wp-block-heading\">\u4e00\u3001\u57fa\u672c\u6982\u5ff5\u7b80\u4ecb<\/h2>\n\n\n\n<ul class=\"wp-block-list\">\n<li><strong>\u7c7b\u540d<\/strong>\uff1a<code>java.util.concurrent.ArrayBlockingQueue&lt;E><\/code><\/li>\n\n\n\n<li><strong>\u7ed3\u6784<\/strong>\uff1a\u57fa\u4e8e\u6570\u7ec4\u7684\u5faa\u73af\u961f\u5217\uff08\u56fa\u5b9a\u5927\u5c0f\uff0c\u6709\u754c\uff09<\/li>\n\n\n\n<li><strong>\u7279\u6027<\/strong>\uff1a\n<ul class=\"wp-block-list\">\n<li>\u7ebf\u7a0b\u5b89\u5168\uff08\u4f7f\u7528\u91cd\u5165\u9501 ReentrantLock\uff09<\/li>\n\n\n\n<li>\u652f\u6301\u963b\u585e\u7684 <code>put()<\/code> \/ <code>take()<\/code> \u65b9\u6cd5<\/li>\n\n\n\n<li>\u652f\u6301\u516c\u5e73\u6027\u7b56\u7565\uff08FIFO\uff0c\u53ef\u9009\u516c\u5e73\u9501\uff09<\/li>\n<\/ul>\n<\/li>\n<\/ul>\n\n\n\n<hr class=\"wp-block-separator has-alpha-channel-opacity\"\/>\n\n\n\n<h2 class=\"wp-block-heading\">\u4e8c\u3001\u6838\u5fc3\u6784\u9020\u4e0e\u53c2\u6570<\/h2>\n\n\n\n<pre class=\"wp-block-code\"><code>public ArrayBlockingQueue(int capacity, boolean fair)<\/code><\/pre>\n\n\n\n<figure class=\"wp-block-table\"><table class=\"has-fixed-layout\"><thead><tr><th>\u53c2\u6570<\/th><th>\u542b\u4e49<\/th><\/tr><\/thead><tbody><tr><td>capacity<\/td><td>\u961f\u5217\u5bb9\u91cf\uff08\u56fa\u5b9a\u5927\u5c0f\uff09<\/td><\/tr><tr><td>fair<\/td><td>\u662f\u5426\u4f7f\u7528\u516c\u5e73\u9501\uff08\u53ef\u9009\uff09<\/td><\/tr><\/tbody><\/table><\/figure>\n\n\n\n<blockquote class=\"wp-block-quote is-layout-flow wp-block-quote-is-layout-flow\">\n<p>\u9ed8\u8ba4\u662f\u975e\u516c\u5e73\u7684\u9501\uff0c\u6027\u80fd\u66f4\u9ad8\uff0c\u516c\u5e73\u6a21\u5f0f\u4e0b\u7ebf\u7a0b\u6309\u5148\u5230\u5148\u670d\u52a1\uff08FIFO\uff09\u6392\u961f\u3002<\/p>\n<\/blockquote>\n\n\n\n<hr class=\"wp-block-separator has-alpha-channel-opacity\"\/>\n\n\n\n<h2 class=\"wp-block-heading\">\u4e09\u3001\u5e95\u5c42\u6838\u5fc3\u7ec4\u6210<\/h2>\n\n\n\n<h3 class=\"wp-block-heading\">\u6e90\u7801\u7c7b\u56fe\u7ed3\u6784\uff1a<\/h3>\n\n\n\n<pre class=\"wp-block-code\"><code>ArrayBlockingQueue&lt;E&gt;\n\u251c\u2500\u2500 Object&#91;] items       \/\/ \u5e95\u5c42\u6570\u636e\u5b58\u50a8\u6570\u7ec4\uff08\u5faa\u73af\u4f7f\u7528\uff09\n\u251c\u2500\u2500 int count            \/\/ \u5f53\u524d\u961f\u5217\u5143\u7d20\u6570\u91cf\n\u251c\u2500\u2500 int putIndex         \/\/ \u5199\u5165\u7d22\u5f15\n\u251c\u2500\u2500 int takeIndex        \/\/ \u8bfb\u53d6\u7d22\u5f15\n\u251c\u2500\u2500 ReentrantLock lock   \/\/ \u5168\u5c40\u91cd\u5165\u9501\uff08\u4fdd\u62a4\u6240\u6709\u64cd\u4f5c\uff09\n\u251c\u2500\u2500 Condition notEmpty   \/\/ \u6d88\u8d39\u8005\u7b49\u5f85\u6761\u4ef6\n\u251c\u2500\u2500 Condition notFull    \/\/ \u751f\u4ea7\u8005\u7b49\u5f85\u6761\u4ef6<\/code><\/pre>\n\n\n\n<blockquote class=\"wp-block-quote is-layout-flow wp-block-quote-is-layout-flow\">\n<p>\u4f7f\u7528 <strong>\u5faa\u73af\u6570\u7ec4<\/strong> + <strong>\u53cc Condition<\/strong> + <strong>\u9501\u673a\u5236<\/strong> \u4fdd\u8bc1\u7ebf\u7a0b\u5b89\u5168\u3002<\/p>\n<\/blockquote>\n\n\n\n<hr class=\"wp-block-separator has-alpha-channel-opacity\"\/>\n\n\n\n<h2 class=\"wp-block-heading\">\u56db\u3001\u6838\u5fc3\u65b9\u6cd5\u539f\u7406\u5206\u6790<\/h2>\n\n\n\n<h3 class=\"wp-block-heading\">1. <code>put(E e)<\/code>\uff1a\u963b\u585e\u5f0f\u5165\u961f<\/h3>\n\n\n\n<pre class=\"wp-block-code\"><code>public void put(E e) throws InterruptedException {\n    final ReentrantLock lock = this.lock;\n    lock.lockInterruptibly();\n    try {\n        while (count == items.length)\n            notFull.await();  \/\/ \u961f\u5217\u6ee1\u4e86\uff0c\u7b49\u5f85\n        enqueue(e);\n    } finally {\n        lock.unlock();\n    }\n}<\/code><\/pre>\n\n\n\n<h4 class=\"wp-block-heading\">enqueue() \u903b\u8f91\uff1a<\/h4>\n\n\n\n<pre class=\"wp-block-code\"><code>void enqueue(E e) {\n    items&#91;putIndex] = e;\n    putIndex = (putIndex + 1) % items.length;\n    count++;\n    notEmpty.signal(); \/\/ \u901a\u77e5\u7b49\u5f85\u7684\u6d88\u8d39\u8005\u7ebf\u7a0b\n}<\/code><\/pre>\n\n\n\n<blockquote class=\"wp-block-quote is-layout-flow wp-block-quote-is-layout-flow\">\n<p>\u82e5\u961f\u5217\u5df2\u6ee1\uff0c\u5219\u963b\u585e\u7b49\u5f85 <code>notFull.await()<\/code>\uff0c\u76f4\u5230\u6709\u7a7a\u4f4d\u3002<\/p>\n<\/blockquote>\n\n\n\n<hr class=\"wp-block-separator has-alpha-channel-opacity\"\/>\n\n\n\n<h3 class=\"wp-block-heading\">2. <code>take()<\/code>\uff1a\u963b\u585e\u5f0f\u51fa\u961f<\/h3>\n\n\n\n<pre class=\"wp-block-code\"><code>public E take() throws InterruptedException {\n    final ReentrantLock lock = this.lock;\n    lock.lockInterruptibly();\n    try {\n        while (count == 0)\n            notEmpty.await();  \/\/ \u961f\u5217\u7a7a\uff0c\u7b49\u5f85\u751f\u4ea7\u8005\n        return dequeue();\n    } finally {\n        lock.unlock();\n    }\n}<\/code><\/pre>\n\n\n\n<h4 class=\"wp-block-heading\">dequeue() \u903b\u8f91\uff1a<\/h4>\n\n\n\n<pre class=\"wp-block-code\"><code>E dequeue() {\n    E e = items&#91;takeIndex];\n    items&#91;takeIndex] = null;\n    takeIndex = (takeIndex + 1) % items.length;\n    count--;\n    notFull.signal();  \/\/ \u901a\u77e5\u7b49\u5f85\u7684\u751f\u4ea7\u8005\u7ebf\u7a0b\n    return e;\n}<\/code><\/pre>\n\n\n\n<blockquote class=\"wp-block-quote is-layout-flow wp-block-quote-is-layout-flow\">\n<p>\u82e5\u961f\u5217\u4e3a\u7a7a\uff0c\u5219\u963b\u585e\u7b49\u5f85 <code>notEmpty.await()<\/code>\uff0c\u76f4\u5230\u6709\u6570\u636e\u53ef\u53d6\u3002<\/p>\n<\/blockquote>\n\n\n\n<hr class=\"wp-block-separator has-alpha-channel-opacity\"\/>\n\n\n\n<h2 class=\"wp-block-heading\">\u4e94\u3001ArrayBlockingQueue \u7684\u6838\u5fc3\u7279\u6027\u603b\u7ed3<\/h2>\n\n\n\n<figure class=\"wp-block-table\"><table class=\"has-fixed-layout\"><thead><tr><th>\u7279\u6027<\/th><th>\u8bf4\u660e<\/th><\/tr><\/thead><tbody><tr><td>\u6709\u754c\u963b\u585e<\/td><td>\u6784\u9020\u65f6\u5fc5\u987b\u6307\u5b9a\u5bb9\u91cf\uff0c\u6ee1\u65f6\u963b\u585e\u751f\u4ea7\u8005\uff0c\u7a7a\u65f6\u963b\u585e\u6d88\u8d39\u8005<\/td><\/tr><tr><td>\u5faa\u73af\u6570\u7ec4\u7ed3\u6784<\/td><td>\u4f7f\u7528\u56fa\u5b9a\u5927\u5c0f\u7684\u6570\u7ec4 + \u5faa\u73af\u6307\u9488 <code>putIndex<\/code> \u548c <code>takeIndex<\/code> \u7ba1\u7406\u961f\u5217\u4f4d\u7f6e<\/td><\/tr><tr><td>\u7ebf\u7a0b\u5b89\u5168<\/td><td>\u6240\u6709\u8bbf\u95ee\u53d7 <code>ReentrantLock<\/code> \u4fdd\u8bc1<\/td><\/tr><tr><td>\u6761\u4ef6\u53d8\u91cf<\/td><td>\u4f7f\u7528\u4e24\u4e2a <code>Condition<\/code> \u5206\u522b\u5524\u9192\u751f\u4ea7\u8005\uff08notFull\uff09\u548c\u6d88\u8d39\u8005\uff08notEmpty\uff09<\/td><\/tr><tr><td>\u516c\u5e73\u6027\u53ef\u9009<\/td><td>\u53ef\u9009\u516c\u5e73\u9501\u6a21\u5f0f\uff0c\u9ed8\u8ba4\u975e\u516c\u5e73\uff08\u6027\u80fd\u66f4\u9ad8\uff09<\/td><\/tr><\/tbody><\/table><\/figure>\n\n\n\n<hr class=\"wp-block-separator has-alpha-channel-opacity\"\/>\n\n\n\n<h2 class=\"wp-block-heading\">\u516d\u3001\u5178\u578b\u4f7f\u7528\u573a\u666f\uff08\u591a\u7ebf\u7a0b\u7f16\u7a0b\uff09<\/h2>\n\n\n\n<ul class=\"wp-block-list\">\n<li>\u751f\u4ea7\u8005-\u6d88\u8d39\u8005\u6a21\u578b\uff08\u7ebf\u7a0b\u6c60\u3001\u4efb\u52a1\u8c03\u5ea6\uff09<\/li>\n\n\n\n<li>\u9650\u6d41\uff08\u5bb9\u91cf\u9650\u5236\uff09<\/li>\n\n\n\n<li>\u63a7\u5236\u8d44\u6e90\u7ade\u4e89<\/li>\n\n\n\n<li>\u65e5\u5fd7\u5f02\u6b65\u5904\u7406<\/li>\n<\/ul>\n\n\n\n<h3 class=\"wp-block-heading\">\u4ee3\u7801\u793a\u4f8b\uff1a<\/h3>\n\n\n\n<pre class=\"wp-block-code\"><code>BlockingQueue&lt;Integer&gt; queue = new ArrayBlockingQueue&lt;&gt;(10);\n\nRunnable producer = () -&gt; {\n    try {\n        for (int i = 0; i &lt; 100; i++) {\n            queue.put(i); \/\/ \u5982\u679c\u961f\u5217\u6ee1\u5219\u963b\u585e\n            System.out.println(\"Produced: \" + i);\n        }\n    } catch (InterruptedException e) {}\n};\n\nRunnable consumer = () -&gt; {\n    try {\n        while (true) {\n            Integer val = queue.take(); \/\/ \u5982\u679c\u961f\u5217\u7a7a\u5219\u963b\u585e\n            System.out.println(\"Consumed: \" + val);\n        }\n    } catch (InterruptedException e) {}\n};\n\nnew Thread(producer).start();\nnew Thread(consumer).start();<\/code><\/pre>\n\n\n\n<hr class=\"wp-block-separator has-alpha-channel-opacity\"\/>\n\n\n\n<h2 class=\"wp-block-heading\">\u4e03\u3001\u548c\u5176\u4ed6\u961f\u5217\u5bf9\u6bd4\uff08\u9762\u8bd5\u5e38\u95ee\uff09<\/h2>\n\n\n\n<figure class=\"wp-block-table\"><table class=\"has-fixed-layout\"><thead><tr><th>\u961f\u5217\u7c7b\u578b<\/th><th>\u5e95\u5c42\u7ed3\u6784<\/th><th>\u662f\u5426\u6709\u754c<\/th><th>\u662f\u5426\u963b\u585e<\/th><th>\u662f\u5426\u7ebf\u7a0b\u5b89\u5168<\/th><th>\u7279\u70b9<\/th><\/tr><\/thead><tbody><tr><td><code>ArrayBlockingQueue<\/code><\/td><td>\u6570\u7ec4\uff08\u5faa\u73af\uff09<\/td><td>\u2705 \u662f<\/td><td>\u2705 \u662f<\/td><td>\u2705 \u662f<\/td><td>\u56fa\u5b9a\u5bb9\u91cf\uff0c\u6027\u80fd\u9ad8\uff0c\u7ed3\u6784\u7b80\u5355<\/td><\/tr><tr><td><code>LinkedBlockingQueue<\/code><\/td><td>\u94fe\u8868<\/td><td>\u2705\/\u274c \u662f<\/td><td>\u2705 \u662f<\/td><td>\u2705 \u662f<\/td><td>\u652f\u6301\u65e0\u754c\uff0c\u9002\u5408\u9ad8\u5e76\u53d1\u573a\u666f<\/td><\/tr><tr><td><code>SynchronousQueue<\/code><\/td><td>\u65e0\u5b58\u50a8<\/td><td>\u274c \u5426<\/td><td>\u2705 \u662f<\/td><td>\u2705 \u662f<\/td><td>\u6bcf\u6b21 put \u5fc5\u987b\u7b49 take<\/td><\/tr><tr><td><code>PriorityBlockingQueue<\/code><\/td><td>\u5806<\/td><td>\u2705 \u662f<\/td><td>\u2705 \u662f<\/td><td>\u2705 \u662f<\/td><td>\u5143\u7d20\u6309\u4f18\u5148\u7ea7\u81ea\u52a8\u6392\u5e8f<\/td><\/tr><\/tbody><\/table><\/figure>\n\n\n\n<hr class=\"wp-block-separator has-alpha-channel-opacity\"\/>\n\n\n\n<h2 class=\"wp-block-heading\">\u516b\u3001\u6743\u5a01\u53c2\u8003\u6587\u6863<\/h2>\n\n\n\n<ul class=\"wp-block-list\">\n<li>\ud83d\udcd8 <a href=\"https:\/\/docs.oracle.com\/en\/java\/javase\/17\/docs\/api\/java.base\/java\/util\/concurrent\/ArrayBlockingQueue.html\">JDK \u5b98\u65b9 API \u6587\u6863<\/a><\/li>\n\n\n\n<li>\ud83d\udcd8 <a href=\"https:\/\/github.com\/openjdk\/jdk\/blob\/master\/src\/java.base\/share\/classes\/java\/util\/concurrent\/ArrayBlockingQueue.java\">OpenJDK \u6e90\u7801 ArrayBlockingQueue.java<\/a><\/li>\n\n\n\n<li>\ud83d\udcd8 \u4e66\u7c4d\uff1a\u300aJava \u5e76\u53d1\u7f16\u7a0b\u5b9e\u6218\u300b\uff08Java Concurrency in Practice\uff09<\/li>\n<\/ul>\n\n\n\n<hr class=\"wp-block-separator has-alpha-channel-opacity\"\/>\n\n\n\n<h2 class=\"wp-block-heading\">\u4e5d\u3001\u603b\u7ed3\uff08\u9762\u8bd5\/\u9879\u76ee\uff09<\/h2>\n\n\n\n<figure class=\"wp-block-table\"><table class=\"has-fixed-layout\"><thead><tr><th>\u7ef4\u5ea6<\/th><th>\u8981\u70b9\u603b\u7ed3<\/th><\/tr><\/thead><tbody><tr><td>\u6570\u636e\u7ed3\u6784<\/td><td>\u5faa\u73af\u6570\u7ec4\uff08\u56fa\u5b9a\u5927\u5c0f\uff09<\/td><\/tr><tr><td>\u7ebf\u7a0b\u5b89\u5168<\/td><td><code>ReentrantLock<\/code> + <code>Condition<\/code> \u5b9e\u73b0<\/td><\/tr><tr><td>\u963b\u585e\u539f\u7406<\/td><td>\u6ee1\u65f6\u963b\u585e\u751f\u4ea7\u8005\uff0c\u7a7a\u65f6\u963b\u585e\u6d88\u8d39\u8005<\/td><\/tr><tr><td>\u516c\u5e73\u6027<\/td><td>\u6784\u9020\u65f6\u53ef\u8bbe\u5b9a\u662f\u5426\u516c\u5e73\uff08\u5f71\u54cd\u6027\u80fd\uff09<\/td><\/tr><tr><td>\u5e94\u7528\u573a\u666f<\/td><td>\u591a\u7ebf\u7a0b\u901a\u4fe1\u3001\u751f\u4ea7\u8005\u6d88\u8d39\u8005\u3001\u9650\u6d41<\/td><\/tr><\/tbody><\/table><\/figure>\n\n\n\n<hr class=\"wp-block-separator has-alpha-channel-opacity\"\/>\n\n\n\n<p>\u66f4\u591a\u8be6\u7ec6\u5185\u5bb9\u8bf7\u5173\u6ce8\u5176\u4ed6\u76f8\u5173\u6587\u7ae0\uff01<\/p>\n","protected":false},"excerpt":{"rendered":"<p>ArrayBlockingQueue \u662f Java \u5e76\u53d1\u5305 java.util.concurrent \u4e2d\u4e00\u4e2a\u91cd [&hellip;]<\/p>\n","protected":false},"author":1,"featured_media":3896,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[86],"tags":[],"class_list":["post-3894","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-java-"],"_links":{"self":[{"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/posts\/3894","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/comments?post=3894"}],"version-history":[{"count":1,"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/posts\/3894\/revisions"}],"predecessor-version":[{"id":3897,"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/posts\/3894\/revisions\/3897"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/media\/3896"}],"wp:attachment":[{"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/media?parent=3894"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/categories?post=3894"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/tags?post=3894"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}