-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathMember.java
More file actions
109 lines (89 loc) · 2.11 KB
/
Member.java
File metadata and controls
109 lines (89 loc) · 2.11 KB
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
package bells;
import javax.sound.sampled.SourceDataLine;
public class Member implements Runnable
{
Thread[] bells;
BellNote current;
boolean occupied;
Conductor.Note[] notes = new Conductor.Note[2];
int memberNum; //must be 1 or greater
SourceDataLine line;
public static final Object Lock = new Object();
Member(int memberNum, Conductor.Note note0, Conductor.Note note1)
{
this.memberNum = memberNum;
occupied = false;
notes[0] = note0;
notes[1] = note1;
bells = new Thread[2];
bells[0] = new Thread(this);
bells[1] = new Thread(this);
bells[0].start();
bells[1].start();
}
public void run()
{
while(true)
{
synchronized (Lock)
{
while(!occupied)
{
try {
Lock.wait();
Lock.wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
playNote(line,current);
occupied = false;
Lock.notifyAll();
}
}
}
public void play(SourceDataLine line, int noteNum, Conductor.NoteLength length)
{
this.line = line;
int threadIndex = noteNum;
current = new BellNote(notes[noteNum], length);
System.out.println("Member Number " + memberNum + " is playing a "
+ notes[noteNum] + " as a " + length);
}
class BellNote
{
final Conductor.Note note;
final Conductor.NoteLength length;
BellNote(Conductor.Note note, Conductor.NoteLength length)
{
this.note = note;
this.length = length;
}
}
private void playNote(SourceDataLine line, BellNote bn)
{
final int ms = Math.min(bn.length.timeMs(), Note.MEASURE_LENGTH_SEC * 1000);
final int actualLength = Note.SAMPLE_RATE * ms / 1000;
line.write(bn.note.sample(), 0, actualLength);
line.write(Note.REST.sample(), 0, 50);
}
public void occupy()
{
synchronized (Lock){
Lock.notifyAll();
occupied = true;
}
}
public void free()
{
synchronized (Lock){
Lock.notifyAll();
occupied = false;
}
}
public boolean getOccupied()
{
return occupied;
}
}