java-multihread 添加communication包,更新至example2

brianway · brianway · commit 82ac4cf8ec5d · 2016-04-13T22:31:01.000+08:00
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example1/MyList.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example1/MyList.java
@@ -0,0 +1,20 @@
+package com.brianway.learning.java.multithread.communication.example1;
+
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * Created by Brian on 2016/4/13.
+ */
+public class MyList {
+    private List list = new ArrayList();
+
+    public void add(){
+        list.add("brian");
+    }
+    public int size(){
+        return list.size();
+    }
+}
+
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example1/Run1_TwoThreadTransData.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example1/Run1_TwoThreadTransData.java
@@ -0,0 +1,60 @@
+package com.brianway.learning.java.multithread.communication.example1;
+
+/**
+ * Created by Brian on 2016/4/13.
+ */
+
+/**
+ * P134
+ * 不使用等待/通知机制实现线程间通信
+ *
+ * 这里有可见性的问题，并不一定能看到线程b退出。
+ */
+public class Run1_TwoThreadTransData {
+    public static void main(String[] args) {
+        MyList service = new MyList();
+        ThreadA a =new ThreadA(service);
+        a.setName("A");
+        a.start();
+        ThreadB b = new ThreadB(service);
+        b.setName("B");
+        b.start();
+    }
+
+}
+
+
+/*
+在ThreadB的run方法while里加上synchronized ("any"){}
+
+输出：
+添加了1元素
+添加了2元素
+添加了3元素
+添加了4元素
+java.lang.InterruptedException
+	at com.brianway.learning.java.multithread.communication.example1.ThreadB.run(ThreadB.java:22)
+添加了5元素
+达到size了，线程b要退出了
+添加了6元素
+添加了7元素
+添加了8元素
+添加了9元素
+添加了10元素
+
+
+----------------
+若不加synchronized ("any"){}
+
+输出：
+添加了1元素
+添加了2元素
+添加了3元素
+添加了4元素
+添加了5元素
+添加了6元素
+添加了7元素
+添加了8元素
+添加了9元素
+添加了10元素
+ */
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example1/ThreadA.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example1/ThreadA.java
@@ -0,0 +1,26 @@
+package com.brianway.learning.java.multithread.communication.example1;
+
+/**
+ * Created by Brian on 2016/4/13.
+ */
+public class ThreadA extends Thread {
+    private MyList list;
+
+    public ThreadA(MyList list) {
+        super();
+        this.list = list;
+    }
+
+    @Override
+    public void run() {
+        for(int i = 0;i<10;i++){
+            list.add();
+            System.out.println("添加了"+(i+1)+"元素");
+            try {
+                Thread.sleep(1000);
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }
+        }
+    }
+}
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example1/ThreadB.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example1/ThreadB.java
@@ -0,0 +1,29 @@
+package com.brianway.learning.java.multithread.communication.example1;
+
+/**
+ * Created by Brian on 2016/4/13.
+ */
+public class ThreadB extends Thread {
+    private MyList list;
+
+    public ThreadB(MyList list) {
+        super();
+        this.list = list;
+    }
+
+    @Override
+    public void run() {
+        try {
+            while (true){
+                //System.out.println("in b while: "+list.size());
+                //synchronized ("any"){}
+                if(list.size() == 5){
+                    System.out.println("达到size了，线程b要退出了");
+                    throw new InterruptedException();
+                }
+            }
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+    }
+}
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example2/Run2_noObjectLock.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example2/Run2_noObjectLock.java
@@ -0,0 +1,34 @@
+package com.brianway.learning.java.multithread.communication.example2;
+
+/**
+ * Created by Brian on 2016/4/13.
+ */
+
+/**
+ * P137
+ * 没有“对象监视器”，调用wait()方法出现运行时异常
+ */
+public class Run2_noObjectLock {
+    public static void main(String[] args) {
+        String s = new String("");
+        try {
+            s.wait();
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+    }
+}
+
+/*
+输出：
+Exception in thread "main" java.lang.IllegalMonitorStateException
+	at java.lang.Object.wait(Native Method)
+	at java.lang.Object.wait(Object.java:502)
+	at com.brianway.learning.java.multithread.communication.example2.Run2_noObjectLock.main(Run2_noObjectLock.java:15)
+	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
+	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
+	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
+	at java.lang.reflect.Method.invoke(Method.java:483)
+	at com.intellij.rt.execution.application.AppMain.main(AppMain.java:144)
+
+ */
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example2/Run2_notify.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example2/Run2_notify.java
@@ -0,0 +1,36 @@
+package com.brianway.learning.java.multithread.communication.example2;
+
+/**
+ * Created by Brian on 2016/4/13.
+ */
+
+/**
+ * P139
+ * notify实现通知
+ * notify调用后，并不会立即释放对象锁，而是退出synchronized代码块后
+ */
+public class Run2_notify {
+    public static void main(String[] args) {
+        try {
+            Object lock = new Object();
+            Thread1 t1 = new Thread1(lock);
+            t1.start();
+            Thread.sleep(3000);
+            Thread2 t2 = new Thread2(lock);
+            t2.start();
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+
+    }
+}
+
+
+/*
+输出：
+开始 wait   time=1460554213416
+开始 notify time=1460554216418
+结束 notify time=1460554218418
+结束 wait   time=1460554218418
+
+ */
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example2/Run2_sleep.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example2/Run2_sleep.java
@@ -0,0 +1,84 @@
+package com.brianway.learning.java.multithread.communication.example2;
+
+/**
+ * Created by Brian on 2016/4/13.
+ */
+
+/**
+ * P142
+ * 测试sleep()期间其他线程是否执行
+ * 处理器资源，对象锁，是不同的概念
+ *
+ */
+public class Run2_sleep {
+    public static void main(String[] args) {
+        Thread t1 =new Thread(){
+            @Override
+            public void run() {
+                super.run();
+                System.out.println(Thread.currentThread().getName()+" begin sleep");
+                try {
+                    Thread.sleep(2000);
+                } catch (InterruptedException e) {
+                    e.printStackTrace();
+                }
+                System.out.println(Thread.currentThread().getName()+" end sleep");
+            }
+        };
+        t1.setName("t1");
+
+        Thread t2 = new Thread(){
+            @Override
+            public void run() {
+                super.run();
+                long i =0;
+                long max = (long)Integer.MAX_VALUE;
+                System.out.println("max = "+max);
+
+                System.out.println(Thread.currentThread().getName()+" begin while");
+                while(i<max){
+                    i++;
+                    if(i%100000000==0){
+                        System.out.println(Thread.currentThread().getName()+" now is "+i);
+                    }
+                }
+                System.out.println(Thread.currentThread().getName()+" end while");
+            }
+        };
+        t2.setName("t2");
+
+        t1.start();
+        t2.start();
+
+    }
+}
+
+/*
+输出：
+t1 begin sleep
+max = 2147483647
+t2 begin while
+t2 now is 100000000
+t2 now is 200000000
+t2 now is 300000000
+t2 now is 400000000
+t2 now is 500000000
+t2 now is 600000000
+t2 now is 700000000
+t2 now is 800000000
+t2 now is 900000000
+t2 now is 1000000000
+t2 now is 1100000000
+t2 now is 1200000000
+t2 now is 1300000000
+t2 now is 1400000000
+t2 now is 1500000000
+t1 end sleep
+t2 now is 1600000000
+t2 now is 1700000000
+t2 now is 1800000000
+t2 now is 1900000000
+t2 now is 2000000000
+t2 now is 2100000000
+t2 end while
+ */
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example2/Run2_wait.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example2/Run2_wait.java
@@ -0,0 +1,32 @@
+package com.brianway.learning.java.multithread.communication.example2;
+
+/**
+ * Created by Brian on 2016/4/13.
+ */
+
+/**
+ * P137
+ * wait()永远阻塞
+ */
+public class Run2_wait {
+    public static void main(String[] args) {
+        try {
+            String lock = new String();
+            System.out.println("syn上面");
+            synchronized (lock){
+                System.out.println("syn第一行,wait前面");
+                lock.wait();
+                System.out.println("wait下面的代码");
+            }
+            System.out.println("syn下面的代码");
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+    }
+}
+
+/*
+输出：
+syn上面
+syn第一行,wait前面
+ */
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example2/Thread1.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example2/Thread1.java
@@ -0,0 +1,26 @@
+package com.brianway.learning.java.multithread.communication.example2;
+
+/**
+ * Created by Brian on 2016/4/13.
+ */
+public class Thread1 extends Thread{
+    private Object lock;
+
+    public Thread1(Object lock) {
+        super();
+        this.lock = lock;
+    }
+
+    @Override
+    public void run() {
+        try {
+            synchronized (lock){
+                System.out.println("开始 wait   time="+System.currentTimeMillis());
+                lock.wait();
+                System.out.println("结束 wait   time="+System.currentTimeMillis());
+            }
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+    }
+}
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example2/Thread2.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/communication/example2/Thread2.java
@@ -0,0 +1,28 @@
+package com.brianway.learning.java.multithread.communication.example2;
+
+/**
+ * Created by Brian on 2016/4/13.
+ */
+public class Thread2 extends Thread{
+    private Object lock;
+
+    public Thread2(Object lock) {
+        super();
+        this.lock = lock;
+    }
+
+    @Override
+    public void run() {
+
+        synchronized (lock){
+            System.out.println("开始 notify time="+System.currentTimeMillis());
+            lock.notify();
+            try {
+                Thread.sleep(2000);
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }
+            System.out.println("结束 notify time="+System.currentTimeMillis());
+        }
+    }
+}
