Вопросы по теме 'executorservice'
Остановить бесконечный цикл в задаче ExecutorService
import java.util.Arrays;
import java.util.Iterator;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import...
13042 просмотров
schedule
31.10.2023
Прерывание Java ExecutorService invokeAll()
У меня есть фиксированный пул потоков ExecutorService шириной 10 и список из 100 Callable , каждый из которых ждет 20 секунд и записывает свои прерывания.
Я вызываю invokeAll из этого списка в отдельном потоке и почти сразу прерываю этот...
4759 просмотров
schedule
28.07.2022
Ожидание завершения всех потоков перед завершением работы исполнителей
Вот мой фрагмент кода.
ExecutorService executor = Executors.newFixedThreadPool(ThreadPoolSize);
while(conditionTrue)
{
ClassImplementingRunnable c = new ClassImplementingRunnable();
executor.submit(c);
}
Теперь после этого...
15822 просмотров
schedule
10.09.2022
ExecutorService, который отменяет текущую задачу при отправке новых
Рассмотрим пользовательский интерфейс, который принимает параметры конфигурации для службы, инициализация которой занимает много времени (например, параметры соединения JDBC). Мы хотим, чтобы наш пользовательский интерфейс оставался отзывчивым, пока...
1480 просмотров
schedule
05.04.2024
Как дождаться появления списка Future`s, созданного с использованием разных ExecutorServices
Хорошо, я знаю, что первым ответом / комментарием здесь будет «используйте один ExecutorService и используйте invokeAll ». Однако есть веская причина (которую я не буду утомлять) для того, чтобы мы держали пулы потоков отдельно.
Итак, у меня...
10976 просмотров
schedule
19.05.2024
Интерактивная архитектура программного обеспечения Java
Некоторое время назад мы разработали программную архитектуру для обработки транзакций. Это работало следующим образом: входящие события в зависимости от их типа преобразовывались в Callable , которые затем превращались в Executor в зависимости от...
196 просмотров
schedule
28.05.2024
Не звоню попасть в список фьючерсов
Я использую глобальную службу Executor с некоторым фиксированным размером пула потоков. У нас есть куча связанных задач, которые мы отправляем на выполнение и ждем в списке фьючерсов.
Недавно мы столкнулись с проблемой высокой загрузки ЦП, и при...
2358 просмотров
schedule
11.07.2022
Устанавливает ли .awaitTermination() действие, выполненное в исполнителе?
Вопрос, который у меня был в течение многих лет: в этом псевдокоде
ExecutorService svc = Executors.newFixedThreadPool(3);
svc.submit(new Runnable() { /* code A */ });
svc.shutdown();
if(svc.awaitTermination(...)) {
// code B...
374 просмотров
schedule
04.03.2024
Нужна ли служба Executors.newSingleThreadExecutor очистка с помощью выключения?
У меня есть небольшая путаница в отношении очистки службы исполнителя с помощью newSingleThreadExecutor. В соответствии с его реализацией он внутренне создает пул потоков из одного потока, и в случае сбоя будет создан новый. И я использую...
2937 просмотров
schedule
05.06.2024
Проверить статус запланированных задач
У меня есть приложение, которое использует ScheduledExecutorService для обработки нескольких Runnable : каждое из них запланировано с фиксированной скоростью и должно быть активным, пока приложение.
Мне нужно решение, которое будет уведомлено,...
805 просмотров
schedule
13.09.2022
В чем разница между отменой периодической задачи через будущее и отключением службы-исполнителя, из которой поступила задача?
Разница между:
A)
ScheduledExecutorService executorService = Executors.newSingleThreadScheduledExecutor();
ScheduledFuture<> periodicTask = executorService.scheduleAtFixedRate(() -> {
try {
doSomething();...
102 просмотров
schedule
10.05.2024
Завершение потоков с использованием управляемого executorservice после установленного времени
У меня есть список потоков, которые необходимо выполнять одновременно. Сначала я делал это с помощью executorservice. Потоки, которые необходимо выполнить, поступают из БД, и я извлекаю их имена классов, сохраняя их в списке vendorDetails.
for...
590 просмотров
schedule
02.08.2022
Параллельный поток Java не использует оптимальное количество потоков при использовании newCachedThreadPool()
Я сделал две отдельные реализации параллельного чтения из базы данных. Первая реализация использует ExecutorService с конструктором newCachedThreadPool() и фьючерсами: я просто делаю вызов, который возвращает будущее для каждого случая чтения, а...
200 просмотров
schedule
25.11.2023
ExecutorService никогда не останавливается. При выполнении новой задачи внутри другой выполняющейся задачи
Добрый день.
У меня проблема с блокировщиком в моем проекте веб-сканера. Логика проста. Сначала создает один Runnable , загружает html-документ, сканирует все ссылки, а затем на всех финансируемых ссылках создает новые объекты Runnable ....
979 просмотров
schedule
28.01.2024
ExecutorService непроверенное назначение
Я изучаю ExecutorService и Callables, но получаю предупреждение от intelij о том, что я выполняю непроверенное задание для этой строки:
Future<OrderWorker<OfferType>> future = executorService.submit(new...
498 просмотров
schedule
04.01.2024
Как получить количество задач в очереди в сервисе-исполнителе?
Итак, я использую executorservice для создания пула потоков.
ExecutorService executor = Executors.newSingleThreadExecutor();
Я пытаюсь получить доступ к количеству задач в очереди пула потоков. Я вижу, что нет никаких методов, чтобы получить...
4949 просмотров
schedule
15.10.2022
Почему запуск ExecutorService в одно-, двух- и трехпоточной программе занимает одинаковое время?
Я запускаю моделирование тонких пленок при очень низких температурах. Я попытался использовать ExecutorService для правильной многопоточности моего кода и, надеюсь, сократить время выполнения. Но я на собственном горьком опыте убедился, что это...
91 просмотров
schedule
07.12.2023
установить значение переменной только при отправке задачи в ExecutorService
С помощью ExecutorService я отправляю пакет задач, а задачи имеют временную переменную, а именно GENERAL_TIME делят между собой. Я хочу установить значение GENERAL_TIME непосредственно перед отправкой задач. Вот код:
ExecutorService...
563 просмотров
schedule
20.04.2024
Существует ли реализация ExecutorService с ограничением очереди и возможностью замены старых членов очереди новыми?
Мне нужна реализация ExecutorService, которая может ограничить количество Runnables, которые могут быть поставлены в очередь. Я также хотел бы иметь возможность контролировать, что происходит, когда новые runnables отправляются, когда очередь уже...
50 просмотров
schedule
09.11.2022
Служба Executor shutdownNow, как это работает
Согласно документу для метода shutdownNow (ExecutorService)
There are no guarantees beyond best-effort attempts to stop
processing actively executing tasks. For example, typical
implementations will cancel via {@link...
45 просмотров
schedule
01.11.2023
