java-multithread lock包更新至example1

brianway · brianway · commit 869156c22920 · 2016-04-15T00:39:58.000+08:00
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/lock/example1/Run1_UseConditionWaitNotify.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/lock/example1/Run1_UseConditionWaitNotify.java
@@ -0,0 +1,25 @@
+package com.brianway.learning.java.multithread.lock.example1;
+
+/**
+ * Created by brian on 2016/4/15.
+ */
+
+
+/**
+ * P206
+ * 使用Condition实现等待通知
+ * Condition对象的await()方法，线程WAITING
+ */
+public class Run1_UseConditionWaitNotify {
+    public static void main(String[] args) {
+        ServiceB service = new ServiceB();
+        ThreadB b = new ThreadB(service);
+        b.start();
+    }
+}
+
+
+/*
+输出：
+A
+ */
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/lock/example1/Run1_UseConditionWaitNotifyError.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/lock/example1/Run1_UseConditionWaitNotifyError.java
@@ -0,0 +1,32 @@
+package com.brianway.learning.java.multithread.lock.example1;
+
+/**
+ * Created by brian on 2016/4/15.
+ */
+
+
+/**
+ * P204
+ * 使用Condition实现等待通知，展示错误用法
+ * IllegalMonitorStateException，监视器出错
+ */
+public class Run1_UseConditionWaitNotifyError {
+    public static void main(String[] args) {
+        ServiceA service = new ServiceA();
+        ThreadA a = new ThreadA(service);
+        a.start();
+    }
+}
+
+
+/*
+输出：
+Exception in thread "Thread-0" java.lang.IllegalMonitorStateException
+	at java.util.concurrent.locks.ReentrantLock$Sync.tryRelease(ReentrantLock.java:151)
+	at java.util.concurrent.locks.AbstractQueuedSynchronizer.release(AbstractQueuedSynchronizer.java:1261)
+	at java.util.concurrent.locks.AbstractQueuedSynchronizer.fullyRelease(AbstractQueuedSynchronizer.java:1723)
+	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2036)
+	at com.brianway.learning.java.multithread.lock.example1.ServiceA.await(ServiceA.java:16)
+	at com.brianway.learning.java.multithread.lock.example1.ThreadA.run(ThreadA.java:15)
+
+ */
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/lock/example1/Run1_UseConditionWaitNotifyOk.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/lock/example1/Run1_UseConditionWaitNotifyOk.java
@@ -0,0 +1,32 @@
+package com.brianway.learning.java.multithread.lock.example1;
+
+/**
+ * Created by brian on 2016/4/15.
+ */
+
+
+/**
+ * P207
+ * 正确使用Condition实现等待通知
+ * Object类的wait()------Condition类的await()
+ * Object类的wait(long timeout)------Condition类的await(long time,TimeUnit unit)
+ * Object类的notify()------Condition类的signal()
+ * Object类的notifyAll()------Condition类的signalAll()
+ */
+public class Run1_UseConditionWaitNotifyOk {
+    public static void main(String[] args) throws InterruptedException {
+        ServiceC service = new ServiceC();
+        ThreadC c = new ThreadC(service);
+        c.start();
+        Thread.sleep(3000);
+        service.signal();
+    }
+}
+
+
+/*
+输出：
+await 时间为1460651340418
+signal时间为1460651343418
+锁释放了
+ */
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/lock/example1/ServiceA.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/lock/example1/ServiceA.java
@@ -0,0 +1,21 @@
+package com.brianway.learning.java.multithread.lock.example1;
+
+import java.util.concurrent.locks.Condition;
+import java.util.concurrent.locks.Lock;
+import java.util.concurrent.locks.ReentrantLock;
+
+/**
+ * Created by brian on 2016/4/15.
+ */
+public class ServiceA {
+    private Lock lock = new ReentrantLock();
+    private Condition condition = lock.newCondition();
+
+    public void await(){
+        try {
+            condition.await();
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+    }
+}
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/lock/example1/ServiceB.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/lock/example1/ServiceB.java
@@ -0,0 +1,27 @@
+package com.brianway.learning.java.multithread.lock.example1;
+
+import java.util.concurrent.locks.Condition;
+import java.util.concurrent.locks.Lock;
+import java.util.concurrent.locks.ReentrantLock;
+
+/**
+ * Created by brian on 2016/4/15.
+ */
+public class ServiceB {
+    private Lock lock = new ReentrantLock();
+    private Condition condition = lock.newCondition();
+
+    public void waitMethod(){
+        try {
+            lock.lock();
+            System.out.println("A");
+            condition.await();
+            System.out.println("B");
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }finally {
+            lock.unlock();
+            System.out.println("锁释放了");
+        }
+    }
+}
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/lock/example1/ServiceC.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/lock/example1/ServiceC.java
@@ -0,0 +1,36 @@
+package com.brianway.learning.java.multithread.lock.example1;
+
+import java.util.concurrent.locks.Condition;
+import java.util.concurrent.locks.Lock;
+import java.util.concurrent.locks.ReentrantLock;
+
+/**
+ * Created by brian on 2016/4/15.
+ */
+public class ServiceC {
+    private Lock lock = new ReentrantLock();
+    private Condition condition = lock.newCondition();
+
+    public void await(){
+        try {
+            lock.lock();
+            System.out.println("await 时间为"+System.currentTimeMillis());
+            condition.await();
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }finally {
+            lock.unlock();
+            System.out.println("锁释放了");
+        }
+    }
+
+    public void signal(){
+        try {
+            lock.lock();
+            System.out.println("signal时间为"+System.currentTimeMillis());
+            condition.signal();
+        } finally {
+            lock.unlock();
+        }
+    }
+}
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/lock/example1/ThreadA.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/lock/example1/ThreadA.java
@@ -0,0 +1,17 @@
+package com.brianway.learning.java.multithread.lock.example1;
+
+/**
+ * Created by brian on 2016/4/15.
+ */
+public class ThreadA extends Thread {
+    private ServiceA service;
+
+    public ThreadA(ServiceA service) {
+        this.service = service;
+    }
+
+    @Override
+    public void run() {
+        service.await();
+    }
+}
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/lock/example1/ThreadB.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/lock/example1/ThreadB.java
@@ -0,0 +1,17 @@
+package com.brianway.learning.java.multithread.lock.example1;
+
+/**
+ * Created by brian on 2016/4/15.
+ */
+public class ThreadB extends Thread {
+    private ServiceB service;
+
+    public ThreadB(ServiceB service) {
+        this.service = service;
+    }
+
+    @Override
+    public void run() {
+        service.waitMethod();
+    }
+}
diff --git a/java-multithread/src/main/java/com/brianway/learning/java/multithread/lock/example1/ThreadC.java b/java-multithread/src/main/java/com/brianway/learning/java/multithread/lock/example1/ThreadC.java
@@ -0,0 +1,17 @@
+package com.brianway.learning.java.multithread.lock.example1;
+
+/**
+ * Created by brian on 2016/4/15.
+ */
+public class ThreadC extends Thread {
+    private ServiceC service;
+
+    public ThreadC(ServiceC service) {
+        this.service = service;
+    }
+
+    @Override
+    public void run() {
+        service.await();
+    }
+}
