add > producer & consumer mode

lihengming · lihengming · commit b9915f32d83e · 2017-06-08T16:49:31.000+08:00
diff --git a/concurrent/src/main/java/pcmodel/Consumer.java b/concurrent/src/main/java/pcmodel/Consumer.java
@@ -0,0 +1,35 @@
+package pcmodel;
+
+import java.util.List;
+
+/**
+ * Created by 李恒名 on 2017/6/8.
+ * <p>
+ * 消费者
+ */
+public class Consumer implements Runnable {
+
+    private List<Product> buffer;
+
+    public Consumer(List<Product> buffer) {
+        this.buffer = buffer;
+    }
+
+    public void run() {
+        while (true) {
+            synchronized (buffer) {
+                while (buffer.isEmpty()) {
+                    try {
+                        buffer.wait();
+                    } catch (InterruptedException e) {
+                        e.printStackTrace();
+                    }
+                }
+                System.out.println("消费者[" + Thread.currentThread().getName() + "]消费了一个产品：" + buffer.remove(0));
+                buffer.notifyAll();
+            }
+        }
+    }
+
+
+}
diff --git a/concurrent/src/main/java/pcmodel/Producer.java b/concurrent/src/main/java/pcmodel/Producer.java
@@ -0,0 +1,44 @@
+package pcmodel;
+
+
+import java.util.List;
+
+/**
+ * Created by 李恒名 on 2017/6/8.
+ * <p>
+ * 生产者
+ */
+public class Producer implements Runnable {
+
+    private final int maxSize = 10;//产品最大库存量
+
+    private List<Product> buffer;
+
+    public Producer(List<Product> buffer) {
+        this.buffer = buffer;
+    }
+
+    public void run() {
+        while (true) {
+            synchronized (buffer) {
+                while (buffer.size() >= maxSize) {
+                    try {
+                        buffer.wait();//将当前线程放入等锁(buffer对象的锁)池，并释放锁。
+                    } catch (InterruptedException e) {
+                        e.printStackTrace();
+                    }
+                }
+                //模拟生产需要500毫秒
+                try {
+                    Thread.sleep(500);
+                } catch (InterruptedException e) {
+                    e.printStackTrace();
+                }
+                Product product = new Product("iPhone 手机");
+                buffer.add(product);
+                System.out.println("生产者[" + Thread.currentThread().getName() + "]生产了一个产品：" + product);
+                buffer.notifyAll();//生产完毕通知等待锁的其他线程(生产者或消费者都有可能)
+            }
+        }
+    }
+}
diff --git a/concurrent/src/main/java/pcmodel/Product.java b/concurrent/src/main/java/pcmodel/Product.java
@@ -0,0 +1,20 @@
+package pcmodel;
+
+/**
+ * Created by 李恒名 on 2017/6/8.
+ *
+ *   产品
+ */
+public class Product {
+
+    private String name;
+
+    public Product(String name) {
+        this.name = name;
+    }
+
+    @Override
+    public String toString() {
+        return name;
+    }
+}
