Форум программистов, компьютерный форум, киберфорум
Java SE (J2SE)
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
 Аватар для Sma6nta
5 / 3 / 1
Регистрация: 12.05.2019
Сообщений: 201

Многопоточность. Покритикуйте

11.06.2019, 14:48. Показов 509. Ответов 5
Метки нет (Все метки)

Студворк — интернет-сервис помощи студентам
ищем простые числа на заданном промежутке, задавая кол-во потоков, равномерно деля работу между ними.
потоки должны стартовать одновременно и сохранив результат работы в один массив напечатать его.
у меня получилось вот что:


работает.
но, проблема в том что по мнению тренера там должны быть notify, wait и даже без join там не обойтись.
А я не понимаю для чего их туда вписывать ведь потоки запускаются одновременно и потом synchronized запись/вывод результата, подозреваю что у меня там проблема в построении логики происходящего.

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
public class StartSearch {
 
    private static Scanner sc;
 
    public static void main(String[] args) {
 
        System.out.println("You are welcomed by the most powerful computing device of our time."
                + "\n  Enter the minimum range number");
        int minNumber = userChoice();
        System.out.println("\n Enter the maximum range number");
        int maxNumber = userChoice();
        System.out.println("\n Enter the number of threads: ");
        int quantityStreams = userChoice();
 
        int[] commonArr = new int[maxNumber];
        System.out.println(
                "\n Attention! Below you can observe the solemn conclusion of a single final array of all primes of the entire specified range:");
        int[] coordinate = new int[quantityStreams * 2];
        Runnable[] r = new JThread[quantityStreams];
        for (int i = 0; i < coordinate.length; i = i + 2) {
            if (i == 0) {
                coordinate[i] = minNumber;
                coordinate[i + 1] = minNumber + (int) ((maxNumber - minNumber) / quantityStreams);
            } else {
                coordinate[i] = coordinate[i - 1] + 1;
                coordinate[i + 1] = coordinate[i - 1] + (int) ((maxNumber - minNumber) / quantityStreams);
            }
        }
        coordinate[quantityStreams * 2 - 1] = maxNumber;
        for (int i = 0; i < quantityStreams; i++) {
            if (i == 0) {
                r[i] = new JThread(coordinate[i], coordinate[i + 1], commonArr);
                new Thread(r[i]).start();
            } else {
                r[i] = new JThread(coordinate[i * 2], coordinate[i * 2 + 1], commonArr);
                new Thread(r[i]).start();
            }
        }
    }
 
    public static int userChoice() {
        sc = new Scanner(System.in);
        int scan = sc.nextInt();
        return scan;
    }
}

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
class JThread implements Runnable {
 
    private int min;
    private int max;
    private int[] commonArr;
 
    public JThread(int min, int max, int[] commonArr) {
        this.min = min;
        this.max = max;
        this.commonArr = commonArr;
    }
 
    public void run() {
        for (int n = getMin(); n <= getMax(); n++) {
            boolean isPrime = true;
            for (int i = 2; i < n; i++) {
                if ((n % i) == 0) {
                    isPrime = false;
                }
            }
            if (isPrime & n > 1) {
                writeInCommonArr(n, getMax());
            } else
                System.out.print("");
        }
    }
 
    public synchronized void writeInCommonArr(int n, int max) {
        for (int i = 0; i < getMax(); i++) {
            if (commonArr[i] == 0) {
                commonArr[i] = n;
                System.out.println(n);
                return;
            }
        }
    }
 
    public int getMin() {
        return min;
    }
 
    public void setMin(int min) {
        this.min = min;
    }
 
    public int getMax() {
        return max;
    }
 
    public void setMax(int max) {
        this.max = max;
    }
 
}
0
cpp_developer
Эксперт
20123 / 5690 / 1417
Регистрация: 09.04.2010
Сообщений: 22,546
Блог
11.06.2019, 14:48
Ответы с готовыми решениями:

