Мне нужно выполнить какое-то действие на 50 миллионов предметов. Я написал ниже код AtomicInteger failCounter = new AtomicInteger (0); длинный старт = System.currentTimeMillis (); ExecutorService es = Executors ....
Я создал простой сервис, такой как ... где мне нужно взять некоторые данные из базы данных в более позднем планировщике пакета com.spring.scheduler.example.spring; import org.springframework.stereotype.Service; @ ...
У меня есть приложение для Android, которое неоднократно собирает отпечатки пальцев из окружающих wifi-сетей (по научным причинам, чтобы не вторгаться в личную неприкосновенность). В любом случае, представьте, у меня есть функция, которая ...
От моих чтений кажется, что ScheduledExecutorService является правильным способом запустить и остановить таймеры в Java. Я должен портировать некоторый код, который запускает и останавливает таймер. Это не периодический таймер. Это...
Да ведь о, почему не делает java.util.concurrent, предоставляют длине очереди индикаторы для ее ExecutorServices? Недавно я делал что-то вроде этого: очередь ExecutorService = Исполнители....
У меня есть класс, содержащий ExecutorService, который может использоваться совместно потоки: class MyExecutor {ExecutorService e = Executors.newSingleThreadExecutor (); .... .... public void add (...
У меня есть ресурс (в моем случае сокет zmq, но эту деталь можно игнорировать). Ресурс не является потокобезопасным, и может использоваться только из потока, который открыл соединение. Я хочу использовать это в ...
У меня есть класс, который синглтон по своей природе и реализует вызываемый интерфейс. Ожидается, что я должен запустить поток этого синглтон-класса, как только он будет создан. Пытался ...
У меня есть проблема с исполнителями. Это правильный способ их использования? Все работает отлично в течение нескольких часов с момента выполнения программы, но потом я предполагаю, что потоки начинают вести себя немного странно ... ...
Я пытаюсь использовать как InheritableThreadLocal, так и ThreadPoolExecutor. Это не работает, потому что ThreadPoolExecutor повторно использует потоки для каждого пула (в конце концов, это пул), что означает ...
Как мне выбрать между отправкой или выполнением ExecutorService, если возвращаемое значение меня не касается? Если я тестирую оба, я не вижу никаких различий между ними, кроме возвращаемого значения. ...
В чем разница между ExecutorService eService = Executors.newFixedThreadPool (2); eService.execute (new TestThread6 ()); eService.execute (new TestThread6 ()); eService.execute (new TestThread6 ()) ...
У меня есть магазин электронной коммерции, над которым я сейчас работаю, и есть около 300 продуктов, в которых есть поле с именем "product_url". Эти поля содержат старый URL, который мне нужно полностью удалить. ...
. Я пытаюсь написать решение, в котором один поток создает задачи с интенсивным вводом-выводом, которые могут выполняться параллельно. Каждая задача имеет важные данные в памяти. Итак, я хочу иметь возможность ограничить количество ...
У меня есть фиксированный пул потоков, который запускает 7 параллельных потоков в любое время (с очередью), и я хочу превратить его в запланированный пул потоков, который выполняет только 7 одновременных заданий, но может ставить в очередь / планировать
В JavaDoc для ThreadPoolExecutor неясно, допустимо ли добавлять задачи непосредственно в BlockingQueue, поддерживающую исполнителя. В документации говорится, что вызов executeor.getQueue () «предназначен ...
Возможный дубликат: обработка исключений из задач Java ExecutorService Я использую ExecutorService из Java для координации потоков.
Для запуска потоков я использую pool = new ExecutorService (2); ...
Я пытаюсь выполнить простой расчет (он вызывает Math.random () 10000000 раз). Удивительно, но запуск простым методом работает намного быстрее, чем использование ExecutorService. Я прочитал другой ...
Проблема Я запускаю несколько вызовов какого-либо внешнего метода через ExecutorService. Я хотел бы иметь возможность прерывать эти методы, но, к сожалению, они не проверяют флаг прерывания ...
Я помещаю свои фьючерсы из ExecutorService в хэш-карту. Позже я могу вызвать отмену фьючерсов из хэш-карты. результат верен, позже я попадаю в точки останова внутри Callable...
У меня есть приложение Java, которое использует платформу Executor, и у меня есть код, который выглядит следующим образом
protected ScheduledExecutorService scheduleExecutorService = new ScheduledThreadPoolExecutor (5) My ...
Допустим, у меня есть приложение, которое использует платформу Executor как такую Executors.newSingleThreadExecutor () .submit (new Runnable () {@Override public void run () {// делать что-нибудь}
} ...
Мне интересно использовать ScheduledExecutorService для создания нескольких потоков для задач, если предыдущая задача еще не завершилась. Например, мне нужно обрабатывать файл каждые 0,5 секунды. Первая задача начинает обработку ...
Всякий раз, когда я вызываю shutdownNow ()или shutdown (), он не выключается. Я читал несколько тем, где говорилось, что отключение не гарантируется -, может ли кто-нибудь предоставить мне хороший способ сделать это?
Если мы используем ExecutorCompletionService, мы можем отправить ряд задач как Callables и получить результат, взаимодействующий с CompletionService в виде очереди. Но есть еще и invokeAll из...
Требуется запустить коллекцию задач Runnable с помощью метода invokeAll (..) ExecutorService. Но это не поддерживается на данный момент (поддерживает сбор только для вызываемой задачи) Есть какая-то конкретная причина для этого? ...
Мне нужно выполнить несколько AsyncTasks а затем собрать все их результаты, объединить и затем вернуть окончательный результат моему пользователю. Я ищу способ управлять несколькими AsyncTasks в Android. Я ...
Я использую ScheduledExecutorService для запуска запланированных потоков.
Я реализовал ServletContextListener.contextDestroyed и вызвал ScheduledExecutorService.shutdownNow и awaitTermination. Вот ...