添加生产者消费者-阻塞队列实现

byhieg · byhieg · commit c41dde8e35e0 · 2017-05-09T09:59:08.000+08:00
diff --git a/src/main/java/cn/byhieg/threadtutorial/concurrent/blocking/ArrayBlock.java b/src/main/java/cn/byhieg/threadtutorial/concurrent/blocking/ArrayBlock.java
@@ -1,7 +1,10 @@
 package cn.byhieg.threadtutorial.concurrent.blocking;
 
-import java.util.concurrent.ArrayBlockingQueue;
-import java.util.concurrent.BlockingQueue;
+import com.sun.scenario.effect.impl.sw.sse.SSEBlend_SRC_OUTPeer;
+
+import javax.sound.midi.SoundbankResource;
+import java.lang.management.LockInfo;
+import java.util.concurrent.*;
 
 /**
  * Created by byhieg on 17/5/3.
@@ -11,8 +14,18 @@ public class ArrayBlock {
 
     private BlockingQueue<String> blockingQueue;
 
-    public ArrayBlock(){
-        blockingQueue = new ArrayBlockingQueue<String>(1024);
+    public ArrayBlock(int index) {
+        switch (index) {
+            case 0:
+                blockingQueue = new ArrayBlockingQueue<String>(3);
+                break;
+            case 1:
+                blockingQueue = new LinkedBlockingQueue<>();
+                break;
+            case 2:
+                blockingQueue = new SynchronousQueue<>();
+                break;
+        }
     }
 
     public BlockingQueue<String> getBlockingQueue() {
diff --git a/src/main/java/cn/byhieg/threadtutorial/concurrent/blocking/Costumer.java b/src/main/java/cn/byhieg/threadtutorial/concurrent/blocking/Costumer.java
@@ -20,7 +20,7 @@ public void run() {
         super.run();
         while (true) {
             try {
-                Thread.sleep(2000);
+                Thread.sleep(5000);
                 String str = blockingQueue.take();
                 System.out.println(getName() + " 取出数据 " + str);
             } catch (InterruptedException e) {
diff --git a/src/main/java/cn/byhieg/threadtutorial/concurrent/blocking/Producer.java b/src/main/java/cn/byhieg/threadtutorial/concurrent/blocking/Producer.java
@@ -14,9 +14,8 @@ public void run() {
         super.run();
         for (int i = 0 ; i < 5;i++) {
             try {
-                System.out.println(getName() + " 生产数据");
                 blockingQueue.put(i + "");
-                Thread.sleep(1000);
+                System.out.println(getName() + " 生产数据");
             } catch (InterruptedException e) {
                 e.printStackTrace();
             }
diff --git a/src/test/java/cn/byhieg/threadtutorialtest/concurrenttest/blockingtest/ArrayBlockTest.java b/src/test/java/cn/byhieg/threadtutorialtest/concurrenttest/blockingtest/ArrayBlockTest.java
@@ -15,7 +15,7 @@ public class ArrayBlockTest extends TestCase {
     ArrayBlock block;
     public void setUp() throws Exception {
         super.setUp();
-        block = new ArrayBlock();
+        block = new ArrayBlock(2);
     }
 
     public void tearDown() throws Exception {

Original file line number	Diff line number	Diff line change
`@@ -15,7 +15,7 @@ public class ArrayBlockTest extends TestCase {`
`15`	`15`	`ArrayBlock block;`
`16`	`16`	`public void setUp() throws Exception {`
`17`	`17`	`super.setUp();`
`18`		`- block = new ArrayBlock();`
	`18`	`+ block = new ArrayBlock(2);`
`19`	`19`	`}`
`20`	`20`
`21`	`21`	`public void tearDown() throws Exception {`