5
ответов

Невозможный сделать кэшируемый пул потоков с пределом размера?

Это, кажется, невозможно сделать кэшируемый пул потоков с пределом количеству потоков, которые это может создать. Вот то, как статический Executors.newCachedThreadPool реализован в стандартном Java...
вопрос задан: 2 March 2016 13:33
4
ответа

Обрабатывание исключений от задач Java ExecutorService

Я пытаюсь использовать класс ThreadPoolExecutor Java для выполнения большого количества тяжелых задач веса с постоянным числом потоков. Каждая из задач имеет много мест, во время которых она может перестать работать из-за...
вопрос задан: 20 June 2017 05:01
2
ответа

Executors.newCachedThreadPool () по сравнению с Executors.newFixedThreadPool ()

newCachedThreadPool () по сравнению с newFixedThreadPool (), Когда я должен использовать один или другой? Какая стратегия лучше с точки зрения использования ресурса?
вопрос задан: 25 July 2017 16:09
1
ответ

Как работает ThreadPoolExecutor, созданный с помощью конструктора с BlockingQueue < Runnable > в качестве аргумента поставить в очередь Callables?

Конструктор для ThreadPoolExecutor имеет аргумент типа для BlockingQueue как Runnable. Предположим, у меня есть ThreadPoolExecutor, объявленный как этот ThreadPoolExecutor customThreadPool = new ...
вопрос задан: 9 March 2019 23:56
1
ответ

Обрабатывание исключений для ThreadPoolExecutor

У меня есть следующий фрагмент кода, который в основном сканирует через список задачи, которая должна быть выполнена, и каждая задача затем дана исполнителю для выполнения. JobExecutor в свою очередь создает...
вопрос задан: 25 April 2016 17:15
0
ответов

Комбинация ThreadPoolExecutor и ArrayBlockingQueue не работает

Я использую ThreadPoolExecutor весны. Может кто-нибудь сказать мне, как я могу отклонить дополнительные задачи в TaskQueue, когда он полон? По сути, я пытаюсь ограничить количество задач в очереди. ...
вопрос задан: 18 March 2019 18:31
0
ответов

Продолжайте работу ThreadPoolExecutor после того, как основная функция вернется

ранее у меня была функция, которую можно упростить как: Class A (): def _run (id): # do_something return def run (): для идентификатора в id_list: proc = Process (...
вопрос задан: 2 March 2019 20:53
0
ответов

статический ScheduledThreadPoolExecutor в CompletableFuture.Delayer

В java-9 был представлен новый метод completeOnTimeout в классе CompletableFuture: public CompletableFuture completeOnTimeout (значение T, длительное время ожидания, ...
вопрос задан: 27 March 2018 12:37
0
ответов

Как дождаться завершения всех задач в ThreadPoolExecutor, не завершая Executor?

Я могу ' t используйте shutdown () и awaitTermination (), потому что возможно, что новые задачи будут добавлены в ThreadPoolExecutor, пока он ожидает. Так что я ищу способ подождать, пока ...
вопрос задан: 25 August 2016 14:14
0
ответов

В чем преимущество Java-5 ThreadPoolExecutor над Java-7 ForkJoinPool?

В Java 5 появилась поддержка асинхронного выполнения задач пулом потоков в форме среды Executor, сердцем которой является реализованный пул потоков автор: java.util.concurrent ....
вопрос задан: 18 January 2016 13:23
0
ответов

Предварительная инициализация пула рабочих потоков для повторного использования объектов подключения (сокетов)

Мне нужно создать пул рабочих в Java, где у каждого рабочего есть свой собственный сокет; когда рабочий поток запускается, он использует сокет, но оставляет его открытым для последующего использования Мы определились с этим подходом ...
вопрос задан: 23 May 2013 23:09
0
ответов

ThreadPoolExecutor и очередь

Я думал, что с помощью ThreadPoolExecutor мы можем отправлять Runnable для выполнения либо в BlockingQueue, переданном в конструкторе, либо с помощью метода execute. Также я понял, что если...
вопрос задан: 5 August 2012 21:12