-
-
Notifications
You must be signed in to change notification settings - Fork 300
/
1117.java
101 lines (91 loc) · 2.55 KB
/
1117.java
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
__________________________________________________________________________________________________
sample 3 ms submission
import java.util.concurrent.locks.*;
import java.util.concurrent.*;
public class H2O {
private int wH, wO;
private Lock lock;
private Condition waitingH, waitingO, barrier;
private int aH, aO;
public H2O() {
wH = 0;
wO = 0;
aH = 0;
aO = 0;
lock = new ReentrantLock();
waitingH = lock.newCondition();
waitingO = lock.newCondition();
barrier = lock.newCondition();
}
public void hydrogen(Runnable releaseHydrogen) throws InterruptedException {
lock.lock();
try {
wH++;
// while not allowed to leave
while (aH == 0) {
if (wH >= 2 && wO >= 1) {
if (aO > 0) {
barrier.await();
}
wH-=2; aH+=2;
wO-=1; aO+=1;
waitingH.signal();
waitingO.signal();
} else {
waitingH.await();
barrier.signal();
}
}
aH--;
} finally {
releaseHydrogen.run();
lock.unlock();
}
}
public void oxygen(Runnable releaseOxygen) throws InterruptedException {
lock.lock();
try {
wO++;
while (aO == 0) {
if (wH >= 2 && wO >= 1) {
if (aH > 0) {
barrier.await();
}
wH-=2; aH+=2;
wO-=1; aO+=1;
waitingH.signal();
waitingH.signal();
} else {
waitingO.await();
barrier.signal();
}
}
aO--;
} finally {
releaseOxygen.run();
lock.unlock();
}
}
}
__________________________________________________________________________________________________
sample 13 ms submission
import java.util.concurrent.Semaphore;
class H2O {
Semaphore h, o;
volatile boolean flag = false;
public H2O() {
h = new Semaphore(2, true);
o = new Semaphore(0, true);
}
public void hydrogen(Runnable releaseHydrogen) throws InterruptedException {
h.acquire();
releaseHydrogen.run();
o.release();
}
public void oxygen(Runnable releaseOxygen) throws InterruptedException {
o.acquire(2);
releaseOxygen.run();
h.release(2);
}
}
__________________________________________________________________________________________________