Это, кажется, невозможно сделать кэшируемый пул потоков с пределом количеству потоков, которые это может создать. Вот то, как статический Executors.newCachedThreadPool реализован в стандартном Java...
Я пытаюсь использовать класс ThreadPoolExecutor Java для выполнения большого количества тяжелых задач веса с постоянным числом потоков. Каждая из задач имеет много мест, во время которых она может перестать работать из-за...
newCachedThreadPool () по сравнению с newFixedThreadPool (), Когда я должен использовать один или другой? Какая стратегия лучше с точки зрения использования ресурса?
Конструктор для ThreadPoolExecutor имеет аргумент типа для BlockingQueue как Runnable. Предположим, у меня есть ThreadPoolExecutor, объявленный как этот ThreadPoolExecutor customThreadPool = new ...
У меня есть следующий фрагмент кода, который в основном сканирует через список задачи, которая должна быть выполнена, и каждая задача затем дана исполнителю для выполнения. JobExecutor в свою очередь создает...
Я использую ThreadPoolExecutor весны. Может кто-нибудь сказать мне, как я могу отклонить дополнительные задачи в TaskQueue, когда он полон? По сути, я пытаюсь ограничить количество задач в очереди. ...
ранее у меня была функция, которую можно упростить как: Class A (): def _run (id): # do_something return def run (): для идентификатора в id_list: proc = Process (...
В java-9 был представлен новый метод completeOnTimeout в классе CompletableFuture: public CompletableFuture completeOnTimeout (значение T, длительное время ожидания, ...
Я могу ' t используйте shutdown () и awaitTermination (), потому что возможно, что новые задачи будут добавлены в ThreadPoolExecutor, пока он ожидает. Так что я ищу способ подождать, пока ...
В Java 5 появилась поддержка асинхронного выполнения задач пулом потоков в форме среды Executor, сердцем которой является реализованный пул потоков автор: java.util.concurrent ....
Мне нужно создать пул рабочих в Java, где у каждого рабочего есть свой собственный сокет; когда рабочий поток запускается, он использует сокет, но оставляет его открытым для последующего использования Мы определились с этим подходом ...
Я думал, что с помощью ThreadPoolExecutor мы можем отправлять Runnable для выполнения либо в BlockingQueue, переданном в конструкторе, либо с помощью метода execute. Также я понял, что если...