-
Notifications
You must be signed in to change notification settings - Fork 0
/
Monitor2
110 lines (101 loc) · 3.42 KB
/
Monitor2
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
import java.util.concurrent.locks.Condition;
import java.io.FileNotFoundException;
import java.util.HashMap;
import java.util.ArrayList;
import java.io.File;
import java.util.Scanner;
public class Monitor2 extends Monitor1 {
public Condition sattInnSubSekvens;
public boolean terminate;
private int antallTråder;
ArrayList<Thread> fletteTråder;
String tf;
Monitor2(String infected) {
super();
sattInnSubSekvens = laas.newCondition();
terminate = false;
antallTråder = 8;
tf = infected;
fletteTråder = new ArrayList<Thread>();
for (int i = 0; i < antallTråder; i++) {
Thread tr = new Thread(new FletteTrad(this));
fletteTråder.add(tr);
tr.start();
}
}
public Beholder hentTo() {
System.out.println("henter to");
return new Beholder(register.hashBeholder.remove(0), register.hashBeholder.remove(0));
}
public void settInnFlettet(HashMap<String, Subsekvens> ferdig) {
register.hashBeholder.add(ferdig);
sattInnSubSekvens.signal();
System.out.println("sender signal");
}
public void lesMappe2(String mappe) throws FileNotFoundException {
lesMappe(mappe);
System.out.println("lest ferdig mappe");
//Denne delen av koden vil være tilgjengelig etter at alle lesetråder er ferdige.
//Skjekk om det bare er en hashmap igjen. Hvis det er bare en, send terminate. Hvis ikke, vent på oppdatering og sjekk igjen.
//Flette trådene vil refreshe frem til det terminate blir true.
laas.lock();
try{
while(antall() > 1){
sattInnSubSekvens.await();
}
terminate = true;
fletteTråder.forEach((tr) -> {
tr.interrupt();
});
}
catch(Exception e){
System.out.println(e);
}
finally{
laas.unlock();
}
}
public void lesMappe(String mappe) throws FileNotFoundException {
String loc = "./" + mappe + "/";
File metafFile = new File(loc + "metadata.csv");
Scanner scan = new Scanner(metafFile);
ArrayList<Thread> threads = new ArrayList<Thread>();
while (scan.hasNextLine()){
String linje = scan.nextLine();
String[] deler = linje.split(",");
String linjetf = deler[1].trim().toLowerCase();
if(linjetf.equals(tf)){
Thread mintr = new Thread(new LeseTrad(loc + deler[0], this));
threads.add(mintr);
System.out.println("laget lese tråd");
mintr.start();
}
}
threads.forEach((thr) -> {
try{
thr.join();
}
catch(Exception e){
System.out.println(e);
}
});
scan.close();
}
//En ekstra funksjonlitet på lesfil er bare å sende signalet at noe var satt inn
@Override
public HashMap<String,Subsekvens> lesFil(String fil){
laas.lock();
try{
HashMap<String,Subsekvens> r = register.lesFil(fil);
sattInnSubSekvens.signal();
return r;
}
catch(Exception e){
System.out.println("Problem med å lese fil. Error: " + e);
}
finally{
laas.unlock();
}
return new HashMap<String,Subsekvens>();
}
}