Вопросы по теме 'futuretask'
Можете ли вы использовать объекты Future/Futuretask с Spring TaskExecutors?
Можно ли использовать Java FutureTask с Spring TaskExecutor для получения Будущий объект?
Я ищу TaskExecutor, который реализует Java ExecutorService , в частности, метод submit(). Просмотр документов Spring Javadocs не показывает никаких...
5080 просмотров
schedule
06.04.2023
Как заставить FutureTask возвращаться после исключения TimeoutException?
В приведенном ниже коде я перехватываю TimeoutException через 100 секунд, как и предполагалось. В этот момент я ожидаю, что код выйдет из main, а программа завершится, но она продолжит вывод на консоль. Как заставить задачу прекратить выполнение...
18173 просмотров
schedule
01.11.2022
Как обеспечить сборку мусора FutureTask, которая отправляется ThreadPoolExecutor, а затем отменяется?
Я отправляю Callable объекты в ThreadPoolExecutor , и кажется, что они застряли в памяти.
Посмотрев дамп кучи с помощью инструмента MAT для Eclipse, вы увидите, что на объекты Callable ссылается вызываемая переменная FutureTask$Sync . На...
7522 просмотров
schedule
20.05.2023
Java: ведение журнала исключений FutureTask
У меня есть приложение, которое регулярно отправляет задачи для выполнения в выделенном потоке. Этими задачами являются FutureTask<V> , а поток - не более чем бесконечный цикл, который выполняет задания, когда они попадают в очередь, переходя...
1656 просмотров
schedule
06.03.2023
Многопоточность - именование потоков и обработка исключений
Каковы предлагаемые способы реализации требований двух потоков в java?
Я хотел бы назвать тему
Я хотел бы, чтобы родительский (или основной) поток знал, есть ли исключения в этом дочернем потоке.
Что касается 2, я понимаю, что наличие...
233 просмотров
schedule
13.03.2022
Лучший способ реализовать TimeoutTask
Я пытаюсь реализовать TimeoutTask , который завершится по истечении заданного тайм-аута. Вот что у меня есть:
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.util.Objects;
import java.util.concurrent.Callable;
import...
276 просмотров
schedule
05.06.2023
Обновление данных ArrayAdapter
Я создаю приложение, которое динамически заполняет/удаляет список массивов в зависимости от потока Futuretask, который взаимодействует с сервером.
Проблема в том, что когда я добавляю новый объект в свой адаптер массива и каким-либо образом...
92 просмотров
schedule
18.02.2023
Android: Future/FutureTask для параллельной обработки данных
Я пытаюсь оптимизировать сложный модуль обновления данных и анализатор для своего приложения для Android. Сервер предоставляет три функции интерфейса. Анализатору требуются данные от всех этих трех функций.
Когда загрузка данных завершена, парсер...
367 просмотров
schedule
20.03.2023
Многопоточный подход для преобразования TIFF в PDF с использованием iText
По сути, я пытаюсь преобразовать файл tiff в pdf, используя itext, что довольно просто. Но из того, что я вижу, TiffImage.getTiffImage требуется много времени для выполнения больших файлов.
Мое требование состоит в том, чтобы использовать...
1013 просмотров
schedule
26.06.2023
Почему исключение имеет значение null в afterExecute() ThreadPoolExecutor?
Я хочу обрабатывать исключения, созданные рабочими потоками в методе ThreadPoolExecutor#afterExecute() . В настоящее время у меня есть этот код:
public class MyExecutor extends ThreadPoolExecutor {
public static void main(String[] args) {...
1422 просмотров
schedule
11.09.2022
JavaFX: Platform.runLater(задача) не распознана для задачи = new FutureTask‹›(new Runnable() {}?
За последние две недели я изучил 10 различных способов избежать проблем с sleep() . Концепция запуска блока кода в потоке пользовательского интерфейса, который нельзя прервать, кажется наиболее практичной. Итак, я приступил к созданию объекта...
453 просмотров
schedule
18.08.2022
Akka-Java: невозможно получить сообщение о будущем в родительском элементе с использованием шаблона канала
Я создаю одного дочернего актера для одного родителя. Мой дочерний актер выполняет некоторую бизнес-логику и возвращает значение в scala Future. Когда я отправляю Future сообщение своему родителю, я не могу перехватить свое будущее сообщение....
516 просмотров
schedule
24.06.2022
Создание фьючерсов без ExecutorService или FutureTask
Я использую JerseyClient для выполнения асинхронных вызовов на http-сервер и напрямую создаю фьючерсы для хранения ответа. Это могут быть даже пакетные вызовы, и в этом случае я создаю список фьючерсов.
На данный момент это работает отлично, но...
78 просмотров
schedule
11.09.2022
Как оптимизировать параллелизм потоков Java с тысячами соединений SSH на поток?
Итак, у меня есть этот фрагмент кода, который я хочу оптимизировать. Идея программы состоит в том, чтобы перебрать список хостов, а затем создать один поток для каждого хоста и подключиться к нему через SSH для проверки некоторых вещей, а затем...
148 просмотров
schedule
14.08.2022
Почему Future(Failure(new Exception)) возвращает успех, а не отказ?
Я пробовал следующее и думал, что получу отказ
val failure = Future { Failure(new Exception) }
но вместо этого я получил
Future(Success(Failure(java.lang.Exception)))
Кто-нибудь может ответить, почему?
61 просмотров
schedule
09.04.2023
Создание DAG из отменяемых задач Java
Я хочу создать DAG из задач на Java, где задачи могут зависеть от результатов других задач. Если между двумя задачами нет направленного пути, они могут выполняться параллельно. Задания могут быть отменены. Если какая-либо задача вызывает...
132 просмотров
schedule
08.07.2022
