Описание тега executorservice
ExecutorService - это объект Java, содержащий управляемый пул потоков и способный планировать отправленные задачи для этих потоков. Стратегии планирования различаются в нескольких доступных реализациях.
1
ответ
Каков наиболее эффективный способ создания дополнительных потоков из потока?
Вопрос Каков наиболее эффективный способ создания дополнительных потоков из потока? контекст Я изменяю дизайн приложения, чтобы сделать его более эффективным. Одним из самых больших улучшений будет запуск параллельных операций; однако я новичок в па…
27 май '13 в 14:21
0
ответов
JUnit не распознает Assert.fail() в потоках
У меня есть тест JUnit, который использует ExecutorService создать несколько потоков: @Test public void testGeneratorPeek() { try { ExecutorService threadPool = Executors.newFixedThreadPool(10); for (int i = 0; i < 10; i++) { threadPool.submit(ne…
26 окт '17 в 20:38
3
ответа
Завершение работы ветки Executor после awaitConfimation
Как закрыть все потоки, созданные с помощью ExecutorService после executor.awaitTermination(1, TimeUnit.DAYS); закончен? Это максимальное время, в течение которого потоки могут работать, и если в каком-то случае какой-либо из них не завершит текущую…
27 авг '13 в 11:40
1
ответ
Требование по мониторингу исполнителя пула потоков
В наших производственных средах мы используем Thread Pool Executor для выполнения выполняемой задачи. Мне нужно разработать пул потоков Heartbeat систему мониторинга для службы пулов потоков: Каждые 60 секунд требуется собирать следующую статистику …
20 ноя '11 в 00:49
1
ответ
Несколько экземпляров Java одного и того же класса совместно используют одни и те же запущенные объекты, но они не должны
Я делаю многопоточный алгоритм оптимизации Java, который инициирует различные экземпляры одного и того же подкласса по причине улучшения времени. У этого подкласса есть и другие подклассы. Алгоритм ищет через пространство поиска оптимальное решение …
09 май '14 в 09:59
0
ответов
Запись результатов в Extent Report с помощью метода, который выполняется несколькими потоками
У меня есть метод, который выполняется в несколько потоков. Метод выполняет действие, а затем записывает результат в отчет экстента. public LinkedHashMap doSomething(){ // do something .... extentReporObj.writeToReport(testName,result,..); } Вышеупо…
06 ноя '18 в 11:45
0
ответов
Выполните итерацию всех машин в цикле for параллельно и проверьте, работают они или нет?
У меня есть список машин в ArrayList, Я проверяю, работают ли все эти машины, или нет, поэтому я делаю http-вызов на них, и если они отвечают, что они работают, но если они не отвечают, то они не работают. Я считал их мертвыми, если они не отвечают …
29 май '18 в 19:06
2
ответа
Спящая нить внутри ExecutorService (Java/Clojure)
У меня довольно большое количество потоков, создаваемых внутри программы clojure: (import '(java.util.concurrent Executors)) (def *pool* (Executors/newCachedThreadPool)) (defn do-something [] ; work Thread/sleep 200 ; repeat) (dotimes [i 10000] (.su…
22 мар '11 в 21:17
3
ответа
Несколько вопросов о Threading в Java
Сначала немного предыстории. В NetBeans я получил предупреждение о том, что не следует создавать новый поток в конструкторе. Я читал, что причина этого в том, что новый поток может запуститься и попытаться сослаться на объект, запустивший поток до т…
29 сен '10 в 13:12
1
ответ
Что происходит, когда я никогда не вызываю shutdown на ExecutorService?
Я пытаюсь использовать ExecutorService для проекта Android. Мне нужно, чтобы он работал во время работы приложения и завершал работу, когда приложение закрывалось. Проблема в том, что на Android обнаружение выключения приложения немного сложнее. Так…
15 дек '15 в 23:09
1
ответ
Java ScheduledExecutorService для периодического запуска
Я пытаюсь запустить задание [которое содержит 3 службы, которые должны выполняться параллельно] для каждой минуты. Ниже мой фрагмент кода. ExecutorService service = Executors.newFixedThreadPool(servicesMap.size()); for (Map.Entry entry : servicesMap…
02 мар '17 в 06:45
1
ответ
Как отследить и реализовать опцию отмены для вложенного Runnable в Java
Я работаю над приложением Java, которое использует ZMQ обработать запрос. Мой код имеет несколько вложенных Runnable которые как в следующей структуре: private class SomeRunnable implements Runnable { @Override public void run() { while (!stop) { tr…
30 авг '18 в 10:01
0
ответов
Несколько потоков Вставка строк в таблицу в Grails
Я пытаюсь вставить несколько строк данных в таблицу с помощью многопоточной программы в стандартном приложении Groovy-Grails. Приложение использует стандартные объекты GORM для взаимодействия с базой данных. Каждый поток вставляет различный набор ст…
04 июл '17 в 21:57
2
ответа
Вести счетчик с ExecutorService?
Я хотел бы сохранить счетчик выполненных потоков, чтобы использовать в тех же потоках, которые я выполняю. Проблема здесь в том, что, хотя счетчик увеличивается, он увеличивается неравномерно, и из вывода консоли я получил это (у меня есть цикл for,…
31 янв '18 в 20:57
3
ответа
Как узнать, когда все потоки в ExecutorService завершены?
Я знаю это shutdown() а также awaitTermination() существовать. Проблема заключается в том, что runnables в пуле должны иметь возможность добавить к нему неизвестный номер (не может использовать обратный отсчет) других runnables, и если я позвоню shu…
04 апр '15 в 20:04
9
ответов
Разница между executor.submit и executor.execute в этом коде в Java?
Я учусь пользоваться exectorServices в бассейн threads и отправить задачи. У меня есть простая программа ниже import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; class Processor i…
10 сен '13 в 23:22
2
ответа
Выполнение заданий Java многопоточным с executorservice?
Как мне реализовать такую функцию? У меня есть динамическая очередь, которая заполняется в неизвестное время с помощью runnables, которые должны быть выполнены. ExecutorService должен запускать только ограниченное количество потоков, при достижени…
03 май '15 в 13:45
0
ответов
Java: неожиданный параллелизм в однопоточном ThreadPoolExecutor
У меня есть ряд MyRunnable объекты запланированы на ExecutorService создано Executors.newFixedThreadPool(1), каждый stepX метод регистрирует, когда он начинает выполняться, и в соответствии с моим журналом у меня есть MyRunnable объекты с перекрываю…
31 окт '17 в 09:11
2
ответа
Как перестать работать ScheduledExecutorService?
В моем проекте у меня есть график, который может превратиться в анимацию в зависимости от того, нажмем ли мы кнопку "Старт" или "Стоп". Я могу начать, но я не знаю, как это остановить. Метод shutdownNow() не дает результата. Как я могу это сделать? …
26 апр '18 в 17:24
1
ответ
Завершение вызова ScheduledExecutorService для бесконечного планирования
Я использую ScheduledExecutorService, который будет запускаться каждую минуту бесконечно Может кто-нибудь сказать мне, когда вызывать завершение работы на ScheduledExecutorService Я уже посмотрел в Guava MoreExecutors. Это не работает, так как мне н…
21 ноя '18 в 06:04