executorservice — все вопросы

3ответа
4 голоса
ExecutorService vs CompletableFuture
Я пытался реализовать асинхронный процесс, где родительский метод вызывает дочерний метод, который, в свою очередь, вызывает три различных метода. Я хочу, чтобы весь этот процесс выполнялся асинхрон
4ответа
4 голоса
Как я могу сообщить о прогрессе от фоновой задачи?
У меня есть длинная задача, которая выполняется в фоновом режиме в пуле потоков ExecutorService. Каковы некоторые лучшие практики с точки зрения этой задачи, возвращающие прогресс или промежуточные
2ответа
4 голоса
Рабочие потоки ScheduledExecutorService сохраняют статус прерывания после FutureTask.cancel (true)
У меня есть задача, которую я планирую периодически запускать через ScheduledThreadPoolExecutor.scheduleAtFixedRate (task, rate, ...) . Пользователь может отменить эту задачу вручную, которая вызыв
1ответ
4 голоса
Как использовать кастомного исполнителя в диспетчере Акка
Я пытаюсь использовать собственного исполнителя для диспетчера в Akka. В частности, я хочу обернуть существующего исполнителя своим собственным (ведение журнала, отладка и т. д.). Я просмотрел
2ответа
4 голоса
Как использовать ExecutorService для опроса до получения результата
У меня есть сценарий, в котором мне нужно опросить удаленный сервер, чтобы проверить, завершена ли задача. После этого я делаю другой вызов, чтобы получить результат. Сначала я решил использовать
2ответа
4 голоса
API завершения работы ThreadPoolExecutor doc verbiage «не ждет»
В документации для ThreadPoolExector # shutdown там написано:    Этот метод не ожидает завершения выполнения ранее отправленных задач Что это значит? Потому что я понимаю, что поставленн
3ответа
4 голоса
Использование ExecutorService для параллельной обработки заданий
Я пишу Java-программу, которая должна обрабатывать много URL-адресов. Каждый URL будет выполнять следующие задания в порядке: скачать, проанализировать, сжать Вместо того, чтобы один поток выпол
1ответ
4 голоса
Использование ExecutorService вместо Thread.start
Я работаю над существующим кодом, где я нашел этот фрагмент кода в одном из классов. Код использует ExecutorService вместо MyThread.start. Скажите, пожалуйста, зачем использовать ExecutorService
2ответа
4 голоса
Поток безопасности между последующими вызовами Executors.newSingleThreadExecutor
У меня есть вопрос относительно использования однопоточного исполнителя. Поскольку он повторно использует один и тот же поток, означает ли это, что если я изменю состояние объекта в одном вызове sub
2ответа
4 голоса
Как дождаться завершения всех задач в ThreadPoolExecutor в течение тайм-аута и без выключения Executor?
После использования ThreadPoolExecutor для управления моими задачами вместо создания для каждого отдельного потока. Я использовал следующую часть, чтобы дождаться завершения определенного количества
1ответ
4 голоса
Динамический пул потоков
У меня длительный процесс, который прослушивает события и выполняет интенсивную обработку. В настоящее время я использую Executors.newFixedThreadPool(x), чтобы регулировать количество одновременн
1ответ
4 голоса
Завершение работы Java Executor после завершения всех выполненных задач без блокировки
Мне интересно, есть ли способ закрыть Java ExecutorService и разрешить выполнение всех отправленных задач, не блокируя их. Чтобы быть более точным, я хочу запланировать Runnable с задержкой и про
1ответ
4 голоса
Как я могу перехватить исключение RejectedExecutionException, генерируемое в вызове метода CompletableFuture whenCompleteAsync?
В следующем примере кода я внедряю ---- +: = 0 =: + ----, который спит в течение 100 миллисекунд в качестве действия завершения набора завершаемого будущего.Я использовал ---- +: = 1 =: + ---- метод,
1ответ
4 голоса
Future.cancel (), за которым следует Future.get (), убивает мой поток
Я хочу использовать интерфейс Executor (используя отзывной) для того , чтобы начать тему (назовем его вызываемой Thread) , который будет делать работу , которая использует блокирующую методы.Это означ
2ответа
4 голоса
Несколько потоков для параллельной работы с фиксированным интервалом с использованием ScheduledExecutorService
Цель: отслеживать 5 URL-адресов json каждые 5 секунд с 5 параллельными потоками.Я хочу запустить несколько параллельных потоков для отслеживания URL-адресов JSON с интервалом в n секунд.Я использую --
2ответа
4 голоса
Как отловить RejectedExecutionException при использовании фьючерсов Scala?
Где я должен перехватить исключения RejectedExecutionException при завершении работы исполнителя?Я пытался:а также :тоже не работает.Все еще получаю:
2ответа
4 голоса
ExecutorService workStealingPool и метод отмены
Можете ли вы придумать причину, по которой этот код не работает и всегда выводит «закончено», но второй пример работает без проблем.Я использую последнюю версию JDK (8u45).открытый статический класс M
2ответа
4 голоса
Обход объекта List вызывает исключение IndexOutOfBounds
У меня есть ExecutorService, который используется для вызова коллекции объектов Callable и возвращает объекты списка будущих объектов, соответствующие элементам Callable в коллекции.Однако где-то при
3ответа
4 голоса
Как сообщить потоку вызывающей стороны, что ExecutorService завершил задачу
Из основного потока:Теперь, когда Runnable завершил выполнение, есть ли в Java стандартный способ сообщить потоку вызывающей стороны, что он завершил выполнение, без создания нового интерфейса /класса
4ответа
4 голоса
Как запускать X-задачи на Y-потоках в Java?
Я хочу измерить среднее время выполнения задачи в 5 потоках, выполняющих 100 задач.Для измерения времени я использую ---- +: = 0 =: + ----Задача вызывает один конкретный метод, давайте назовем его ---
1 2

Популярные теги

security × 330linux × 316macos × 2827 × 268performance × 244command-line × 241sql-server × 235joomla-3.x × 222java × 189c++ × 186windows × 180cisco × 168bash × 158c# × 142gmail × 139arduino-uno × 139javascript × 134ssh × 133seo × 132mysql × 132