Есть задание:
Значения констант и реализуемые потоками функции:
o N=3
o Первый поток - генерирует в первый буфер 50 чисел из ряда 1/х, где х при-нимает значения от 1 до 50.
o Второй поток - извлекает числа из первого буфера, начиная с последнего в буфере, извлекает из него корень и помещает его во второй буфер.
o Третий поток - извлекает из второго буфера первое число, вычисляет значе-ние функции 1/х, где х - извлечённое число, и выводит это значение на экран. Третий по-ток завершает своё выполнение по окончании чисел во втором буфере.
Пишу код:
| 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
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
| public class buf {
int kol = 0;
int iteration1 = 0;
int iteration2 = 0;
int iteration3 = 0;
double y;
public synchronized void generation(){
if (buffer_1.size() >= 3){
try {
wait();
}
catch (InterruptedException e) {
}
} else{
y = 1.0/((double)kol + 1);
buffer_1.add(y);
iteration1++;
iteration++;
kol++;
System.out.println(/*dfDateAndTime.format(now) +*/ " Итерация:" + iteration + "/" + iteration1 + " Поток: 1 Записал в буфер 1: " + y);
notify();
}
}
public synchronized void quart(){
if ((buffer_1.size() > 0 && buffer_2.size() < 3)==false) {//если в буфере 1 есть хоть одно число
try {
wait();
}
catch (InterruptedException e) {
}
}else{
int indexLast = buffer_1.size() - 1;
double value = (double) buffer_1.get(indexLast);
buffer_1.remove(indexLast);
double value2 = Math.sqrt(value);
buffer_2.add(value2);
iteration2++;
iteration++;
System.out.println("Итерация:" + iteration + "/" + iteration2 + " Поток: 2 Записал в буфер 2: " + value2 + " удалил из буфера 1: " + value);
notify();
}
}
public synchronized void del(){
if (buffer_2.size() <= 0) {//если в буфере 2 есть хоть одно число
try {
wait();
}
catch (InterruptedException e) {
}
}else{
//извлекаем первое число
double value = (double) buffer_2.get(0);
buffer_2.remove(0);
double value2 = 1 / value;
iteration3++;
iteration++;
System.out.println("Итерация:" + iteration + "/" + iteration3 + " Поток: 3 Вычислил: " + value2 + " удалил из буфера 2: " + value);
notify();
}
}
}
public class Potok3 extends Thread {
buf potok = new buf();
@Override
public void run() {
while (threadActive2){
potok.del();
// notify();
}
}
}
public class Potok2 extends Thread {
buf potok = new buf();
@Override
public void run() {
while (threadActive1){
potok.quart();
// notify();
}
threadActive2 = false;
}
}
public class Potok1 extends Thread {
buf potok = new buf();
int kol = 0;
@Override
public void run() {
while (kol<=49){
potok.generation();
kol++;
// notify();
}
threadActive1 = false;
}
}
public static void main(String[] args) {
Potok1 newPotok1 = new Potok1();
Potok2 newPotok2 = new Potok2();
Potok3 newPotok3 = new Potok3();
//запускаем потоки
newPotok1.start();
newPotok2.start();
newPotok3.start();
try {
newPotok1.join();
newPotok2.join();
newPotok3.join();
} catch (InterruptedException x) {}
}
} |
|
Отрабатывает неправильно, иногда выводится только 3 итерации 1 потока и умирает программа, иногда выводится первый и 2 поток в параллель, но 3 не выводится и программа опять же умирает. Не могу понять что я делаю не так.
(
Сообщение от excess
