Форум программистов, компьютерный форум, киберфорум
Java
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
Рейтинг 4.75/8: Рейтинг темы: голосов - 8, средняя оценка - 4.75
0 / 0 / 0
Регистрация: 25.05.2015
Сообщений: 10

Параллельные потоки в чем соль?

23.09.2017, 10:53. Показов 1718. Ответов 5

Студворк — интернет-сервис помощи студентам
Есть задание:
Значения констант и реализуемые потоками функции:
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 не выводится и программа опять же умирает. Не могу понять что я делаю не так.
0
IT_Exp
Эксперт
34794 / 4073 / 2104
Регистрация: 17.06.2006
Сообщений: 32,602
Блог
23.09.2017, 10:53
Ответы с готовыми решениями:

GlassFish Realm и соль
Здравствуйте! В GlassFish есть realms, которые позволят легко реализовать аутентификацию. Но нет встроенных средств для реализации...

Вся соль в изменении знака
Нужно построить сплайн по введенным точкам. Все уже готово, но есть проблема: если эти точки меняют знак, рисуется не то, что надо. Короче,...

Параллельные потоки
Доброго времени суток, знатоки! Есть задача, написать программу, со сложными и объемными вычислениями, я не хочу нагружать никого, по...

5
Эксперт Java
3639 / 2971 / 918
Регистрация: 05.07.2013
Сообщений: 14,220
23.09.2017, 14:16
Цитата Сообщение от excess Посмотреть сообщение
что я делаю не так
пытаешься писать код наугад, вместо того, чтобы почитать доки и разобраться, как оно работает
0
0 / 0 / 0
Регистрация: 25.05.2015
Сообщений: 10
23.09.2017, 14:25  [ТС]
остроумный ответ конечно
0
Эксперт Java
3639 / 2971 / 918
Регистрация: 05.07.2013
Сообщений: 14,220
23.09.2017, 15:11
Цитата Сообщение от excess Посмотреть сообщение
остроумный ответ конечно
допустим, что конвенция не соблюдается по ошибке и ты что-то знаешь про джаву и понимаешь, что ты делаешь.
Объясни, с какой целью вот тут стоит synchronized.
Цитата Сообщение от excess Посмотреть сообщение
public synchronized void generation
0
0 / 0 / 0
Регистрация: 25.05.2015
Сообщений: 10
23.09.2017, 15:25  [ТС]
Ну насколько я знаю в принципе wait и notify должны быть прописаны в синхронизированном блоке или методе.
А смысл его в блокировке объектов от других потоков. Ну это насколько я понимаю.
0
Эксперт функциональных языков программированияЭксперт Java
 Аватар для korvin_
4575 / 2774 / 491
Регистрация: 28.04.2012
Сообщений: 8,779
23.09.2017, 21:28
excess, возьми какую-нибудь реализацию java.util.concurrent.BlockingQueue и не парь себе мозг. Ты адовую кашу написал.

Цитата Сообщение от excess Посмотреть сообщение
Второй поток - извлекает числа из первого буфера, начиная с последнего в буфере
Это вообще какой-то идиотизм, ИМХО.
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
BasicMan
Эксперт
29316 / 5623 / 2384
Регистрация: 17.02.2009
Сообщений: 30,364
Блог
23.09.2017, 21:28
Помогаю со студенческими работами здесь

Параллельные потоки
Доброй ночи! необходимо написать пример, показывающий параллельную активность потоков. вот если я сделаю так: class Thread_1 :...

Параллельные потоки
Может кто-нибудь подсказать, как написать программу, в которой с какой-то определенной точки работают параллельно, например, три потока?...

Параллельные потоки в QT
Здравствуйте! Я новичок в QT,ранее почти не работал с потоками, хотелось бы навести справки как правильно пользоваться...

Таймер и параллельные потоки
Добрый день, сразу оговорюсь, что прошёлся поиском по темам с запросом &quot;таймер&quot;, &quot;потоки&quot; и т.д. Разрабатываю...

Параллельные потоки и исключения
Здравствуйте всем! Хочу спросить у вас по поводу хорошей практики: работа параллельных потоков с исключениями. По моему...


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
6
Ответ Создать тему
Новые блоги и статьи
Символьное дифференцирование
igorrr37 13.02.2026
/ * Логарифм записывается как: (x-2)log(x^2+2) - означает логарифм (x^2+2) по основанию (x-2). Унарный минус обозначается как ! в-строка - входное арифметическое выражение в инфиксной(обычной). . .
Камера Toupcam IUA500KMA
Eddy_Em 12.02.2026
Т. к. у всяких "хикроботов" слишком уж мелкий пиксель, для подсмотра в ESPriF они вообще плохо годятся: уже 14 величину можно рассмотреть еле-еле лишь на экспозициях под 3 секунды (а то и больше),. . .
И ясному Солнцу
zbw 12.02.2026
И ясному Солнцу, и светлой Луне. В мире покоя нет и люди не могут жить в тишине. А жить им немного лет.
«Знание-Сила»
zbw 12.02.2026
«Знание-Сила» «Время-Деньги» «Деньги -Пуля»
SDL3 для Web (WebAssembly): Подключение Box2D v3, физика и отрисовка коллайдеров
8Observer8 12.02.2026
Содержание блога Box2D - это библиотека для 2D физики для анимаций и игр. С её помощью можно определять были ли коллизии между конкретными объектами и вызывать обработчики событий столкновения. . . .
SDL3 для Web (WebAssembly): Загрузка PNG с прозрачным фоном с помощью SDL_LoadPNG (без SDL3_image)
8Observer8 11.02.2026
Содержание блога Библиотека SDL3 содержит встроенные инструменты для базовой работы с изображениями - без использования библиотеки SDL3_image. Пошагово создадим проект для загрузки изображения. . .
SDL3 для Web (WebAssembly): Загрузка PNG с прозрачным фоном с помощью SDL3_image
8Observer8 10.02.2026
Содержание блога Библиотека SDL3_image содержит инструменты для расширенной работы с изображениями. Пошагово создадим проект для загрузки изображения формата PNG с альфа-каналом (с прозрачным. . .
Установка Qt-версии Lazarus IDE в Debian Trixie Xfce
volvo 10.02.2026
В общем, достали меня глюки IDE Лазаруса, собранной с использованием набора виджетов Gtk2 (конкретно: если набирать текст в редакторе и вызвать подсказку через Ctrl+Space, то после закрытия окошка. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru