blob: f1f454e2398ae5fb0a5e8404a87deeac3fe7d298 (
plain) (
blame)
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
|
/** Solution of exercise session 6 (first question). */
object semaphore {
import scala.concurrent.pilib._;
class Signal extends Chan[unit] {
def send = write(());
def receive = read;
}
/** Interface. */
trait Semaphore {
def get: unit;
def release: unit;
}
/** First implementation. */
class Sem1 extends Semaphore {
private val g = new Signal;
private val r = new Signal;
def get: unit = g.send;
def release: unit = r.send;
private def Sched: unit = choice (
g * (x => { r.receive; Sched }),
r * (x => Sched)
);
spawn< Sched >;
}
/** Second implementation. */
class Sem2 extends Semaphore {
private val a = new Signal;
private val na = new Signal;
def get: unit = { a.receive; spawn< na.send > }
def release: unit = choice (
a * (x => spawn< a.send >),
na * (x => spawn< a.send >)
);
spawn< a.send >;
}
/** Test program. */
def main(args: Array[String]): unit = {
val random = new java.util.Random();
val sem = new Sem2;
def mutex(def p: unit): unit = { sem.get; p; sem.release }
spawn< {
Thread.sleep(1 + random.nextInt(100));
mutex( {
System.out.println("a1");
Thread.sleep(1 + random.nextInt(100));
System.out.println("a2")
} )
} | {
Thread.sleep(1 + random.nextInt(100));
mutex( {
System.out.println("b1");
Thread.sleep(1 + random.nextInt(100));
System.out.println("b2")
} )
} >;
}
}
|
