Описание тега forkjoinpool
Используйте этот тег для вопросов, связанных с ForkJoinPool, классом Java, который обеспечивает точку входа для отправлений от клиентов, не относящихся к ForkJoinTask, а также для операций управления и мониторинга.
0
ответов
Уязвимость Fork-Join для статической переменной Java
Почему статические переменные уязвимы, но другие переменные не используются при использовании fork join в Java. Предположим, что класс A имеет две переменные public static int count = 1; public int c=1; сейчас в классе рекурсивного действия B @Overr…
29 июн '17 в 13:36
0
ответов
Почему java ForkJoinPool по умолчанию ограничивает параметр параллелизма
Это конструктор по умолчанию для ForkJoinPool. public ForkJoinPool() { this(Math.min(MAX_CAP, Runtime.getRuntime().availableProcessors()), defaultForkJoinWorkerThreadFactory, null, false); } И это все аргумент конструктора. public ForkJoinPool(int p…
10 июн '17 в 22:49
1
ответ
Проверьте, обрабатывается ли запрос, отправленный на пользовательский ForkJoinPool, немедленно
У меня есть список объектов Отправления, и мне нужно совершать вызовы API, чтобы получить некоторую информацию о каждой Отправке. Я пытаюсь сделать эти сетевые вызовы параллельно. Поэтому я использую Java 8 parallelStream() и отправив его на заказ F…
23 май '17 в 15:23
2
ответа
Параллельный поток не устанавливает Thread.contextClassLoader после обновления tomcat
После обновления tomcat с 8.5.6 до 8.5.28 параллельный поток прекратил предоставлять потокам contextClassLoader: Из-за этого Warmer::run не могу загрузить классы в нем. warmers.parallelStream().forEach(Warmer::run); Есть ли у вас какие-либо идеи о т…
05 мар '18 в 12:28
2
ответа
Фибоначчи с помощью Fork Join в Java 7
Это программа для Фибоначчи, использующая Java 7 ForkJoin . Но похоже, что есть мертвый замок. package ForkJoin; import java.time.LocalTime; import java.util.concurrent.ForkJoinPool; import java.util.concurrent.RecursiveTask; import static java.time…
19 июл '18 в 04:32
1
ответ
Задача очереди ParallelStream в CommonPool, а не в пользовательском пуле
Я хотел использовать пользовательский ThreadPool для parallelStream. Причина в том, что я хотел использовать MDCContext в этой задаче. Вот код, который я написал для использования пользовательского ThreadPool: final ExecutorService mdcPool = MDCExec…
16 окт '18 в 13:07
2
ответа
Использование java fork-join executor для доступа к БД
ForkJoinTask явно вызывает "Подразделяемые задачи также не должны выполнять блокирующий ввод / вывод". Его основная цель - "вычислительные задачи, вычисляющие чистые функции или работающие на чисто изолированных объектах". Мой вопрос: Зачем разраба…
26 фев '15 в 21:54
0
ответов
Управление параллелизмом и вложенными параллельными коллекциями scala
Мне очень трудно понять это поведение параллельных коллекций в Scala. import java.util.concurrent.TimeUnit import scala.collection.parallel.ForkJoinTaskSupport object test extends App { val CHANGE_ME = false val externalParallelism = if (CHANGE_ME) …
30 окт '17 в 22:16
0
ответов
Когда вызывается метод compute() при использовании RecursiveAction/RecursiveTask
Я нашел следующий фрагмент кода для RecursiveAction онлайн, и мне было интересно, когда compute() вызывается. import java.util.ArrayList; import java.util.List; import java.util.concurrent.RecursiveAction; public class MyRecursiveAction extends Recu…
11 ноя '17 в 20:16
2
ответа
Проблема времени объединения пула Java Fork
Я пытаюсь реализовать Fork Join Pool, который будет брать потомков одного узла и исследовать их одновременно. Тем не менее, я думаю, что мой пул соединений форка выполняет потоки, а затем завершает работу слишком быстро, вызывая прекращение выполнен…
29 апр '15 в 14:59
1
ответ
Размер пула потоков RecursiveAction
Я только что увидел использование для Java 7 RecursiveAction.invokeAll(), и мне интересно: Каков размер пула задач? (или алгоритм, который определяет это..) Если у меня много заданий (скажем, 100 заданий), следует ли мне их использовать?
14 сен '14 в 12:03
2
ответа
Параллельный Судоку Солвер на Яве
У меня есть домашнее задание, которое требует реализации последовательной и параллельной версии решателя судоку в Java (используя платформу ForkJoin для параллельной). Я написал последовательный, и он отлично работает. Алгоритмическая идея представл…
25 дек '16 в 14:49
2
ответа
Поведение ForkJoinPool в CompletableFuture.supplyAsync()
Я сравниваю поведение CompletableFuture.supplyAsync() в двух случаях, когда я устанавливаю пользовательский ExecutorService или я хочу, чтобы мой поставщик выполнялся по умолчанию (если не указан), то есть ForkJoinPool.commonPool() Давайте посмотрим…
04 янв '19 в 08:01
1
ответ
Java Fork-Join не работает с большим ArrayList
Я довольно плохо знаком с параллелизмом и параллелизмом и пытаюсь реализовать алгоритм медианного фильтра, используя Fork-Join в Java. По сути, я считываю входной файл в ArrayList и использую этот список для генерации нового ArrayList отфильтрованны…
11 авг '15 в 16:31
4
ответа
Как использовать ForkJoinPool в Spring Boot @Async?
Я хочу использовать ForkJoinPool в моем весеннем загрузочном проекте с аннотацией @Async, например ThreadPoolTaskExecutor Например:- @Bean("threadPoolTaskExecutor") public TaskExecutor getAsyncExecutor() { ThreadPoolTaskExecutor executor = new Threa…
25 янв '19 в 12:12
0
ответов
Настройка ForkJoinPool в приложении SBT
Как описано в https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ForkJoinPool.html для настройки ForkJoinPool ThreadFactory Мне нужно запустить Java с дополнительным параметром java.util.concurrent.ForkJoinPool.common.threadFactory=MyThr…
29 янв '19 в 13:29
1
ответ
Влияние на производительность параллельных потоков Java
Каковы лучшие практики использования .stream().parallel()? Например, если у вас есть куча блокирующих вызовов ввода / вывода, и вы хотите проверить, .anyMatch(...)Делать это параллельно кажется разумной вещью. Пример кода: public boolean hasAnyRecen…
07 фев '19 в 19:26
1
ответ
Правильное использование параллельных потоков в Java
Я экспериментирую с параллельными потоками в Java, и для этого у меня есть следующий код для вычисления числа простых чисел перед n, В основном у меня есть 2 метода calNumberOfPrimes(long n) - 4 разных варианта isPrime(long n) - 2 разных варианта На…
24 фев '19 в 07:13
0
ответов
Веб-приложение Spring и асинхронные исполнения с использованием пула потоков
У меня есть весеннее приложение, которое выступает в качестве оркестратора, в обязанности которого входит объединение результатов 6+ других весенних веб-приложений, результаты которых являются взаимно исключающими друг друга, что означало, что кажды…
13 сен '18 в 18:12
0
ответов
Как использовать универсальную реализацию ForkJoinPool
Ниже приведена утилита класса Java, которую я должен использовать для запуска двух параллельных задач: public final class ForkJoinGameTools { private static final ForkJoinPool defaultPool; private static final long TIME_OUT = 1; private static final…
12 апр '18 в 21:42