Вопросы по теме 'forkjoinpool'

Почему ForkJoinPool :: invoke () блокирует основной поток?
Отказ от ответственности: я впервые использую платформу Java Fork-Join, поэтому я не на 100% уверен, что использую ее правильно. Java также не является моим основным языком программирования, так что это тоже может иметь значение. Учитывая...
1509 просмотров
schedule 29.10.2021

Какая польза от ForkJoinPool для Akka?
Документы Akka заявляют, что диспетчер по умолчанию - fork-join-executor , потому что он «дает отличную производительность в большинстве случаев». Мне интересно, почему это так? Из ForkJoinPool ForkJoinPool отличается от других видов...
1367 просмотров

Вызов JdbcTemplate batchUpdate () с помощью Java ForkJoinPool
Я искал способ оптимально обновить большое количество строк, поскольку операции orm оказались медленными. В конце концов, решение, которое я использовал в настоящее время, заключается в том, чтобы обернуть обновление базы данных через пакетное...
185 просмотров

ThreadPoolExecutor vs ForkJoinPool: кража подзадач
Из java-документов, ForkJoinPool отличается от других видов ExecutorService главным образом тем, что использует перехват работы: все потоки в пуле пытаются найти и выполнить подзадачи, созданные другими активными задачами (в конечном итоге...
7482 просмотров

Подробная разница между Java8 ForkJoinPool и Executors.newWorkStealingPool?
В чем разница на низком уровне между использованием: ForkJoinPool = new ForkJoinPool(X); а также ExecutorService ex = Executors.neWorkStealingPool(X); Где X — желаемый уровень параллелизма, т. е. количество запущенных потоков....
10624 просмотров

parallelStream() кажется тупиковым при вызове из блока static{}
У меня странный тупик, который, кажется, происходит только за пределами main() . static { init(); } private static final void init() { ForkJoinPool forkJoinPool = null; try {...
105 просмотров

Как произвести параллельную работу с потенциальными взаимодействиями с БД по списку
Я стараюсь, чтобы мой код работал более эффективно, поэтому я пытаюсь понять, как заставить его работать с Futures и ForkJoinPool. На данный момент у меня есть код, который работает так: @RestController @RequestMapping(SEND) @Slf4j public class...
25 просмотров

Почему CompletableFuture.runAsync() не всегда подчиняется ForkJoinPool.commonPool()?
CompletableFuture.runAsync указано: Возвращает новый CompletableFuture, который асинхронно завершается задачей, запущенной в ForkJoinPool.commonPool() после выполнения данного действия. Однако, насколько я могу судить, runAsync...
173 просмотров

Java ExecutorService — масштабирование
Я пытаюсь написать программу на Java, используя ExecutorService и ее функцию invokeAll . Мой вопрос: решает ли функция invokeAll задачи одновременно? В смысле, если у меня два процессора, будет два рабочих одновременно? Потому что я не могу...
776 просмотров

ForkJoinPool против простой рекурсии
Прочитав о ForkJoinPool , я попытался провести эксперимент, чтобы проверить, насколько быстро работает ForkJoinPool по сравнению с простой рекурсией. Я рекурсивно подсчитал количество файлов в папке, и, к моему удивлению, обычная рекурсия...
548 просмотров
schedule 07.01.2023

Какой исполнитель лучше передать CompletableFuture SupplyAsync Executors.newFixedThreadPool(10) или новый ForkJoinPool(10)
Я использую CompletableFuture.supplyAsync, я не хочу использовать Forkjoinpool.commonpool, я хочу передать ему пул. В настоящее время я создаю ссылку на статический пул и использую ее, потому что я не хочу создавать пул для каждого запроса. Я...
95 просмотров

Применить аспект к методу ForkJoinPool (управляемый компонент без Spring)
Я хочу скопировать и установить карту контекста MDC в поток, которым управляет ForkJoinPool в весеннем приложении. К сожалению, я не могу добавить aop для метода выполнения, потому что ForkJoinPool не является управляемым компонентом Spring. Я также...
74 просмотров
schedule 26.06.2023

Как настроить и настроить Akka Dispatchers
Я просматриваю документацию здесь: http://doc.akka.io/docs/akka/2.3.3/java/dispatchers.html Мы используем Akka таким образом, что у нас есть два отдельных диспетчера (исполнители fork-join по умолчанию) для разных участников. Теперь у нас...
6540 просмотров
schedule 04.12.2023

Нахождение самого большого числа с помощью ForkJoin
Без блока if delay == 2 работает, а с ним не работает. Вот расчет ForkJoin: compute() { if(lastElem - firstElem == 1) return array[firstElem]; if(lastElem - firstElem == 2){ if(array[firstElem] >...
141 просмотров
schedule 29.03.2024