✨ Introducing new features. wait notify 交替打印奇偶数

crossoverJie · crossoverJie · commit 4ec03bb20df1 · 2018-03-07T13:33:19.000+08:00
diff --git a/src/main/java/com/crossoverjie/actual/TwoThread.java b/src/main/java/com/crossoverjie/actual/TwoThread.java
@@ -6,6 +6,8 @@
 /**
  * Function: 两个线程交替执行打印 1~100
  *
+ * lock 版
+ *
  * @author crossoverJie
  *         Date: 11/02/2018 10:04
  * @since JDK 1.8
diff --git a/src/main/java/com/crossoverjie/actual/TwoThreadWaitNotify.java b/src/main/java/com/crossoverjie/actual/TwoThreadWaitNotify.java
@@ -0,0 +1,89 @@
+package com.crossoverjie.actual;
+
+/**
+ * Function:两个线程交替执行打印 1~100
+ * 等待通知机制版
+ *
+ * @author crossoverJie
+ *         Date: 07/03/2018 13:19
+ * @since JDK 1.8
+ */
+public class TwoThreadWaitNotify {
+
+    private int start = 1 ;
+
+    private boolean flag = false ;
+
+    public static void main(String[] args) {
+        TwoThread twoThread = new TwoThread();
+
+        Thread t1 = new Thread(new TwoThread.OuNum(twoThread));
+        t1.setName("t1");
+
+
+        Thread t2 = new Thread(new TwoThread.JiNum(twoThread));
+        t2.setName("t2");
+
+        t1.start();
+        t2.start();
+    }
+
+    /**
+     * 偶数线程
+     */
+    public static class OuNum implements Runnable {
+        private TwoThreadWaitNotify number;
+
+        public OuNum(TwoThreadWaitNotify number) {
+            this.number = number;
+        }
+
+        @Override
+        public void run() {
+            synchronized (TwoThreadWaitNotify.class){
+                while (number.start <= 100){
+                    if (number.flag){
+                        System.out.println(Thread.currentThread().getName() + "+-+" + number.start);
+                        number.start ++ ;
+
+                        number.flag = false ;
+                        try {
+                            TwoThreadWaitNotify.class.wait();
+                        } catch (InterruptedException e) {
+                            e.printStackTrace();
+                        }
+                    }
+                }
+
+            }
+        }
+    }
+
+
+    /**
+     * 奇数线程
+     */
+    public static class JiNum implements Runnable{
+        private TwoThreadWaitNotify number;
+
+        public JiNum(TwoThreadWaitNotify number) {
+            this.number = number;
+        }
+
+        @Override
+        public void run() {
+            synchronized (TwoThreadWaitNotify.class){
+                while (number.start <= 100){
+                    if (!number.flag){
+                        System.out.println(Thread.currentThread().getName() + "+-+" + number.start);
+                        number.start ++ ;
+
+                        number.flag = true ;
+
+                        TwoThreadWaitNotify.class.notify();
+                    }
+                }
+            }
+        }
+    }
+}

Original file line number	Diff line number	Diff line change
`@@ -6,6 +6,8 @@`
`6`	`6`	`/**`
`7`	`7`	`* Function: 两个线程交替执行打印 1~100`
`8`	`8`	`*`
	`9`	`+ * lock 版`
	`10`	`+ *`
`9`	`11`	`* @author crossoverJie`
`10`	`12`	`* Date: 11/02/2018 10:04`
`11`	`13`	`* @since JDK 1.8`