blocking queue

Author: laileon

src/com/blankj/custom/desingn_pattern/producer/Consumer.java

@@ -0,0 +1,27 @@
+package com.blankj.custom.desingn_pattern.producer;
+
+import java.util.concurrent.BlockingQueue;
+
+public class Consumer implements Runnable {
+    private BlockingQueue<String> queue;
+    private String consumer;
+
+    public Consumer(BlockingQueue<String> queue, String consumer) {
+        this.queue = queue;
+        if (null != consumer)
+            this.consumer = consumer;
+        else
+            this.consumer = "null ";
+    }
+
+    @Override
+    public void run() {
+        try {
+            String uuid = queue.take();
+            System.out.println(consumer + " decayed " + uuid
+                    + " " + Thread.currentThread());
+        } catch (InterruptedException e) {
+            System.out.println(e.getMessage());
+        }
+    }
+}

src/com/blankj/custom/desingn_pattern/producer/Producer.java

@@ -0,0 +1,29 @@
+package com.blankj.custom.desingn_pattern.producer;
+
+import java.util.UUID;
+import java.util.concurrent.BlockingQueue;
+
+public class Producer implements Runnable {
+    private BlockingQueue<String> queue;
+    private String produce;
+
+    public Producer(BlockingQueue<String> queue, String produce) {
+        this.queue = queue;
+        if (null != produce)
+            this.produce = produce;
+        else this.produce = "null ";
+    }
+
+    @Override
+    public void run() {
+        String uuid = UUID.randomUUID().toString();
+        try {
+            Thread.sleep(200);//生产需要时间
+            queue.put(produce + " : " + uuid);
+            System.out.println("Produce \"" + produce + "\" : " + uuid + " " + Thread.currentThread());
+
+        } catch (InterruptedException e) {
+            System.out.println(e.getMessage());
+        }
+    }
+}

src/com/blankj/custom/desingn_pattern/producer/Tester.java

@@ -0,0 +1,22 @@
+package com.blankj.custom.desingn_pattern.producer;
+
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.LinkedBlockingQueue;
+
+public class Tester {
+    public static void main(String[] args) {
+        // 队列
+        LinkedBlockingQueue<String> queue = new LinkedBlockingQueue<String>(10);
+        ExecutorService service = Executors.newCachedThreadPool();
+        for (int i = 0; i < 6; i++) {
+            service.submit(new Consumer(queue, "X二代" + i));
+            service.submit(new Consumer(queue, "导演" + i));
+        }
+        for (int i = 0; i < 6; i++) {
+            service.submit(new Producer(queue, "黄金酒," + i));
+            service.submit(new Producer(queue, "美女演员" + i));
+        }
+        service.shutdown();
+    }
+}