Описание тега fork-join

Fork-Join означает разделение работы на фрагменты и объединение результатов. Вы можете разделить работу на компоненты и запланировать каждый компонент для пула потоков, объединяя результаты, когда все компоненты будут завершены. Вы можете рекурсивно разбить агрегированную структуру на идентичные задачи и объединить результаты, когда все задачи будут выполнены.
1 ответ

Как использовать более одного метода Compute в ForkJoin Framework Javaello

Мне нужно решить более простую проблему. Мне нужно решить параллельное суммирование 1000 случайных значений X и 1000 случайных значений Y. Я использую Parallel ForkJoin фреймворк Java. При использовании метода с одним вычислением невозможно вычислит…
08 дек '11 в 22:36
4 ответа

Java ForkJoin Многопоточный медленнее, чем один поток

Я опробовал среду Java ForkJoin и написал простую тестовую программу, которая устанавливает пиксели изображения в случайные цвета. Например, он генерирует псевдошум. Но во время тестирования производительности я обнаружил, что на самом деле быстрее …
22 дек '12 в 03:01
2 ответа

forkJoin Firebase Observable не завершена

Так что я пытался использовать forkJoin с массивом Observable от Firebase, но, кажется, они не завершены. Я пытался подать заявку .first() или же .take(1) поскольку оно должно завершить наблюдаемое, но, похоже, ничего не меняет. getChat(userTwoId: s…
05 мар '18 в 13:23
1 ответ

Поддерживает ли OmnithreadLibrary "кражу работы"?

Кража работ, например, доступна в среде Fork / Join на платформе Java. (См. Чем инфраструктура fork/join лучше, чем пул потоков?) - возможно ли нечто подобное с OmniThreadLibrary? Воровство работы: рабочие потоки, у которых заканчиваются дела, могут…
06 июл '12 в 16:51
1 ответ

Выполнение длительной задачи с использованием fork-join занимает почти то же время, что и однопоточная программа

Я пытаюсь преобразовать каждый элемент массива длиной 10,00,00,000. Мой первый подход заключается в использовании одного потока в простом основном методе. Мой следующий подход заключается в использовании java-структуры fork-join путем деления массив…
25 дек '18 в 15:59
0 ответов

Akka fork join executor потребляет 100 % CPU

У меня есть система актеров с четырьмя активными супервайзерами, которые охватывают несколько дочерних актеров. Каждую минуту актер будет получать показания, которые будут рассчитываться и храниться в MongoDB. Все было сделано из будущих звонков. Во…
11 фев '19 в 18:24
4 ответа

Ресурсы по будущей структуре fork-join

Я ищу хорошо организованные источники информации о том, как можно использовать предстоящие jsr166y (fork-join, fences) и extras166y (ParallelArray и т. Д.) - что-то от учебного до экспертного уровня.
18 июл '09 в 17:49
2 ответа

Невозможно получить доступ к данным из компонента в HTML в Angular

Я использую Observable.forkjoin для отправки нескольких запросов http и сохраняю результат в переменной, но не могу получить доступ к результату в формате html. Может ли кто-нибудь, пожалуйста, помогите. Service.ts: addedProductIdArray : string[] =[…
10 апр '18 в 07:40
2 ответа

Использование java fork-join executor для доступа к БД

ForkJoinTask явно вызывает "Подразделяемые задачи также не должны выполнять блокирующий ввод / вывод". Его основная цель - "вычислительные задачи, вычисляющие чистые функции или работающие на чисто изолированных объектах". Мой вопрос: Зачем разраба…
0 ответов

Fork Join неправильно сортирует

Я пытаюсь сделать адаптацию сортировки слиянием, используя соединение вилки. Я использую это как пример разветвления / соединения, поэтому мне нужно, чтобы он был базовым. Я хочу отредактировать обычную сортировку слиянием так, чтобы, когда размер с…
2 ответа

Разница между Fork/Join и Map/Reduce

В чем ключевое различие между Fork/Join и Map/Reduce? Различаются ли они по типу разложения и распределения (данные против вычислений)?
29 мар '10 в 13:34
2 ответа

Как фреймворки java fork -join распределяют задачи по процессору?

Может кто-нибудь объяснить, как фреймворки java fork-join распределяют задачи для процессора. Можем ли мы это контролировать?
22 мар '11 в 17:47
1 ответ

Используйте fork-and-join в JDK6

Как я понимаю, в jdk7 есть поддержка fork-and-join. Могу ли я использовать fork-and-join в JDK6 без обновления до JDK7.0?
21 ноя '11 в 00:04
1 ответ

Проблема с MergeMap с forkJoin Angular 5

Я пытаюсь выполнить 5 параллельных HTTP-запросов с mergeMap и forkJoin условно. Для меня только первый API выполняется, а остальные API не запускаются. моя функция выполнит первый API, и если он вернет статус "NOT_FOUND", то мне нужно выполнить еще …
01 авг '18 в 08:33
1 ответ

RecursiveTask Throwing StackruError При выполнении ForkJoin

Я разработал RecursiveTask Вот код для задачи, которую я разработал. public class SearchTask extends RecursiveTask<Map<Short, Long>> { private static final long serialVersionUID = 1L; private int majorDataThreshold = 16001; private Concu…
05 апр '18 в 08:04
1 ответ

Java 7: пример Fork/Join - правильно ли я понял?

Я запачкаю руки с помощью функции параллелизма и параллелизма Java 7 - Fork/Join Framework. Я пытаюсь отобразить список всех каталогов по указанному пути. Может кто-нибудь сказать мне, правильно ли я понял? Вот мой основной класс - JoinForkExample, …
19 июл '12 в 04:18
1 ответ

Создание нескольких потоков с использованием Java RecursiveTasks

Поэтому я пытаюсь ознакомиться с параллельным программированием в Java, поэтому я написал следующий код public class Test{ public static void main(String[] args){ ForkJoinPool pool = new ForkJoinPool(); pool.invoke(new Agent()); } } class thread ext…
22 мар '14 в 17:23
1 ответ

Как долго средневзвешенное значение должно занимать Apache Ignite?

В настоящее время я тестирую Appache Ignite для приложения, работающего практически в реальном времени, и простые операции кажутся чрезмерно медленными при относительно небольшом размере выборки. Ниже приводятся подробности настройки и сроки - смотр…
1 ответ

Прервать RecursiveTask с заданным результатом?

Я сталкиваюсь со следующей проблемой: Я пересекаюсь с ConcurrentHashMap с помощью RecursiveAction для разделения и захвата карты. Проблема в том, что мне нужно вернуть первый результат, найденный по определенным критериям, или, если ничего не найден…
2 ответа

Логика фреймворка Java / соединения

Это стало побочным эффектом ответа на другой вопрос сегодня. Это больше о любопытстве, чем о реальной проблеме. Java SE 7 предлагает то, что Oracle называет "инфраструктурой fork/join". Это, по-видимому, лучший способ планирования работы с нескольки…