Покритикуйте новичка
Доброго всем времени суток! Самоучкой пытаюсь освоить Java, общение с опытными программистами или преподавателями недоступно. Остаётся...

Покритикуйте код
Всем привет. У меня есть обычный POJO-класс с полями и класс для работы с данной коллекцией объектов. Посоветуйте плс, как улучшить...

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

5
528 / 263 / 70
Регистрация: 11.12.2016
Сообщений: 1,223
11.06.2019, 15:15
Цитата Сообщение от Sma6nta Посмотреть сообщение
но, проблема в том что по мнению тренера там должны быть notify, wait и даже без join там не обойтись.
А я не понимаю для чего их туда вписывать ведь потоки запускаются одновременно и потом synchronized запись/вывод результата,
Ну тут все просто, по логике вы знаете что делают notify, wait, join, и synchronized. И я просто понял из названия метода на котором повесили synchronized что он прав (подсказка : у вас многопоточная программа). А это я даже не смотрел остальной код (не хочу разбыратся в вашем да и сам не силен в этой теме), но мне кажется что там надо синхронизировать не метод, а объект (напримет массив).
0
 Аватар для Sma6nta
5 / 3 / 1
Регистрация: 12.05.2019
Сообщений: 201
11.06.2019, 15:47  [ТС]
а в чем немногопоточность моей? Она многопоточно вычисляет нужные цифры и потоки получая по очереди доступ к массиву вписывают в него результат.

можно конечно сам массив вписать в run, но проблемы с индексацией предвижу я...
0
Эксперт Java
3639 / 2971 / 918
Регистрация: 05.07.2013
Сообщений: 14,220
11.06.2019, 16:16
перепиши на forkjoin xD
Вообще тебе надо потокам раздать задания, дождаться, пока они все завершатся. И только после этого напечатать результат.
0
 Аватар для Lumber
345 / 141 / 51
Регистрация: 02.12.2015
Сообщений: 333
11.06.2019, 17:27
Как я понимаю диапазон сразу делится на равные части и каждый поток получает свою часть, а далее они работают независимо. Я думаю это не то что нужно т.к. во-первых равные диапазоны не значит равное время вычисления каждого диапазона и соответственно часть вычислений будет производится меньшим числом потоков чем задано. Во-вторых это учебное задание и в нём должно отрабатываться взаимодействие потоков, а имеющемся варианте этого почти нет.

Я подозреваю что требуется сделать примерно так: один поток берет число и начинает проверять, подходит другой смотрит какие числа ещё не проверяли и берет из них первое. И результаты скидывали в какую-то общую кучу (ну это и сейчас так). Тогда появляется какое-то взаимодействие потоков (но wait notify я всё равно не вижу чтобы были необходимы).

Ещё лучше чтобы потоки не по одному числу брали, а некоторый поддиапазон небольшого размера чтобы им реже приходилось синхронизироваться.
0
 Аватар для Sma6nta
5 / 3 / 1
Регистрация: 12.05.2019
Сообщений: 201
11.06.2019, 18:03  [ТС]
перепиши на forkjoin xD
Вообще тебе надо потокам раздать задания, дождаться, пока они все завершатся. И только после этого напечатать результат.
это ничего не изменит. это просто будет цикл в мейне по выводу этого массива. Ну да, перед ним прийдеться написать джойн.
и все.
Если ничего хитрее не предложат то так и сделаю)
Я подозреваю что требуется сделать примерно так: один поток берет число и начинает проверять, подходит другой смотрит какие числа ещё не проверяли и берет из них первое. И результаты скидывали в какую-то общую кучу (ну это и сейчас так). Тогда появляется какое-то взаимодействие потоков (но wait notify я всё равно не вижу чтобы были необходимы).

