结束多线程Lock锁内容。

byhieg · byhieg · commit a87e23c321eb · 2017-01-28T13:45:34.000+08:00
diff --git a/src/main/java/cn/byhieg/threadtutorial/char04/HoldCountService.java b/src/main/java/cn/byhieg/threadtutorial/char04/HoldCountService.java
@@ -0,0 +1,33 @@
+package cn.byhieg.threadtutorial.char04;
+
+import java.util.concurrent.locks.ReentrantLock;
+
+/**
+ * Created by byhieg on 17/1/27.
+ * Mail to byhieg@gmail.com
+ */
+public class HoldCountService {
+    private ReentrantLock lock = new ReentrantLock();
+
+    public void serviceMethod1(){
+        try {
+            lock.lock();
+            System.out.println("ServiceMethod1 getHoldCount=" + lock.getHoldCount());
+            serviceMethod2();
+        }finally {
+            lock.unlock();
+        }
+    }
+
+    public void serviceMethod2(){
+        try {
+            lock.lock();
+            System.out.println("ServiceMethod2 getHoldCount=" + lock.getHoldCount());
+        }finally {
+            lock.unlock();
+        }
+    }
+
+
+
+}
diff --git a/src/main/java/cn/byhieg/threadtutorial/char04/ReadReadService.java b/src/main/java/cn/byhieg/threadtutorial/char04/ReadReadService.java
@@ -0,0 +1,27 @@
+package cn.byhieg.threadtutorial.char04;
+
+import java.util.concurrent.locks.ReentrantReadWriteLock;
+
+/**
+ * Created by byhieg on 17/1/28.
+ * Mail to byhieg@gmail.com
+ */
+public class ReadReadService {
+    private ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
+
+
+    public void read(){
+        try{
+            try{
+                lock.readLock().lock();
+                System.out.println("获得读锁" + Thread.currentThread().getName() +
+                " " + System.currentTimeMillis());
+                Thread.sleep(1000 * 10);
+            }finally {
+                lock.readLock().unlock();
+            }
+        }catch (InterruptedException e){
+            e.printStackTrace();
+        }
+    }
+}
diff --git a/src/main/java/cn/byhieg/threadtutorial/char04/ReadWriteService.java b/src/main/java/cn/byhieg/threadtutorial/char04/ReadWriteService.java
@@ -0,0 +1,42 @@
+package cn.byhieg.threadtutorial.char04;
+
+import java.util.concurrent.locks.ReentrantReadWriteLock;
+
+/**
+ * Created by byhieg on 17/1/28.
+ * Mail to byhieg@gmail.com
+ */
+public class ReadWriteService {
+    private ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
+
+    public void read(){
+        try{
+            try{
+                lock.readLock().lock();
+                System.out.println("获得读锁" + Thread.currentThread().getName()
+                + " " + System.currentTimeMillis());
+                Thread.sleep(1000 * 10);
+            }finally {
+                lock.readLock().unlock();
+            }
+        }catch (InterruptedException e){
+            e.printStackTrace();
+        }
+    }
+
+   public void write(){
+        try{
+            try{
+                lock.writeLock().lock();
+                System.out.println("获得写锁" + Thread.currentThread().getName()
+                + " " + System.currentTimeMillis());
+                Thread.sleep(1000 * 10);
+            }finally {
+                lock.writeLock().unlock();
+            }
+        }catch (InterruptedException e){
+            e.printStackTrace();
+        }
+    }
+
+}
diff --git a/src/main/java/cn/byhieg/threadtutorial/char04/WriteReadService.java b/src/main/java/cn/byhieg/threadtutorial/char04/WriteReadService.java
@@ -0,0 +1,43 @@
+package cn.byhieg.threadtutorial.char04;
+
+import java.util.concurrent.locks.ReentrantReadWriteLock;
+
+/**
+ * Created by byhieg on 17/1/28.
+ * Mail to byhieg@gmail.com
+ */
+public class WriteReadService {
+
+    private ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
+
+    public void read(){
+        try{
+            try{
+                lock.readLock().lock();
+                System.out.println("获得读锁" + Thread.currentThread().getName()
+                        + " " + System.currentTimeMillis());
+                Thread.sleep(1000 * 10);
+            }finally {
+                lock.readLock().unlock();
+            }
+        }catch (InterruptedException e){
+            e.printStackTrace();
+        }
+    }
+
+    public void write(){
+        try{
+            try{
+                lock.writeLock().lock();
+                System.out.println("获得写锁" + Thread.currentThread().getName()
+                        + " " + System.currentTimeMillis());
+                Thread.sleep(1000 * 10);
+            }finally {
+                lock.writeLock().unlock();
+            }
+        }catch (InterruptedException e){
+            e.printStackTrace();
+        }
+    }
+
+}
diff --git a/src/main/java/cn/byhieg/threadtutorial/char04/WriteWriteService.java b/src/main/java/cn/byhieg/threadtutorial/char04/WriteWriteService.java
@@ -0,0 +1,26 @@
+package cn.byhieg.threadtutorial.char04;
+
+import java.util.concurrent.locks.ReentrantReadWriteLock;
+
+/**
+ * Created by byhieg on 17/1/28.
+ * Mail to byhieg@gmail.com
+ */
+public class WriteWriteService {
+    private ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
+
+    public void write(){
+        try{
+            try{
+                lock.writeLock().lock();
+                System.out.println("获得写锁" + Thread.currentThread().getName() +
+                        " " +System.currentTimeMillis());
+                Thread.sleep(1000 * 10);
+            }finally {
+                lock.writeLock().unlock();
+            }
+        }catch (InterruptedException e){
+            e.printStackTrace();
+        }
+    }
+}
diff --git a/src/test/java/cn/byhieg/threadtutorialtest/char04test/HoldCountServiceTest.java b/src/test/java/cn/byhieg/threadtutorialtest/char04test/HoldCountServiceTest.java
@@ -0,0 +1,19 @@
+package cn.byhieg.threadtutorialtest.char04test;
+
+import cn.byhieg.threadtutorial.char04.HoldCountService;
+import junit.framework.TestCase;
+
+/**
+ * Created by byhieg on 17/1/27.
+ * Mail to byhieg@gmail.com
+ */
+public class HoldCountServiceTest extends TestCase {
+    public void testServiceMethod1() throws Exception {
+
+        HoldCountService service = new HoldCountService();
+        service.serviceMethod1();
+
+        Thread.sleep(1000 * 5);
+    }
+
+}
diff --git a/src/test/java/cn/byhieg/threadtutorialtest/char04test/ReadReadServiceTest.java b/src/test/java/cn/byhieg/threadtutorialtest/char04test/ReadReadServiceTest.java
@@ -0,0 +1,24 @@
+package cn.byhieg.threadtutorialtest.char04test;
+
+import cn.byhieg.threadtutorial.char04.ReadReadService;
+import junit.framework.TestCase;
+
+/**
+ * Created by byhieg on 17/1/28.
+ * Mail to byhieg@gmail.com
+ */
+public class ReadReadServiceTest extends TestCase {
+    public void testRead() throws Exception {
+        ReadReadService service = new ReadReadService();
+        Thread a = new Thread(service::read);
+        a.setName("A");
+
+        Thread b = new Thread(service::read);
+        b.setName("B");
+
+        a.start();
+        b.start();
+
+    }
+
+}
diff --git a/src/test/java/cn/byhieg/threadtutorialtest/char04test/ReadWriteServiceTest.java b/src/test/java/cn/byhieg/threadtutorialtest/char04test/ReadWriteServiceTest.java
@@ -0,0 +1,27 @@
+package cn.byhieg.threadtutorialtest.char04test;
+
+import cn.byhieg.threadtutorial.char04.ReadWriteService;
+import junit.framework.TestCase;
+
+/**
+ * Created by byhieg on 17/1/28.
+ * Mail to byhieg@gmail.com
+ */
+public class ReadWriteServiceTest extends TestCase {
+    public void testRead() throws Exception {
+
+        ReadWriteService service = new ReadWriteService();
+        Thread a = new Thread(service::read);
+        a.setName("AA");
+        a.start();
+        Thread.sleep(1000);
+
+        Thread b = new Thread(service::write);
+        b.setName("BB");
+
+
+        b.start();
+        Thread.sleep(1000 * 30);
+    }
+
+}
diff --git a/src/test/java/cn/byhieg/threadtutorialtest/char04test/WriteReadServiceTest.java b/src/test/java/cn/byhieg/threadtutorialtest/char04test/WriteReadServiceTest.java
@@ -0,0 +1,27 @@
+package cn.byhieg.threadtutorialtest.char04test;
+
+import cn.byhieg.threadtutorial.char04.WriteReadService;
+import cn.byhieg.threadtutorial.char04.WriteWriteService;
+import junit.framework.TestCase;
+
+/**
+ * Created by byhieg on 17/1/28.
+ * Mail to byhieg@gmail.com
+ */
+public class WriteReadServiceTest extends TestCase {
+    public void testWrite() throws Exception {
+
+        WriteReadService service = new WriteReadService();
+        Thread a = new Thread(service::write);
+        a.setName("A");
+        a.start();
+        Thread.sleep(1000);
+
+        Thread b = new Thread(service::read);
+        b.setName("B");
+        b.start();
+
+        Thread.sleep(1000 * 30);
+    }
+
+}
diff --git a/src/test/java/cn/byhieg/threadtutorialtest/char04test/WriteWriteServiceTest.java b/src/test/java/cn/byhieg/threadtutorialtest/char04test/WriteWriteServiceTest.java
@@ -0,0 +1,23 @@
+package cn.byhieg.threadtutorialtest.char04test;
+
+import cn.byhieg.threadtutorial.char04.WriteWriteService;
+import junit.framework.TestCase;
+
+/**
+ * Created by byhieg on 17/1/28.
+ * Mail to byhieg@gmail.com
+ */
+public class WriteWriteServiceTest extends TestCase {
+    public void testWrite() throws Exception {
+        WriteWriteService service = new WriteWriteService();
+        Thread a = new Thread(service::write);
+        a.setName("A");
+        Thread b = new Thread(service::write);
+        b.setName("B");
+
+        a.start();
+        b.start();
+        Thread.sleep(1000 * 30);
+    }
+
+}
