WaitNotify__等待唤醒线程

CPU-Code · CPU-Code · commit 0f5dd237e65f · 2021-02-09T17:43:51.000+08:00
diff --git a/out/production/thread/com/cpucode/java/README.md b/out/production/thread/com/cpucode/java/README.md
@@ -69,12 +69,17 @@
 
 - [x] [Deadlock__死锁](deadlock/Deadlock.java)
 
-
 - [返回文件目录](#文件目录)
 
 ---------------
 
+## [等待唤醒线程](wait/notify)
+
+- [x] [WaitNotify__等待唤醒线程](wait/notify/WaitNotify.java)
 
+- [返回文件目录](#文件目录)
+
+---------------
 
 
 - [x] [thread1__创建新线程](thread/thread2.java)
diff --git a/thread/src/com/cpucode/java/README.md b/thread/src/com/cpucode/java/README.md
@@ -73,7 +73,13 @@
 
 ---------------
 
+## [等待唤醒线程](wait/notify)
 
+- [x] [WaitNotify__等待唤醒线程](wait/notify/WaitNotify.java)
+
+- [返回文件目录](#文件目录)
+
+---------------
 
 
 - [x] [thread1__创建新线程](thread/thread2.java)
diff --git a/thread/src/com/cpucode/java/wait/notify/WaitNotify.java b/thread/src/com/cpucode/java/wait/notify/WaitNotify.java
@@ -0,0 +1,90 @@
+package com.cpucode.java.wait.notify;
+
+import java.util.ArrayList;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.Queue;
+
+/**
+ * @author : cpucode
+ * @date : 2021/2/9
+ * @time : 17:24
+ * @github : https://github.com/CPU-Code
+ * @csdn : https://blog.csdn.net/qq_44226094
+ */
+public class WaitNotify {
+    @SuppressWarnings("AlibabaAvoidManuallyCreateThread")
+    public static void main(String[] args) throws InterruptedException{
+        TaskQueue q = new TaskQueue();
+        List<Thread> ts = new ArrayList<Thread>();
+        int num = 5;
+        int num1 = 10;
+
+        for (int i = 0; i < num; i++) {
+            //noinspection AlibabaAvoidManuallyCreateThread
+            Thread t = new Thread(){
+                @Override
+                public void run(){
+                    // 执行task:
+                    while(true){
+                        try{
+                            String s = q.getTask();
+
+                            System.out.println("execute task : " + s);
+                        } catch (InterruptedException e){
+                            return;
+                        }
+                    }
+                }
+            };
+
+            t.start();
+            ts.add(t);
+        }
+
+        Thread add = new Thread(() ->{
+            for (int i = 0; i < num1; i++) {
+                // 放入task:
+                String s =  "t -" + Math.random();
+
+                System.out.println("add task:" + s);
+
+                q.addTask(s);
+
+                try{
+                    Thread.sleep(100);
+                }catch (InterruptedException e){
+                    e.printStackTrace();
+                }
+            }
+        });
+
+        add.start();
+        add.join();
+
+        Thread.sleep(100);
+
+        for (Thread t : ts){
+            t.interrupt();
+        }
+    }
+}
+
+class TaskQueue{
+    Queue<String> queue = new LinkedList<>();
+
+    public synchronized void addTask(String s){
+        this.queue.add(s);
+        //唤醒所有当前正在this锁等待的线程
+        this.notifyAll();
+    }
+
+    public synchronized String getTask() throws InterruptedException{
+        while (queue.isEmpty()){
+            //等待
+            this.wait();
+        }
+
+        return queue.remove();
+    }
+}
