一、ReentrantLock
1 package com.ietree.basicskill.mutilthread.lock;
2
3 import java.util.concurrent.locks.Lock;
4 import java.util.concurrent.locks.ReentrantLock;
5
6 /**
7 * Created by Administrator on 2017/5/17.
8 */
9 public class UseReentrantLock {
10
11 private Lock lock = new ReentrantLock();
12
13 public void method1(){
14 try {
15 lock.lock();
16 System.out.println("当前线程:" + Thread.currentThread().getName() + "进入method1..");
17 Thread.sleep(1000);
18 System.out.println("当前线程:" + Thread.currentThread().getName() + "退出method1..");
19 Thread.sleep(1000);
20 } catch (InterruptedException e) {
21 e.printStackTrace();
22 } finally {
23
24 lock.unlock();
25 }
26 }
27
28 public void method2(){
29 try {
30 lock.lock();
31 System.out.println("当前线程:" + Thread.currentThread().getName() + "进入method2..");
32 Thread.sleep(2000);
33 System.out.println("当前线程:" + Thread.currentThread().getName() + "退出method2..");
34 Thread.sleep(1000);
35 } catch (InterruptedException e) {
36 e.printStackTrace();
37 } finally {
38
39 lock.unlock();
40 }
41 }
42
43 public static void main(String[] args) {
44
45 final UseReentrantLock ur = new UseReentrantLock();
46 Thread t1 = new Thread(new Runnable() {
47 @Override
48 public void run() {
49 ur.method1();
50 ur.method2();
51 }
52 }, "t1");
53
54 t1.start();
55 try {
56 Thread.sleep(10);
57 } catch (InterruptedException e) {
58 e.printStackTrace();
59 }
60 //System.out.println(ur.lock.getQueueLength());
61 }
62
63 }
二、ReentrantReadWriteLock
1 package com.ietree.basicskill.mutilthread.lock;
2
3 import java.util.concurrent.locks.ReentrantReadWriteLock;
4
5 /**
6 * Created by Administrator on 2017/5/17.
7 */
8 public class UseReentrantReadWriteLock {
9
10 private ReentrantReadWriteLock rwLock = new ReentrantReadWriteLock();
11 private ReentrantReadWriteLock.ReadLock readLock = rwLock.readLock();
12 private ReentrantReadWriteLock.WriteLock writeLock = rwLock.writeLock();
13
14 public void read(){
15 try {
16 readLock.lock();
17 System.out.println("当前线程:" + Thread.currentThread().getName() + "进入...");
18 Thread.sleep(3000);
19 System.out.println("当前线程:" + Thread.currentThread().getName() + "退出...");
20 } catch (Exception e) {
21 e.printStackTrace();
22 } finally {
23 readLock.unlock();
24 }
25 }
26
27 public void write(){
28 try {
29 writeLock.lock();
30 System.out.println("当前线程:" + Thread.currentThread().getName() + "进入...");
31 Thread.sleep(3000);
32 System.out.println("当前线程:" + Thread.currentThread().getName() + "退出...");
33 } catch (Exception e) {
34 e.printStackTrace();
35 } finally {
36 writeLock.unlock();
37 }
38 }
39
40 public static void main(String[] args) {
41
42 final UseReentrantReadWriteLock urrw = new UseReentrantReadWriteLock();
43
44 Thread t1 = new Thread(new Runnable() {
45 @Override
46 public void run() {
47 urrw.read();
48 }
49 }, "t1");
50 Thread t2 = new Thread(new Runnable() {
51 @Override
52 public void run() {
53 urrw.read();
54 }
55 }, "t2");
56 Thread t3 = new Thread(new Runnable() {
57 @Override
58 public void run() {
59 urrw.write();
60 }
61 }, "t3");
62 Thread t4 = new Thread(new Runnable() {
63 @Override
64 public void run() {
65 urrw.write();
66 }
67 }, "t4");
68
69 // t1.start();
70 // t2.start();
71
72 // t1.start(); // R
73 // t3.start(); // W
74
75 t3.start();
76 t4.start();
77 }
78 }
三、Condition
1 package com.ietree.basicskill.mutilthread.lock;
2
3 import java.util.concurrent.locks.Condition;
4 import java.util.concurrent.locks.Lock;
5 import java.util.concurrent.locks.ReentrantLock;
6
7 /**
8 * Created by Administrator on 2017/5/17.
9 */
10 public class UseCondition {
11 private Lock lock = new ReentrantLock();
12 private Condition condition = lock.newCondition();
13
14 public void method1(){
15 try {
16 lock.lock();
17 System.out.println("当前线程：" + Thread.currentThread().getName() + "进入等待状态..");
18 Thread.sleep(3000);
19 System.out.println("当前线程：" + Thread.currentThread().getName() + "释放锁..");
20 condition.await(); // Object wait
21 System.out.println("当前线程：" + Thread.currentThread().getName() +"继续执行...");
22 } catch (Exception e) {
23 e.printStackTrace();
24 } finally {
25 lock.unlock();
26 }
27 }
28
29 public void method2(){
30 try {
31 lock.lock();
32 System.out.println("当前线程：" + Thread.currentThread().getName() + "进入..");
33 Thread.sleep(3000);
34 System.out.println("当前线程：" + Thread.currentThread().getName() + "发出唤醒..");
35 condition.signal(); //Object notify
36 } catch (Exception e) {
37 e.printStackTrace();
38 } finally {
39 lock.unlock();
40 }
41 }
42
43 public static void main(String[] args) {
44
45 final UseCondition uc = new UseCondition();
46 Thread t1 = new Thread(new Runnable() {
47 @Override
48 public void run() {
49 uc.method1();
50 }
51 }, "t1");
52 Thread t2 = new Thread(new Runnable() {
53 @Override
54 public void run() {
55 uc.method2();
56 }
57 }, "t2");
58 t1.start();
59
60 t2.start();
61 }
62 }
四、ManyCondition
1 package com.ietree.basicskill.mutilthread.lock;
2
3 import java.util.concurrent.locks.Condition;
4 import java.util.concurrent.locks.ReentrantLock;
5
6 /**
7 * Created by Administrator on 2017/5/17.
8 */
9 public class UseManyCondition {
10 private ReentrantLock lock = new ReentrantLock();
11 private Condition c1 = lock.newCondition();
12 private Condition c2 = lock.newCondition();
13
14 public void m1(){
15 try {
16 lock.lock();
17 System.out.println("当前线程：" +Thread.currentThread().getName() + "进入方法m1等待..");
18 c1.await();
19 System.out.println("当前线程：" +Thread.currentThread().getName() + "方法m1继续..");
20 } catch (Exception e) {
21 e.printStackTrace();
22 } finally {
23 lock.unlock();
24 }
25 }
26
27 public void m2(){
28 try {
29 lock.lock();
30 System.out.println("当前线程：" +Thread.currentThread().getName() + "进入方法m2等待..");
31 c1.await();
32 System.out.println("当前线程：" +Thread.currentThread().getName() + "方法m2继续..");
33 } catch (Exception e) {
34 e.printStackTrace();
35 } finally {
36 lock.unlock();
37 }
38 }
39
40 public void m3(){
41 try {
42 lock.lock();
43 System.out.println("当前线程：" +Thread.currentThread().getName() + "进入方法m3等待..");
44 c2.await();
45 System.out.println("当前线程：" +Thread.currentThread().getName() + "方法m3继续..");
46 } catch (Exception e) {
47 e.printStackTrace();
48 } finally {
49 lock.unlock();
50 }
51 }
52
53 public void m4(){
54 try {
55 lock.lock();
56 System.out.println("当前线程：" +Thread.currentThread().getName() + "唤醒..");
57 c1.signalAll();
58 } catch (Exception e) {
59 e.printStackTrace();
60 } finally {
61 lock.unlock();
62 }
63 }
64
65 public void m5(){
66 try {
67 lock.lock();
68 System.out.println("当前线程：" +Thread.currentThread().getName() + "唤醒..");
69 c2.signal();
70 } catch (Exception e) {
71 e.printStackTrace();
72 } finally {
73 lock.unlock();
74 }
75 }
76
77 public static void main(String[] args) {
78
79
80 final UseManyCondition umc = new UseManyCondition();
81 Thread t1 = new Thread(new Runnable() {
82 @Override
83 public void run() {
84 umc.m1();
85 }
86 },"t1");
87 Thread t2 = new Thread(new Runnable() {
88 @Override
89 public void run() {
90 umc.m2();
91 }
92 },"t2");
93 Thread t3 = new Thread(new Runnable() {
94 @Override
95 public void run() {
96 umc.m3();
97 }
98 },"t3");
99 Thread t4 = new Thread(new Runnable() {
100 @Override
101 public void run() {
102 umc.m4();
103 }
104 },"t4");
105 Thread t5 = new Thread(new Runnable() {
106 @Override
107 public void run() {
108 umc.m5();
109 }
110 },"t5");
111
112 t1.start(); // c1
113 t2.start(); // c1
114 t3.start(); // c2
115
116
117 try {
118 Thread.sleep(2000);
119 } catch (InterruptedException e) {
120 e.printStackTrace();
121 }
122
123 t4.start(); // c1
124 try {
125 Thread.sleep(2000);
126 } catch (InterruptedException e) {
127 e.printStackTrace();
128 }
129 t5.start(); // c2
130
131 }
132 }
时间： 2024-08-06 11:36:02