Вопросы по теме 'fork-join'
Координация параллельного выполнения в node.js
Модель программирования node.js, управляемая событиями, несколько усложняет координацию выполнения программы.
Простое последовательное выполнение превращается во вложенные обратные вызовы, что достаточно легко (хотя и немного запутано для записи)....
36576 просмотров
schedule
10.03.2022
Интересные примеры Fork/Join или Divide and Conquer
Мы хотим продемонстрировать новый JDK7 Fork/Join Framework на семинаре конференции. Для этого мы сейчас ищем интересный пример того, что можно сделать с помощью фреймворка.
Есть очевидные, такие как сортировка или матричные вычисления, но есть и...
291 просмотров
schedule
10.08.2022
Вычисление факториала через DnC
Я пытаюсь реализовать факториальную функцию с помощью стратегии «разделяй и властвуй». Я использовал инфраструктуру ForkJoin для разветвления каждой рекурсивной задачи, чтобы ускорить вычисления. Но я обнаружил, что это не ускоряется, как я ожидал....
923 просмотров
schedule
23.02.2023
Создание пользовательского java.util.concurrent.ForkJoinTask‹V›
В настоящее время я оцениваю различные решения параллелизма для решения бизнес-проблемы. Вариант использования сродни алгоритму «смущающе-параллельного».
По сути, для одного запроса пользователя нам нужно получить данные из нескольких разных...
821 просмотров
schedule
19.05.2022
scala.concurrent.forkjoin.ForkJoinPool против java.util.concurrent.ForkJoinPool
Почему ForkJoinPool был создан для Scala?
Какая реализация и для какого случая предпочтительнее?
1960 просмотров
schedule
02.05.2022
Почему эта простая вилка Java не работает?
Я собираюсь протестировать этот пул forkjoin, но он не работает нормально. Интересно, почему?
Это класс, который я сделал, чтобы получить массив и добавить 3 к его элементам:
import static java.util.concurrent.ForkJoinTask.invokeAll;
import...
1861 просмотров
schedule
03.02.2023
Можно ли в Java 7+ ForkJoinPool отменить задачу и все подзадачи?
Моя программа ищет решение (любое решение) проблемы с помощью подхода «разделяй и властвуй», реализованного с использованием рекурсии и RecursiveTasks : я разветвляю задачу для первой ветви разделения, затем рекурсивно выполняю вторую ветвь: если...
3592 просмотров
schedule
17.06.2022
Прервать RecursiveTask с заданным результатом?
Я столкнулся со следующей проблемой:
Я взаимодействую с ConcurrentHashMap с помощью RecursiveAction для разделения и завоевания карты.
Проблема в том, что мне нужно вернуть первый результат, найденный для определенного критерия, или, если ничего...
124 просмотров
schedule
29.12.2022
Когда сплитератор должен прекратить расщепление?
Я понимаю, что существует накладные расходы на настройку параллельной обработки Stream , и этой обработки в одиночный поток выполняется быстрее, если элементов мало или обработка каждого элемента выполняется быстро.
Но существует ли аналогичный...
540 просмотров
schedule
05.06.2022
Является ли фреймворк Fork-Join в Java 8 лучшим вариантом?
У меня есть сценарий, как будто я хочу прочитать электронную таблицу, состоящую примерно из 2000 записей, и ввести ее в базу данных.
В настоящее время мы используем фреймворк Executor. У нас есть ограничение, что количество задач должно быть...
161 просмотров
schedule
14.04.2022
Observable.forkJoin и аргумент массива
В документации Observables forkJoin говорится, что args может быть массивом, но в нем не приведен пример этого:
https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/operators/forkjoin.md
Я пробовал функцию, аналогичную той, что...
77735 просмотров
schedule
07.08.2022
Как разветвить три разных задания, которые используют один и тот же общий workflow.xml с разным списком параметров?
Я новичок в экосистеме Hadoop. Я пытаюсь разветвить три разных задания, которые я хочу вызывать из одного и того же общего файла workflow.xml, но передаю разные параметры каждому из подпроцессов.
Подпроцесс:
<?xml version="1.0"...
596 просмотров
schedule
01.04.2022
Angular 2/4 Обработка ошибок в URL-адресе forkjoin
Я использую angular 2, и я использую forkjoin для одного из сценариев, где мне приходится выполнять несколько вызовов отдыха параллельно. Ниже приведена моя функция.
private getBatchObservableData(data: Array<Widget>): Observable<any>...
2023 просмотров
schedule
06.06.2023
Oozie присоединяется, когда одно из разветвленных действий успешно
У меня есть рабочий процесс oozie, который начинается с вилки с двумя действиями watcher1 и watcher2. Мне нужно продолжить соединение, как только один из них, т. е. watcher1 или watcher2, будет успешным.
Есть ли что-то в oozie, что я могу сделать...
98 просмотров
schedule
26.06.2022
Создание адаптивного уточнения сетки с помощью ForkJoin и Streams
Я хочу построить адаптивное уточнение сетки в 3D.
Основной принцип заключается в следующем:
У меня есть набор ячеек с уникальными идентификаторами ячеек. Я проверяю каждую ячейку, чтобы увидеть, нужно ли ее уточнять.
Если требуется уточнение,...
117 просмотров
schedule
22.01.2024
Как реализовать многопоточную сортировку MergeSort в Java
Большинство примеров сортировки слиянием, которые я нахожу, выполняются в одном потоке. Это в первую очередь сводит на нет некоторые преимущества использования алгоритма сортировки слиянием. Может ли кто-нибудь показать, как правильно написать...
1688 просмотров
schedule
15.01.2023
fork/join, синхронизация необходима для входного массива?
У меня есть большой массив объектов, и я хочу собрать все объекты с определенным значением поля, и поскольку это такой большой массив, я планирую использовать fork/join в java.
большой массив разветвляется не путем создания новых подсписков, а...
423 просмотров
schedule
19.07.2023
forkJoin не привязывает данные к внешнему интерфейсу в Angular 6
Мне нужно сделать несколько запросов HTTP из моего компонента, чтобы загрузить разные разделы во внешнем интерфейсе.
Запросы нужно делать один за другим, поэтому для этого я использовал forkJoin .
Я успешно получаю данные, как и ожидалось....
462 просмотров
schedule
20.02.2023
Как объединить несколько наблюдаемых значений с помощью forkjoin, чтобы получить одно наблюдаемое значение
Пытаюсь получить Observable<boolean> для моего Guard, объединив два значения Observable<boolean> через forkJoin .
Я пробовал этот подход раньше:
isAllowedToEditSession(sessionId: number): Observable<boolean> {...
300 просмотров
schedule
06.11.2022
Как обрабатывать вложенные HTTP-запросы в Angular 7?
У меня есть общий сервис для получения данных с сервера. Когда ответ получен, я использую функцию сопоставления для сопоставления чистых данных JSON с требуемой моделью. Для некоторого типа класса в функции сопоставления мне нужно получить...
158 просмотров
schedule
18.05.2023
