ProdConsumerSynchronized

DreamCats · DreamCats · commit 9564eda6cdb1 · 2020-02-16T14:19:38.000+08:00
diff --git a/Multithread/src/com/juc/queue/ProdConsumerSynchronized.java b/Multithread/src/com/juc/queue/ProdConsumerSynchronized.java
@@ -10,65 +10,59 @@
 package com.juc.queue;
 
 import java.util.LinkedList;
-import java.util.concurrent.TimeUnit;
 
 public class ProdConsumerSynchronized {
 
     private final LinkedList<String> lists = new LinkedList<>();
 
-    private final int MAX = 10; // 最多10个元素
-
-    private int count = 0;
-
     public synchronized void put(String s) {
-        while (lists.size() == 1) { // 用while怕有存在虚拟唤醒线程
+        while (lists.size() != 0) { // 用while怕有存在虚拟唤醒线程
             // 满了， 不生产了
             try {
                 this.wait();
             } catch (InterruptedException e) {
                 e.printStackTrace();
             }
         }
-        lists.add(s); // 毕竟所有线程抢这一把锁
-        count++;
-        try { TimeUnit.SECONDS.sleep(1); } catch (InterruptedException e) { e.printStackTrace(); }
+        lists.add(s);
+        System.out.println(Thread.currentThread().getName() + " " + lists.peekFirst());
         this.notifyAll(); // 这里可是通知所有被挂起的线程，包括其他的生产者线程
     }
 
-    public synchronized String get() {
-        String s = null;
+    public synchronized void get() {
         while (lists.size() == 0) {
             try {
                 this.wait();
             } catch (InterruptedException e) {
                 e.printStackTrace();
             }
         }
-        s = lists.removeFirst();
-        count--;
+        System.out.println(Thread.currentThread().getName() + " " + lists.removeFirst());
         this.notifyAll(); // 通知所有被wait挂起的线程  用notify可能就死锁了。
-        return s;
     }
 
     public static void main(String[] args) {
         ProdConsumerSynchronized prodConsumerSynchronized = new ProdConsumerSynchronized();
+
         // 启动消费者线程
-        for (int i = 0; i < 2; i++) {
-            new Thread(() -> {
-                for (int j = 0; j < 15; j++) {
-                    System.out.println(Thread.currentThread().getName() + prodConsumerSynchronized.get());
-                }
-            }, "消费者线程ID：" + i).start();
+        for (int i = 0; i < 5; i++) {
+            new Thread(prodConsumerSynchronized::get, "ConsA" + i).start();
         }
 
-        try { TimeUnit.SECONDS.sleep(2); } catch (InterruptedException e) { e.printStackTrace(); }
         // 启动生产者线程
-        for (int i = 0; i < 2; i++) {
+        for (int i = 0; i < 5; i++) {
+            int tempI = i;
             new Thread(() -> {
-                for (int j = 0; j < 15; j++) {
-                    prodConsumerSynchronized.put(Thread.currentThread().getName() + " 编号：" + j);
-                }
-            }, "生产者线程ID：" + i).start();
+                prodConsumerSynchronized.put("" + tempI);
+            }, "ProdA" + i).start();
         }
+
+
+
+
+
+
+
+
     }
 }
