Вопросы по теме 'executorservice'
Java Executors: как остановить отправленные задачи?
Я отправил задачу с помощью исполнителей, и мне нужно, чтобы она остановилась через некоторое время (например, через 5 минут). Я пробовал делать вот так:
for (Future<?> fut : e.invokeAll(tasks, 300, TimeUnit.SECONDS)) {
try {...
31047 просмотров
schedule
22.09.2022
использование ScheduledExecutorService для запуска и остановки таймера
Из моих чтений кажется, что ScheduledExecutorService — это правильный способ запуска и остановки таймеров в Java.
Мне нужно портировать некоторый код, который запускает и останавливает таймер. Это не периодический таймер. Этот код останавливает...
5360 просмотров
schedule
12.06.2023
Как я могу реализовать или найти эквивалент потокобезопасного CompletionService?
У меня есть простой веб-сервис, работающий внутри контейнера Tomcat, который по своей природе является многопоточным. В каждом запросе, поступающем в службу, я хочу совершать одновременные вызовы внешней службы. ExecutorCompletionService в...
1432 просмотров
schedule
29.06.2023
Как запустить невыполненные задачи сразу после ExecutorService.shutdown()?
У меня есть ScheduledExecutorService задачи, выполнение которых запланировано на час. Как мне получить список незавершенных задач, чтобы я мог принудительно запустить их немедленно?
Я полагаю, что shutdown() будет ждать час, и похоже, что...
3475 просмотров
schedule
26.04.2023
Как немедленно остановить задачу, запущенную с помощью ExecutorService?
Я пробовал много разных способов немедленно остановить задачу, запущенную с помощью ExecutorService, но безуспешно.
Future<Void> future = executorService.submit(new Callable<Void>(
public Void call () {
... do many other...
8671 просмотров
schedule
25.03.2023
Не удается остановить задачу, запущенную с помощью ExecutorService
К сожалению, я должен открыть новую тему, чтобы описать эту проблему.
Сегодня утром я задал этот вопрос , есть несколько ответов, но моя проблема все еще не решена.
На этот раз я прикреплю исполняемый код (упрощенный, но с той же проблемой),...
3450 просмотров
schedule
11.02.2023
Как выключить ожидающий сервер?
Я создал небольшой (однопоточный) сервер и поместил «рабочий» код в файл Runnable . Затем этот исполняемый файл выполняется в фоновом потоке с использованием Java Executor Framework:
ExecutorService exec = Executors.newSingleThreadExecutor();...
3172 просмотров
schedule
31.03.2022
Проблема при выполнении асинхронных задач с помощью ExecutorService
Я задал вопрос ранее относительно инициализации ExecutorService и Apache Velocity. Чтобы дать краткий обзор - у меня есть интерфейс Java EE, который принимает запросы пользователей, а затем для каждого из этих запросов использует ExecutorService...
1681 просмотров
schedule
19.03.2023
Пример Java использования ExecutorService и PipedReader/PipedWriter (или PipedInputStream/PipedOutputStream) для потребителя-производителя
Я ищу простую реализацию производителя-потребителя на Java и не хочу изобретать велосипед.
Мне не удалось найти пример, в котором используется как новый пакет параллелизма, так и любой из классов Piped.
Есть ли пример использования как...
4342 просмотров
schedule
11.02.2024
ExecutorCompletionService? Зачем он нужен, если у нас есть invokeAll?
Если мы используем ExecutorCompletionService , мы можем отправить ряд задач как Callable s и получить результат, взаимодействуя с CompletionService как queue .
Но есть также invokeAll из ExecutorService , который принимает Collection...
27713 просмотров
schedule
21.03.2022
Многопоточность Java не использует все ядра
У меня есть многопоточная программа, которая, похоже, не использует все ядра на моей машине. Вот код, и любой вклад будет высоко оценен.
Основной класс
public class MainClass{
public static void main(String [] args){
Work work=new...
437 просмотров
schedule
16.09.2022
Java - разделение работы на несколько потоков
У меня возникла следующая проблема: мне нужно разделить работу на несколько потоков по причинам производительности, но я не уверен, какой подход выбрать.
Во-первых, задача, которую я бы поставил, должна возвращать значение и принимать параметр....
24779 просмотров
schedule
07.07.2022
Fibonacci on Java ExecutorService работает быстрее последовательно, чем параллельно
Я пробую службу исполнителя на Java и написал следующий код для запуска Фибоначчи (да, массово рекурсивную версию, просто чтобы подчеркнуть службу исполнителя).
Удивительно, но он будет работать быстрее, если я установлю для nThreads значение 1....
802 просмотров
schedule
14.05.2022
Почему служба SingleThreaded Executor использует 4 ядра?
У меня есть следующий код, который использует однопоточную службу исполнителя, но при его запуске используются все 4 ядра на моей машине (каждое ядро в среднем использует около 80%).
Вопрос в том, почему это происходит? И я не заинтересован...
207 просмотров
schedule
24.03.2022
shutdownNow со службой исполнителя
Я использую ExecutorService для задача подключения, как показано ниже:
ExecutorService executor = Executors.newSingleThreadExecutor();
Future<ApplicationConnection> future = (Future<ApplicationConnection>) executor.submit(new...
583 просмотров
schedule
28.12.2022
Оптимальный способ создания пула потоков фиксированного размера в Java с помощью службы Executors
Я использую платформу Executors в Java для создания пулов потоков для многопоточного приложения, и у меня есть вопрос, связанный с производительностью.
У меня есть приложение, которое может работать в режиме реального времени или не в режиме...
8180 просмотров
schedule
12.06.2022
Предоставляет ли Java ExecutorService, который позволяет исполнителю выполняться в том же потоке?
Я ищу реализацию ExecutorService , которая обеспечит следующую семантику. Каждый поток занят «рабочим», который выполняет некоторую задачу на основе ввода. Каждый рабочий процесс гарантированно выполняется только в одном потоке, поэтому ему должно...
1465 просмотров
schedule
22.03.2022
Добавление потока в ThreadPool в службе исполнителя
Я работаю над многопоточной программой, в которой я пытаюсь убедиться, что каждый поток работает для 30 minutes . Предположим, что если у нас есть 10 threads , то каждый поток из 10 должен выполняться для 30 minutes .
Ниже мой код-
class...
6392 просмотров
schedule
10.12.2022
ClassLoader находит ресурс только в определенных потоках
Я борюсь с ситуацией, когда ClassLoader пытается разрешить ресурс, который работает только при определенных условиях.
Вариант использования следующий: я использую IBM Rational Functional Tester в сочетании с JBehave для автоматизированных...
821 просмотров
schedule
15.03.2023
ExecutorService: вызов future.get(long, TimeUnit) не приводит к запуску Callable в очереди
Я пытаюсь реализовать асинхронный преобразователь DNS, вызывая все подпрограммы, выполняющие DNS-запрос, в отдельном потоке с помощью ThreadPoolExecutor.
Я определяю вызываемый объект следующим образом:
public class SocketAddressCreator extends...
315 просмотров
schedule
15.04.2023
