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

Настройка GC при использовании Executors
У меня есть серверное приложение, которое использует cachedThreadPool ( Executors.newCachedThreadPool . Но я вижу падение производительности из-за частых сборок мусора, которые могут очищать потоки от cachedpool . Есть ли способ настроить сборщик...
63 просмотров

Как получить идентификатор потока из пула потоков?
У меня есть фиксированный пул потоков, в который я отправляю задачи (ограничено 5 потоками). Как узнать, какой из этих 5 потоков выполняет мою задачу (что-то вроде «эту задачу выполняет поток № 3 из 5 »)? ExecutorService taskExecutor =...
204125 просмотров

Исполнители искры apache и местоположение данных
В искровой литературе говорится Каждое приложение получает свои собственные процессы-исполнители, которые остаются активными на протяжении всего приложения и выполняют задачи в нескольких потоках. И если я правильно понимаю, при...
445 просмотров
schedule 23.04.2022

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

Потоки исполнителей не завершаются
Я использую метод Executors.newFixedThreadPool(100). Для выполнения одной команды требуется около 20 потоков. После выполнения команды 5-6 раз приложение перестает отвечать. Мой поток реализует Callable. Я сомневаюсь, что этот поток не...
2630 просмотров
schedule 04.07.2023

Как я могу временно приостановить вызов задачи, когда очередь исполнителя заполнена
У меня есть ряд задач, которые принимают данные, а затем по завершении обработки перемещают их в другую задачу. Каждая задача имеет свою собственную службу Executor, инициализированную как int workerSize =...
157 просмотров
schedule 05.03.2023

ThreadPool/Executor как для Runnable, так и для Callable - который может автоматически выходить из java8
Я пытаюсь использовать ThreadPoolExecutor/ExecutorService в своем приложении - это статический глобальный объект. Я использую: Executors.newScheduledThreadPool(corePoolSize) - но у меня проблемы с закрытием executorService. Если я не вызову...
208 просмотров

Spark: Executor Lost Failure (после добавления groupBy job)
Я пытаюсь запустить задание Spark на клиенте Yarn. У меня два узла, и каждый узел имеет следующие конфигурации. Я получаю сообщение «ExecutorLostFailure (исполнитель 1 потерян)». Я испробовал большую часть конфигурации настройки Spark. Я...
1409 просмотров

Используйте исполнителей для массового обновления с помощью весенней загрузки
Используйте исполнителей для массового обновления. Попробуйте сохранить 10-20 записей в базе данных с помощью исполнителей. используя spring boot jpa hibernate. Пожалуйста, помогите мне, как действовать
319 просмотров
schedule 03.04.2024