java-multithread,communication更新至example5

brianway · brianway · commit 26d9caa63c45 · 2016-04-14T01:15:30.000+08:00
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example3/MyThread.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example3/MyThread.java
@@ -0,0 +1,19 @@
+package com.brianway.learning.java.multithread.communication.example3;
+
+/**
+ * Created by brian on 2016/4/14.
+ */
+public class MyThread extends Thread {
+    private Object lock;
+
+    public MyThread(Object lock) {
+        super();
+        this.lock = lock;
+    }
+
+    @Override
+    public void run() {
+        Service service = new Service();
+        service.testMethod(lock);
+    }
+}
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example3/NotifyThread.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example3/NotifyThread.java
@@ -0,0 +1,20 @@
+package com.brianway.learning.java.multithread.communication.example3;
+
+/**
+ * Created by brian on 2016/4/14.
+ */
+public class NotifyThread extends Thread {
+    private Object lock;
+
+    public NotifyThread(Object lock) {
+        super();
+        this.lock = lock;
+    }
+
+    @Override
+    public void run() {
+        synchronized (lock){
+            lock.notify();
+        }
+    }
+}
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example3/NotifyThread2.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example3/NotifyThread2.java
@@ -0,0 +1,24 @@
+package com.brianway.learning.java.multithread.communication.example3;
+
+/**
+ * Created by brian on 2016/4/14.
+ */
+public class NotifyThread2 extends Thread {
+    private Object lock;
+
+    public NotifyThread2(Object lock) {
+        super();
+        this.lock = lock;
+    }
+
+    @Override
+    public void run() {
+        synchronized (lock){
+            lock.notify();
+            lock.notify();
+            lock.notify();
+            lock.notify();
+
+        }
+    }
+}
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example3/NotifyThread3.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example3/NotifyThread3.java
@@ -0,0 +1,20 @@
+package com.brianway.learning.java.multithread.communication.example3;
+
+/**
+ * Created by brian on 2016/4/14.
+ */
+public class NotifyThread3 extends Thread {
+    private Object lock;
+
+    public NotifyThread3(Object lock) {
+        super();
+        this.lock = lock;
+    }
+
+    @Override
+    public void run() {
+        synchronized (lock){
+            lock.notifyAll();
+        }
+    }
+}
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example3/Run3_notifyAll.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example3/Run3_notifyAll.java
@@ -0,0 +1,37 @@
+package com.brianway.learning.java.multithread.communication.example3;
+
+/**
+ * Created by brian on 2016/4/14.
+ */
+
+/**
+ * P150
+ * 唤醒多个线程，(逆序？试了好多次，全部都是刚好逆序的。巧合？机制？)
+ */
+public class Run3_notifyAll {
+    public static void main(String[] args) throws InterruptedException {
+        Object lock = new Object();
+        MyThread a = new MyThread(lock);
+        a.start();
+        MyThread b = new MyThread(lock);
+        b.start();
+        MyThread c = new MyThread(lock);
+        c.start();
+
+        Thread.sleep(1000);
+
+        NotifyThread3 notifyThread = new NotifyThread3(lock);
+        notifyThread.start();
+    }
+}
+
+/*
+输出：
+begin wait(),ThreadName=Thread-0
+begin wait(),ThreadName=Thread-1
+begin wait(),ThreadName=Thread-2
+end wait(),ThreadName=Thread-2
+end wait(),ThreadName=Thread-1
+end wait(),ThreadName=Thread-0
+
+ */
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example3/Run3_notifyMany.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example3/Run3_notifyMany.java
@@ -0,0 +1,37 @@
+package com.brianway.learning.java.multithread.communication.example3;
+
+/**
+ * Created by brian on 2016/4/14.
+ */
+
+/**
+ * P150
+ * 通知多个线程
+ */
+public class Run3_notifyMany {
+    public static void main(String[] args) throws InterruptedException {
+        Object lock = new Object();
+        MyThread a = new MyThread(lock);
+        a.start();
+        MyThread b = new MyThread(lock);
+        b.start();
+        MyThread c = new MyThread(lock);
+        c.start();
+
+        Thread.sleep(1000);
+
+        NotifyThread2 notifyThread = new NotifyThread2(lock);
+        notifyThread.start();
+    }
+}
+
+/*
+输出：
+begin wait(),ThreadName=Thread-0
+begin wait(),ThreadName=Thread-2
+begin wait(),ThreadName=Thread-1
+end wait(),ThreadName=Thread-0
+end wait(),ThreadName=Thread-1
+end wait(),ThreadName=Thread-2
+
+ */
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example3/Run3_notifyOne.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example3/Run3_notifyOne.java
@@ -0,0 +1,35 @@
+package com.brianway.learning.java.multithread.communication.example3;
+
+/**
+ * Created by brian on 2016/4/14.
+ */
+
+/**
+ * P149
+ * 通知一个线程
+ */
+public class Run3_notifyOne {
+    public static void main(String[] args) throws InterruptedException {
+        Object lock = new Object();
+        MyThread a = new MyThread(lock);
+        a.start();
+        MyThread b = new MyThread(lock);
+        b.start();
+        MyThread c = new MyThread(lock);
+        c.start();
+
+        Thread.sleep(1000);
+
+        NotifyThread notifyThread = new NotifyThread(lock);
+        notifyThread.start();
+    }
+}
+
+/*
+输出：
+begin wait(),ThreadName=Thread-1
+begin wait(),ThreadName=Thread-2
+begin wait(),ThreadName=Thread-0
+end wait(),ThreadName=Thread-1
+
+ */
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example3/Service.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example3/Service.java
@@ -0,0 +1,20 @@
+package com.brianway.learning.java.multithread.communication.example3;
+
+import java.awt.font.TextHitInfo;
+
+/**
+ * Created by brian on 2016/4/14.
+ */
+public class Service {
+    public void testMethod(Object lock){
+        try {
+            synchronized (lock){
+                System.out.println("begin wait(),ThreadName="+Thread.currentThread().getName());
+                lock.wait();
+                System.out.println("end wait(),ThreadName="+Thread.currentThread().getName());
+            }
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+    }
+}
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example4/Run4_waitHasParam.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example4/Run4_waitHasParam.java
@@ -0,0 +1,38 @@
+package com.brianway.learning.java.multithread.communication.example4;
+
+/**
+ * Created by brian on 2016/4/14.
+ */
+
+/**
+ * p151
+ * wait(long)使用，超时自动唤醒
+ */
+public class Run4_waitHasParam {
+    static private Object lock = new Object();
+    static private Runnable runnable1 =new Runnable() {
+        public void run() {
+            try {
+                synchronized (lock){
+                    System.out.println("wait begin timer="+System.currentTimeMillis());
+                    lock.wait(4000);
+                    System.out.println("wait end timer="+System.currentTimeMillis());
+                }
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }
+        }
+    };
+
+    public static void main(String[] args) {
+        Thread t = new Thread(runnable1);
+        t.start();
+    }
+}
+
+
+/*
+输出：
+wait begin timer=1460566545742
+wait end timer=1460566549743
+ */
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example4/Run4_waitHasParam2.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example4/Run4_waitHasParam2.java
@@ -0,0 +1,56 @@
+package com.brianway.learning.java.multithread.communication.example4;
+
+/**
+ * Created by brian on 2016/4/14.
+ */
+
+/**
+ * p152
+ * wait(long)使用，时间限制内由其他线程唤醒
+ */
+public class Run4_waitHasParam2 {
+    static private Object lock = new Object();
+    static private Runnable runnable1 =new Runnable() {
+        public void run() {
+            try {
+                synchronized (lock){
+                    System.out.println("wait begin timer="+System.currentTimeMillis());
+                    lock.wait(5000);
+                    System.out.println("wait end timer="+System.currentTimeMillis());
+                }
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }
+        }
+    };
+
+    static private Runnable runnable2 =new Runnable() {
+        public void run() {
+
+            synchronized (lock){
+                System.out.println("notify begin timer="+System.currentTimeMillis());
+                lock.notify();
+                System.out.println("notify end timer="+System.currentTimeMillis());
+            }
+
+        }
+    };
+
+
+    public static void main(String[] args) throws InterruptedException {
+        Thread t1 = new Thread(runnable1);
+        t1.start();
+        Thread.sleep(2000);
+        Thread t2 = new Thread(runnable2);
+        t2.start();
+    }
+}
+
+
+/*
+输出：
+wait begin timer=1460566507815
+notify begin timer=1460566509815
+notify end timer=1460566509815
+wait end timer=1460566509815
+ */
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example5/MyRun.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example5/MyRun.java
@@ -0,0 +1,38 @@
+package com.brianway.learning.java.multithread.communication.example5;
+
+/**
+ * Created by brian on 2016/4/14.
+ */
+public class MyRun {
+    private Object lock = new Object();
+    private boolean isFirstRunNotify=false;
+    public Runnable runnableWait =new Runnable() {
+        public void run() {
+            try {
+                synchronized (lock){
+                    while (!isFirstRunNotify){
+                        System.out.println("wait begin timer="+System.currentTimeMillis());
+                        lock.wait();
+                        System.out.println("wait end timer="+System.currentTimeMillis());
+                    }
+
+                }
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }
+        }
+    };
+
+    public Runnable runnableNotify =new Runnable() {
+        public void run() {
+
+            synchronized (lock){
+                System.out.println("notify begin timer="+System.currentTimeMillis());
+                lock.notify();
+                System.out.println("notify end timer="+System.currentTimeMillis());
+                isFirstRunNotify = true;
+            }
+
+        }
+    };
+}
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example5/Run5_notify.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example5/Run5_notify.java
@@ -0,0 +1,29 @@
+package com.brianway.learning.java.multithread.communication.example5;
+
+/**
+ * Created by brian on 2016/4/14.
+ */
+
+/**
+ * P154
+ * notify正常通知
+ */
+public class Run5_notify {
+    public static void main(String[] args) throws InterruptedException {
+        MyRun myRun = new MyRun();
+        Thread a =new Thread(myRun.runnableWait);
+        a.start();
+        Thread.sleep(100);
+        Thread b= new Thread(myRun.runnableNotify);
+        b.start();
+    }
+
+}
+
+/*
+输出：
+wait begin timer=1460567668037
+notify begin timer=1460567668137
+notify end timer=1460567668137
+wait end timer=1460567668137
+ */
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example5/Run5_notifyEarly.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example5/Run5_notifyEarly.java
