Вопросы по теме 'threadpoolexecutor'

Фиксированный пул потоков ThreadPoolExecutor с настраиваемым поведением
я новичок в этой теме... я использую ThreadPoolExecutor, созданный с помощью Executors.newFixedThreadPool(10), и после заполнения пула я начинаю получать RejectedExecutionException. Есть ли способ «заставить» исполнителя перевести новую задачу в...
28557 просмотров

Многопоточность Spring JPA
Мы создаем продукт, поэтому с точки зрения производительности мне нужна помощь. Мы используем полный Spring (MVC, JPA, Security и т.д.) У нас есть требование, согласно которому, скажем, для определенного потока может одновременно выполняться 100...
4819 просмотров

Проблемы с PhoneGap Google Cloud Messaging Android
02-01 14:16:32.054: E/AndroidRuntime(17134): FATAL EXCEPTION: pool-2-thread-2 02-01 14:16:32.054: E/AndroidRuntime(17134): java.lang.NullPointerException 02-01 14:16:32.054: E/AndroidRuntime(17134): at...
623 просмотров

Предварительная инициализация пула рабочих потоков для повторного использования объектов подключения (сокетов)
Мне нужно создать пул воркеров на Java, где у каждого воркера есть свой собственный подключенный сокет; когда рабочий поток запускается, он использует сокет, но оставляет его открытым для повторного использования позже. Мы выбрали этот подход,...
7798 просмотров

Почему я не могу создать экземпляр ThreadPoolExecutor с помощью BlockingQueue‹Callable›; почему только BlockingQueue‹Runnable›?
Насколько я понимаю, callable был добавлен в 1.5, а runnable интерфейс остался как есть, чтобы предотвратить конец света. Почему я не могу создать экземпляр ThreadPoolExecutor (core, max, tu, unit, new BlockingQueue<Callable>()) - почему...
3192 просмотров
schedule 11.06.2023

Список всех запущенных/поставленных в очередь потоков в ThreadPoolTaskExecutor
Я использую ThreadPoolTaskExecutor весной для планирования своих задач. Есть ли способ получить список или что-то из каждого запущенного и поставленного в очередь потока этого исполнителя/пула задач?
6890 просмотров

Функция отмены в java ThreadPool. Обнаружение определенного исполняемого файла в пуле и отмена его.
У меня есть ThreadPool в моем приложении для Android, где я запускаю в нем кучу потоков в разных ситуациях. public class ThreadPoolExecuter { private final ExecutorService mExecuter; private static final int nThreads = 5; private...
228 просмотров

Отключение бездействующего потока Java ThreadPoolExecutors — вызов пользовательского кода очистки
Согласно документу ThreadPoolExecutor ( Java ThreadPoolExecutor ), если я создам службу-исполнитель следующим образом: new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue); и когда #threads > corePoolSize,...
918 просмотров
schedule 23.04.2022

Очередь потоков Java
У нас есть приложение, которое обрабатывает элементы и на каждой итерации запускает поток для обновления другой базы данных — не так уж важно, что происходит в этом другом потоке, это очень простое обновление. Наше первоначальное намерение состояло...
3643 просмотров

ThreadPoolExecutor игнорирует ошибки (OutOfMemoryError)
Мы пишем приложение, которое использует собственное расширение ThreadPoolExecutor для обработки группы Runnable . При разработке приложения мы столкнулись с OutOfMemoryError проблемами, которые произошли в наших Runnable классах. Но вместо...
257 просмотров
schedule 27.09.2022

время ожидания запросов async-http-client с NettyAsyncHttpProvider
Я использую async-http-client , но у меня проблемы с NettyAsyncHttpProvider . Это дает это предупреждение: Oct 28, 2014 12:50:16 PM org.jboss.netty.channel.socket.nio.AbstractNioWorkerPool WARNING: Failed to get all worker threads ready...
1272 просмотров

Java ScheduledThreadPool для использования дополнительных потоков, если продолжительность задачи превышает период
Итак, скажем, у меня есть ScheduledExecutorService с 10 потоками, сгенерированными как таковые, и я запускаю периодическую задачу, которая запускается раз в минуту. svc = Executors.newScheduledThreadPool(10); svc.scheduleAtFixedRate(myRunnable,...
150 просмотров

Spring 4: проблема управления транзакциями ThreadPoolTaskExecutor
Недавно мы обновили нашу весеннюю версию до 4.x с 2.x, что начало вызывать некоторые проблемы с одной из наших реализаций «threadpooltaskexecutor». Реализация была следующей: public class A { .................................
868 просмотров

Как отменить конкретную задачу по таймауту при использовании ThreadPoolExecutor в Java?
Я использую ThreadPoolExecutor в Java для распараллеливания обработки элементов. Обработка каждого элемента - это отдельная задача, которую я помещаю в очередь для обработки исполнителем. К сожалению, некоторые задачи могут занять слишком много...
988 просмотров
schedule 17.04.2022

executeor.shutdown () в сервисе onDestroy ()
Я хочу, чтобы мой исполнитель работал до тех пор, пока моя служба не перестанет работать. Логическое решение, о котором я думаю, - это сделать executor.shutdown() на onDestroy() службы Каковы будут последствия этого действия? Я знаю, что...
486 просмотров
schedule 25.01.2023

Cancel() vs remove() для исполнителей
Недавно я работал с ThreadPoolExecutor и priorityqueue и столкнулся с обоими методами future.cancel() для будущей задачи. И task.remove() для самой задачи, чтобы удалить ее из очереди. Какой вариант лучше? есть ли разница? Я могу сохранить...
3122 просмотров
schedule 09.05.2023

Приложение ThreadPoolExecutor не завершается
Это очень простое приложение печатает «Hello», но не завершает работу. Я не вижу абсолютно никаких причин, почему это должно быть. JavaDoc , завершение раздела, говорит, что Пул, на который больше нет ссылок в программе И в котором нет...
982 просмотров

Повторяемый пул потоков путем переопределения afterExecute(Runnable r, Throwable t)
Я хочу реализовать пул потоков, чтобы задачи могли выполняться в определенное время, переопределяя хук afterExecute . Могу ли я снова отправить аргумент Runnable r ? Вот моя первоначальная реализация. public class RetriableThreadPool extends...
306 просмотров
schedule 16.07.2023

Почему всегда threadPoolExecutor.getActiveCount() ‹= maxPoolSize/2?
У нас есть очередь задач и ее инициализация выглядит так: LinkedBlockingQueue<Runnable> queue = new LinkedBlockingQueue<Runnable>(); ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(maximumPoolSize, maximumPoolSize,...
623 просмотров
schedule 20.03.2024

Каков наилучший способ дождаться завершения потока ThreadPoolExecutor в java?
Я использую ThreadPoolExecutor в java для выполнения нескольких потоков, и мне нужно что-то делать после завершения потоков и ждать. Вот я и хочу спросить, как лучше это сделать? Правильно ли я делаю в пути? threadPool.shutdown(); boolean...
1723 просмотров