Публикации по теме 'executorservice'
Демонстрация MapReduce с использованием Java
Что такое MapReduce
Модель программирования, используемая для эффективной параллельной обработки больших наборов данных распределенным образом.
Данные сначала разделяются, обрабатываются и объединяются для получения окончательного результата.
Задача уменьшения карты в основном делится на две фазы:
Фаза сопоставления: здесь мы разделяем входные данные на фрагменты и обрабатываем эти фрагменты параллельно. Фаза уменьшения: выходные данные вышеуказанных фрагментов передаются в..
Вопросы по теме 'executorservice'
Executors.newCachedThreadPool() по сравнению с Executors.newFixedThreadPool()
newCachedThreadPool() по сравнению с newFixedThreadPool()
Когда я должен использовать тот или иной? Какая стратегия лучше с точки зрения использования ресурсов?
113133 просмотров
schedule
07.03.2023
Как дождаться завершения всех потоков, используя ExecutorService?
Мне нужно выполнять некоторое количество задач по 4 за раз, примерно так:
ExecutorService taskExecutor = Executors.newFixedThreadPool(4);
while(...) {
taskExecutor.execute(new MyTask());
}
//...wait for completion somehow
Как я могу...
365380 просмотров
schedule
03.07.2022
500 рабочих потоков, какой пул потоков?
Мне интересно, лучший ли это способ сделать это. У меня есть около 500 потоков, которые работают бесконечно, но Thread.sleep на минуту, когда выполняется один цикл обработки.
ExecutorService es = Executors.newFixedThreadPool(list.size()+1);...
5125 просмотров
schedule
09.07.2023
что происходит с запущенными/заблокированными runnables, когда executorservice выключен()
Сегодня я отправил вопрос о шаблоне потока, и почти все предлагали мне заглянуть в ExecutorService.
Пока я изучал ExecutorService, мне кажется, что я что-то упускаю. Что произойдет, если в службе есть запущенные или заблокированные потоки, и...
2302 просмотров
schedule
27.10.2022
Рабочие потоки ScheduledExecutorService сохраняют прерванный статус после FutureTask.cancel(true)
У меня есть задача, которую я планирую периодически запускать через ScheduledThreadPoolExecutor.scheduleAtFixedRate(task, rate, ...) . Пользователь может отменить эту задачу вручную, что вызывает ScheduledFuture.cancel(true) . По какой-то причине,...
1361 просмотров
schedule
17.04.2022
ThreadPool не выполняет задачи последовательно
Я использую фреймворк Executor специально Executors.newCachedThreadPool(); У меня есть список Runnable , например. 100. Каждое из первых 50 создает значение (хранящееся в списке), которое будет использоваться последними 50. Я подумал, что если я...
11575 просмотров
schedule
11.01.2023
Остановить периодическую задачу из самой задачи, выполняемой в ScheduledExecutorService
Есть ли хороший способ остановить повторение задачи из самой задачи при запуске в ScheduledExecutorService?
Допустим, у меня есть следующая задача:
Future<?> f = scheduledExecutor.scheduleAtFixedRate(new Runnable() {
int count = 0;...
13433 просмотров
schedule
07.06.2022
блокировать, пока ExecutorService не будет выполнен
Возможные дубликаты: ExecutorService , как дождаться завершения всех задач Java ExecutorService: awaitTermination всех рекурсивно созданных задач
Есть ли способ заблокировать текущий поток, пока ExecutorService не завершит все...
6179 просмотров
schedule
03.09.2023
Почему ExecutorService продолжает выполняться, когда потоки блокируются?
Я пытаюсь написать часть многопоточной программы, в которой каждый поток из фиксированного пула потоков пытается получить объект из очереди, и если очередь пуста, поток ждет.
Проблема, с которой я сталкиваюсь, заключается в том, что память,...
1349 просмотров
schedule
18.02.2023
ScheduledExecutorService несколько потоков параллельно
Я заинтересован в использовании ScheduledExecutorService для создания нескольких потоков для задач, если предыдущая задача еще не завершилась. Например, мне нужно обрабатывать файл каждые 0,5 секунды. Первая задача начинает обработку файла, через...
9879 просмотров
schedule
26.03.2022
ExecutorService замедляет многопоточную производительность
Я пытаюсь выполнить простой расчет (он вызывает Math.random() 10000000 раз). Удивительно, но запуск его в простом методе выполняется намного быстрее, чем при использовании ExecutorService.
Я прочитал еще один поток в удивительной точке...
6385 просмотров
schedule
17.07.2022
Потоки демона, запланированные для ExecutorService; объясните, почему это плохая форма
Меня устраивает идея упорядоченного завершения работы потоков, запланированных с помощью ExectuorService ; то есть вызов shutdown или shutdownNow приведет к корректному выходу потоков, созданных в пуле. Если они ответят на interrupt , вы...
16914 просмотров
schedule
24.03.2022
Java правильно использует ExecutorService, CompletionService, BlockingQueue и Observer?
Итак, я новичок в многопоточности и в последнее время использую эту идею во всех своих программах. Прежде чем я начну использовать его больше, я действительно хочу убедиться, что это правильный эффективный способ реализации многопоточности с...
2775 просмотров
schedule
07.08.2022
Akka/futures решает ли Akka, стоит ли использовать текущий поток или диспетчер?
В настоящее время я думаю об использовании Akka (Java API/библиотеки) для выполнения задачи создания нескольких Future и помещения их в BlockingQueue . Теперь может случиться так, что некоторые задачи, которые обрабатываются Callables,...
621 просмотров
schedule
21.04.2022
Ошибка OutOfMemory с FixedThreadPool и ExecutorCompletionService
Я работаю над приложением, которое должно получать список пользователей из базы данных и обновлять данные из каталога (ldap или AD). Я выполняю эту процедуру на многоядерной машине, поэтому я создал это приложение (код ниже). Я использую...
4921 просмотров
schedule
29.04.2022
Как прервать потоки ExecutorService
При использовании ExecutorService , возвращаемого Executors.newSingleThreadExecutor() , как его прервать?
30394 просмотров
schedule
06.01.2023
вызов ExecutorService.shutDown() в java
я начинаю изучать класс ExecutorService. В документации (и онлайн-учебниках) говорится, что для восстановления ресурсов всегда следует вызывать ExecutorService.shutDown(). однако в документации также говорится, что после вызова функции shutdown()...
3017 просмотров
schedule
09.12.2023
Дизайн для многопоточного клиента REST API
Я работаю над программой, которая получает поисковые запросы по теме, делает вызовы API к API New York Times для получения статей, связанных с этой темой, а затем к API Twitter для получения твитов, в которых упоминаются статьи, и, наконец,...
4568 просмотров
schedule
01.03.2023
Пулы потоков Java / служба исполнителя и ожидание () - что происходит с потоками и очередью задач?
Я огляделся, но не нашел ответа, поэтому я хотел подтвердить это наверняка.
Скажем, у меня есть пул потоков фиксированного размера - ExecutorService pool = Executors.newFixedThreadPool(5);
И у меня есть код:
pool.execute(new Runnable(){...
12864 просмотров
schedule
07.06.2023
Где перехватывать исключения из Callable.call ()
Возможный дубликат: Обработка исключений из задач Java ExecutorService
Я использую ExecutorService от Java для координации потоков. Для запуска потоков я использую
pool = new ExecutorService(2);
callableResults =...
36100 просмотров
schedule
23.04.2023
