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

CountdownLatch объединяет ожидание (maxTime) и обратный отсчет ()
У меня есть несколько потоков, работающих почти бесконечное время и количество итераций. Счетчик итераций сбрасывается до 0, когда найдено лучшее решение. Установлено максимальное количество итераций для предотвращения бесконечного цикла. Я...
1273 просмотров

В чем разница между get () и invoke () в Java 7 ForkJoinTask?
Вот javadoc для обоих: get (): при необходимости ожидает завершения вычисления, а затем получает его результат. invoke (): начинает выполнение этой задачи, ожидает ее завершения, если необходимо, и возвращает свой результат, или генерирует...
676 просмотров
schedule 17.11.2021

Java: синхронизация потока ExecutorService с CountDownLatch вызывает мертвую блокировку?
Я написал игру жизни для практики программирования. Есть 3 различных реализации генератора. Первый: один основной поток + N вспомогательных потоков, Второй: SwingWorker + N вспомогательных потоков, Третий: SwingWorker + ExecutorService. N -...
1659 просмотров

Планирование задач в другой задаче Java
Я разработал программу, которая через каждые две минуты вызывает db для проверки новых задач. public static void main(String[] args) { ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor();...
217 просмотров
schedule 03.10.2021

Служба исполнителя на java - ›как преобразовать однопоточный код для использования исполнителя
Простите, если вопрос звучит глупо - я только начинаю пользоваться Executor. У меня есть существующее Java-приложение, которое использует потоки таким образом - в основном используются автономные потоки - private Thread spawnThread( ) {...
15939 просмотров

ExecutorService против ThreadPoolExecutor с использованием LinkedBlockingQueue
Я работаю над многопоточным проектом, в котором мне нужно создать несколько потоков для измерения сквозной производительности моего клиентского кода, поскольку я выполняю тестирование нагрузки и производительности. Итак, я создал приведенный ниже...
47172 просмотров

Java ExecutorService - иногда медленнее, чем последовательная обработка?
Я пишу простую утилиту, которая принимает набор вызываемых задач и запускает их параллельно. Есть надежда, что общее время, затрачиваемое на выполнение самой продолжительной задачи, немного меньше. Утилита также добавляет некоторую логику обработки...
2225 просмотров

Java: рекурсивное создание потока для пула потоков - ›Как определить завершение
Я работаю над программой для игры в крестики-нолики. Он будет использовать поиск по дереву игр. Однако сначала мне нужно собрать дерево игры. Я хочу распараллелить этот процесс, поскольку он в основном включает в себя проверку текущей позиции,...
333 просмотров

как программа может гарантировать выполнение нескольких потоков одновременно с использованием среды исполнителя
Я пытаюсь запустить 5 потоков одновременно. Но, глядя на результат ниже, я думаю, что они начали в одно и то же время, но не одновременно, поскольку счетчик возраста всегда заканчивается 5 счетами. Если они выполняются реально одновременно, вывод...
672 просмотров

Завершение и отправка вызываемых объектов Executor
Это должно продолжаться в более ранней публикации , как часть моей задачи, которую я пытаюсь загрузить файлы из URL-адреса с использованием вызываемых объектов, и всякий раз, когда возникает исключение, я пытаюсь повторно отправить тот же вызываемый...
57 просмотров

Java ExecutorService для веб-службы Async
Нам нужно реализовать веб-службу Async. Поведение веб-службы: Мы отправляем запрос на учетную запись на сервер, и он отправляет ответ синхронизации с идентификатором подтверждения. После этого мы получаем несколько запросов обратного...
835 просмотров

Связь между основным потоком и рабочими потоками в Android
В моем самом первом проекте для Android я немного манипулирую данными, поэтому использую многопоточность. В MainActivity я создал несколько объектов Runnable и использовал ExecutorService для запуска всех потоков. Насколько я понимаю, все потоки...
1681 просмотров
schedule 30.11.2021

Как справиться с ситуацией, когда ExecutorService ThreadFactory возвращает null вместо thead
Я задавал этот вопрос раньше, но не смог открыть его снова, так как мое обновление не привело к повторному открытию. Так что отправляем его повторно Мой вопрос заключается в том, как заставить ExecutorService сразу понять, что поток...
269 просмотров
schedule 15.10.2021

Когда именно Callable передается в ExecutorService, доступный для сборки мусора
У меня есть пул потоков из 8, и я даю ему примерно 100 экземпляров класса, реализующего Callable , т.е. WorkerThread for (List<String> s : listOfLists) { Future<?> future = executor.submit(new Worker(hugeList)); } for...
245 просмотров

Многоядерное программирование на Java
Эта программа принимает входные файлы последовательно, но все задачи выполняются параллельно с использованием одного ядра. Время выполнения для всех задач больше, чем время последовательного выполнения. Я хочу сократить время выполнения с...
1272 просмотров

Как corePoolSize = 0 работает для ThreadPoolExecutor?
Определение ExecutorService.newCachedThreadPool() : public static ExecutorService newCachedThreadPool(ThreadFactory threadFactory) { return new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60L, TimeUnit.SECONDS,...
679 просмотров

ExecutorService.execute () автоматически выходит из метода run ()
Пытаюсь проверить, что один из моих классов может обрабатывать доступ в нескольких потоках. У меня есть тест JUnit, в котором я создал класс для реализации Runnable и запуска моего класса. Когда я запускаю execute, он достигает строки в методе...
274 просмотров

Как запустить несколько ExecutorServices, чтобы делать запросы и направлять ответ через единый интерфейс?
Этот вопрос является архитектурной проблемой, которую я не смог понять. У меня есть TaskScheduler, у которого есть такие операции, как start () и stop (). TaskScheduler предназначен быть агностиком, я хочу иметь возможность передавать в него любые...
175 просмотров

Недостаточно памяти с превышением лимита GC при использовании ExecutorService в SpringBoot
Мы создали Spring Listener / Consumer, который принимает сообщения из ActiveMQ и сохраняет их в RDBMS. Это приложение работает постоянно. Мы использовали ExecutorService для Listener для получения сообщений. Его threadpoolsize = 15. Если приложение...
260 просмотров
schedule 21.11.2021

Задержка между задачами, отправленными в Службу исполнителя
Я использую spring -boot, и у меня есть этот вариант использования, когда я хочу отправить каждый элемент списка в службу исполнителя (размер пула потоков = 4). Но между каждым элементом, который должен быть обработан, мне нужна задержка в 1 секунду....
75 просмотров
schedule 11.10.2021