JavaInterviewQuestion/src/codingInterview/thread/ABC.java at master · jating4you/JavaInterviewQuestion · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
package codingInterview.thread;

import java.util.concurrent.locks.ReentrantLock;

class ClassABC {
	static String abc;
};

public class ABC {
	static enum EnumABC {
		A, C, B
	};

	public static void main(String[] args) {

		ReentrantLock rlock = new ReentrantLock(true);
		// 1. new ReentrantLock(boolean fairness); FCFC
		// 2. false ... Can't expect
		// lock interface
		ClassABC.abc = "A";
		new AThread(rlock).start();
		new BThread(rlock).start();
		new CThread(rlock).start();

	}

}

class AThread extends Thread {
	ReentrantLock rlock;

	public AThread(ReentrantLock rlock) {
		super();
		this.rlock = rlock;

	}

	@Override
	public void run() {

		while (true) {
			rlock.lock();
			try {
				if ("A".equalsIgnoreCase(ClassABC.abc)) {
					System.out.print(ClassABC.abc);
					ClassABC.abc = "B";
				} else {
//					System.out.println(a);
				}

			} finally {
				rlock.unlock();

				try {
					// rlock.wait();
					sleep(100);
				} catch (InterruptedException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
		}

	}

}

class BThread extends Thread {
	ReentrantLock rlock;

	public BThread(ReentrantLock rlock) {
		super();
		this.rlock = rlock;

	}

	@Override
	public void run() {
		while (true) {
			rlock.lock();
			try {

				if ("B".equalsIgnoreCase(ClassABC.abc)) {
					System.out.print(ClassABC.abc);
					ClassABC.abc = "C";
				}

			} finally {
				rlock.unlock();
				try {
					// rlock.wait();
					sleep(100);
				} catch (InterruptedException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}

			}
		}

	}

}

class CThread extends Thread {
	ReentrantLock rlock;

	public CThread(ReentrantLock rlock) {
		super();
		this.rlock = rlock;

	}

	@Override
	public void run() {
		while (true) {
			rlock.lock();
			try {
				if ("C".equalsIgnoreCase(ClassABC.abc)) {
					System.out.print(ClassABC.abc);
					ClassABC.abc = "A";
				}

			} finally {
				rlock.unlock();

				try {
//					rlock.wait();
					sleep(100);
				} catch (InterruptedException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}

			}
		}

	}

}