Threads, consommateurs & producteurs, problème de synchronisation.
Salut,
Voilà j'essaye de faire une émulation de buffer (TP d'université). Je vous mets ci dessous une partie fonctionnelle incomplète (sachant que je gère aussi des délais fictifs d'attente pour chaque producteurs et consommateurs)
Le buffer contient 4 espaces destinés à 4 lettres.
Un producteur envoie en une lettre au buffer, si celui-ci est plein, le thread se met en attente (wait), sinon il l'insere en première position et décale les autres.
Un consommateur extraie une lettre du buffer (il prend la 4ème si elle n'est pas nulle, ou 3ème, ou seconde ou première) mais si celui-ci est vide il se met en attente (wait).
Le programme fonctionne lorsque j'ai:
- 1 consommateur & 1 producteur
- 2 consommateurs & 1 producteur
Cela ne fonctionne pas lorsque j'ai:
- 1 consommateur & 2 producteurs
Voici mon code:
Classe correspondant au buffer:
Code:
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
|
class Q {
int n;
String a = null;
String b = null;
String c = null;
String d = null;
synchronized String get() {
if(d==null && c==null && b==null && a==null)
try {
wait();
} catch(InterruptedException e) {
System.out.println("InterruptedException caught");
}
if(d!=null)
{
String temp = null;
temp = d;
d = null;
notify();
System.out.println("Got: " + temp);
return temp;
}
else if(c!=null)
{
String temp = null;
temp = c;
c = null;
notify();
System.out.println("Got: " + temp);
return temp;
}
else if(b!=null)
{
String temp = null;
temp = b;
b = null;
notify();
System.out.println("Got: " + temp);
return temp;
}
else if(a!=null)
{
String temp = null;
temp = a;
a = null;
notify();
System.out.println("Got: " + temp);
return temp;
}
else
{
return null;
}
}
synchronized void put(String n) {
if(a!=null && b!=null && c!=null && d!=null)
try {
wait();
} catch(InterruptedException e) {
System.out.println("InterruptedException caught");
}
if(d==null || c==null || b==null || a==null)
{
d = c;
c = b;
b = a;
a = n;
}
System.out.println("Put: " + n);
notify();
}
} |
Producteur et consommateur:
Code:
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
|
class Producer implements Runnable {
Q q;
public String processedString = "";
private String getNextCharacter() {
String temp = processedString;
String cs = null;
if(temp!=null)
{
try {
cs = temp.substring(0,1);
processedString = temp.substring(1, temp.length());
} catch(Exception e) {
return null;
}
}
return cs;
}
Producer(Q q, String s) {
this.processedString = s;
this.q = q;
new Thread(this, "Producer"+s).start();
}
public void run() {
while(true) {
String character = this.getNextCharacter();
if(character!=null)
q.put(character);
}
}
}
class Consumer implements Runnable {
Q q;
Consumer(Q q) {
this.q = q;
new Thread(this, "Consumer").start();
}
public void run() {
while(true) {
q.get();
}
}
} |
Main:
Code:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
|
class PCFixed {
public static void main(String args[]) {
Q q = new Q();
new Producer(q,"IVEHEARDTHEREWASASECRETCHORD");
//new Producer(q, "XYXYXYXYXYXYXYXYXYX");
new Consumer(q);
//new Consumer(q);
System.out.println("Press Control-C to stop.");
}
}
class Test
{
public static void main(String args[])
{
PCFixed p = new PCFixed();
p.main(args);
}
} |
Toute aide est grandement appréciée :mouarf:, je vais aussi chercher de mon coté cet après midi.