Ещё лучше чтобы потоки не по одному числу брали, а некоторый поддиапазон небольшого размера чтобы им реже приходилось синхронизироваться.
не( тут все ок. диапазоны именно так как надо сделаны и розданы
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
raxper
Эксперт
30234 / 6612 / 1498
Регистрация: 28.12.2010
Сообщений: 21,154
Блог
11.06.2019, 18:03
Помогаю со студенческими работами здесь

Алгоритм: Трамвайные билеты. Покритикуйте
Привет, решение данной задачи на Java. Покритикуйте. package olympicexercises; import java.io.*; import java.util.*; import...

Задачи на числа. Решение. Покритикуйте. (часть №1)
Привет, решение данных заданий на Java - ниже. Покритикуйте. package chapt01.b; import java.util.*; import static...

Задачи на строки и числа. Решение. Покритикуйте
Задачи: Привет, решение данных заданий на Java - см. ссылку ниже. Покритикуйте. import java.io.InputStream; import...

Покритикуйте код моего сокет сервера для игрового чата
С помощью пары уроков, сделал сервер для визуального чата, типа галактики знакомств. Интересны советы по упрощению и оптимизации. Там...

Многопоточность
У меня есть класс в нем куча функций мне нужно что б эти функции работали одновременно если так можно киньте набросок. Работаю в ДжаваФХ...


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

Или воспользуйтесь поиском по форуму:
6
Ответ Создать тему
Новые блоги и статьи
Подключение Box2D v3 к SDL3 для Android: физика и отрисовка коллайдеров
8Observer8 29.01.2026
Содержание блога Box2D - это библиотека для 2D физики для анимаций и игр. С её помощью можно определять были ли коллизии между конкретными объектами. Версия v3 была полностью переписана на Си, в. . .
Инструменты COM: Сохранение данный из VARIANT в файл и загрузка из файла в VARIANT
bedvit 28.01.2026
Сохранение базовых типов COM и массивов (одномерных или двухмерных) любой вложенности (деревья) в файл, с возможностью выбора алгоритмов сжатия и шифрования. Часть библиотеки BedvitCOM Использованы. . .
Загрузка PNG с альфа-каналом на SDL3 для Android: с помощью SDL_LoadPNG (без SDL3_image)
8Observer8 28.01.2026
Содержание блога SDL3 имеет собственные средства для загрузки и отображения PNG-файлов с альфа-каналом и базовой работы с ними. В этой инструкции используется функция SDL_LoadPNG(), которая. . .
Загрузка PNG с альфа-каналом на SDL3 для Android: с помощью SDL3_image
8Observer8 27.01.2026
Содержание блога SDL3_image - это библиотека для загрузки и работы с изображениями. Эта пошаговая инструкция покажет, как загрузить и вывести на экран смартфона картинку с альфа-каналом, то есть с. . .
Влияние грибов на сукцессию
anaschu 26.01.2026
Бифуркационные изменения массы гриба происходят тогда, когда мы уменьшаем массу компоста в 10 раз, а скорость прироста биомассы уменьшаем в три раза. Скорость прироста биомассы может уменьшаться за. . .
Воспроизведение звукового файла с помощью SDL3_mixer при касании экрана Android
8Observer8 26.01.2026
Содержание блога SDL3_mixer - это библиотека я для воспроизведения аудио. В отличие от инструкции по добавлению текста код по проигрыванию звука уже содержится в шаблоне примера. Нужно только. . .
Установка Android SDK, NDK, JDK, CMake и т.д.
8Observer8 25.01.2026
Содержание блога Перейдите по ссылке: https:/ / developer. android. com/ studio и в самом низу страницы кликните по архиву "commandlinetools-win-xxxxxx_latest. zip" Извлеките архив и вы увидите. . .
Вывод текста со шрифтом TTF на Android с помощью библиотеки SDL3_ttf
8Observer8 25.01.2026
Содержание блога Если у вас не установлены Android SDK, NDK, JDK, и т. д. то сделайте это по следующей инструкции: Установка Android SDK, NDK, JDK, CMake и т. д. Сборка примера Скачайте. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru