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

Java FixedThreadPool не работает с заданным размером пула?
Я использую FixedThreadPool для рабочих потоков. Вот как я его создал: ThreadPoolExecutor producerThreadPool = (ThreadPoolExecutor) Executors.newFixedThreadPool(25); Поэтому я установил его размер как 25, я предполагаю, что в любое время...
363 просмотров
schedule 23.10.2022

Как сообщить ThreadPoolExecutor, когда он должен работать или нет
Мне нужно отправить набор файлов на несколько компьютеров через определенный порт. Дело в том, что каждый раз, когда вызывается метод, отправляющий файлы, вычисляются данные назначения (адрес и порт). Следовательно, используя цикл, который создает...
666 просмотров

Начать новый поток вместо помещения в очередь
Из javadoc для ThreadPoolExecutor : Когда новая задача отправляется в методе execute (java.lang.Runnable) .... Если количество запущенных потоков больше corePoolSize, но меньше maximumPoolSize, новый поток будет создан только в том случае,...
445 просмотров

запланированная точность исполнителя
У меня проблема с ScheduledExecutorService в java (пару дней назад я не сталкивался с этой проблемой, что делает ее странной для меня). Пожалуйста, найдите приведенный ниже код и вывод консоли. Задержка между повторным выполнением задачи составляет...
328 просмотров
schedule 21.01.2023

пул потоков - создайте новый для каждой задачи, определите, когда будет выполнен набор задач
Запуск параллельных задач через ThreadPoolExecutors. Поскольку у меня есть 2-3 набора задач, на данный момент у меня есть карта ThreadPoolExecutors и я могу отправить набор задач одному из них. Теперь нужно узнать, когда пул выполнил все...
367 просмотров

LinkedBlockingQueue пут vs оффер
У меня есть связанная очередь блокировки, в которой я выполняю операции вставки и удаления. Мне нужно знать, какой из них лучше put или offer в случае связанной очереди блокировки. Параметры производительности — это загрузка ЦП, памяти и...
11618 просмотров
schedule 07.03.2023

Как заставить ThreadPoolExecutor увеличивать потоки до максимума перед постановкой в ​​очередь?
Некоторое время я был разочарован поведением ThreadPoolExecutor по умолчанию, которое поддерживает ExecutorService пулы потоков, которые используют многие из нас. Цитата из Javadocs: Если количество запущенных потоков больше corePoolSize,...
32101 просмотров

Android останавливает службу после завершения ThreadPoolExcutor
У меня Service запускается независимо с активностью с использованием startService() . Эта служба обрабатывает множество запросов из активности и создает Callable , а затем добавляет в ThreadPoolExecutor . Выглядит это так: private...
262 просмотров

Многопоточность push-уведомлений GCM
Мы разрабатываем приложение для Android, которое отправляет обновления пользователям нашего приложения. Обновления публикуются на нашем сервере из консоли администратора (приложение JAVA SWING), а затем сохраняются в базе данных. После того, как...
417 просмотров

Получить ThreadPoolExecutor по умолчанию?
Я делаю приложение для Android, и у меня возникают проблемы с появлением RejectedExecutionException (вероятно, из-за чрезмерного использования AsyncTask ). Я хотел бы получить ThreadPoolExecutor по умолчанию и прочитать getTaskCount() и...
2333 просмотров
schedule 10.10.2022

Исполнитель ThreadPool, сборка мусора
Я использую исполнитель ThreadPool в цикле do while в качестве процесса deamon. В начале каждой итерации я создаю newFixedThreadPool: executor = Executors.newFixedThreadPool (5); После завершения задачи я вызываю завершение работы до начала...
182 просмотров

Spring threadpooltaskexecutor: управление транзакциями
Я пытаюсь сделать вызов асинхронного метода в моем коде сервисного уровня. Некоторый псевдокод для того же, как показано ниже: public void createXXX () { dao.saveOrUpdate(entity); // save an entity ................... ......................
624 просмотров
schedule 03.05.2023

ThreadPoolExecutor с ConcurrentLinkedQueue
Могу ли я передать неблокирующую очередь с именем ConcurrentLinkedQueue в ThreadPoolExecutor вместо LinkedBlockingQueue (или любой другой блокирующей очереди)?
1093 просмотров
schedule 29.12.2022

Политика справедливости синхронной очереди в bean-компоненте ThreadPoolTaskExecutor?
У меня есть следующий боб <bean id="executor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor"> <property name="corePoolSize" value="1" /> <property name="maxPoolSize" value="1" /> <!--...
616 просмотров

Как долго я могу оставить пул потоков без задач, прежде чем он завершится в Android?
Я новичок в использовании ThreadPools для выполнения многопоточности в моем приложении для Android. В прошлом я создавал новые потоки для выполнения сетевых запросов, запросов к базе данных и интенсивных алгоритмов. Согласно этому сообщению новый...
58 просмотров

Многопоточность Java, выполняющая больше, чем границы цикла
Я создаю веб-скребок для извлечения ссылок и электронных писем из Интернета. Ссылки будут использоваться для поиска новых мест для поиска электронных писем, а затем электронные письма будут храниться в наборе. Каждая ссылка передается в...
100 просмотров

Пользовательский класс обслуживания с ThreadPoolExecutor убит, когда приложение выключено
Мне нужно выполнять несколько задач параллельно в пользовательской службе, чтобы заставить их работать: - Служба определения местоположения и API распознавания действий. - API Geofence и вызовы REST API. Я новичок в потоках в Java и Android, и я...
362 просмотров

получить вызываемый из ThreadPoolTaskExecutor или преобразовать Runnable в Callable
Я использую ThreadPoolTaskExecutor для выполнения моих задач, которые являются реализацией Callable интерфейс. Я просто хочу вовремя проверить, находится ли задача в пуле (мониторинг). Как это сделать? Я знаю, что могу получить очередь из...
1436 просмотров

ThreadPoolExecutor: ожидание завершения вне метода
Текущий сценарий: мой код (скажем, «Вызывающий класс: caller()») будет вызывать метод класса (класс ThreadPoolClass: writeData()), который внутренне выполняет свою задачу через ThreadPoolExecutor. Теперь эта реализация не ждет завершения всех своих...
132 просмотров

Тестирование пропускной способности базы данных postgres с использованием пула потоков и пула соединений. Но почему у меня только 300 вставок в секунду, когда должно быть 6000?
Я хочу проверить пропускную способность моей системы, которая подключена к базе данных postgresql. Моя система состоит из 2 основных компонентов: ThreadPoolExecutor как newFixedThreadPool с максимум 10 потоками и PGPoolingDataSource, называемый...
836 просмотров