1
ответ

Пул исполнителей не обрабатывает все элементы

Мне нужно выполнить какое-то действие на 50 миллионов предметов. Я написал ниже код AtomicInteger failCounter = new AtomicInteger (0); длинный старт = System.currentTimeMillis (); ExecutorService es = Executors ....
вопрос задан: 5 March 2019 17:23
1
ответ

как внедрить службу в поток, созданный через службу executor весной

Я создал простой сервис, такой как ... где мне нужно взять некоторые данные из базы данных в более позднем планировщике пакета com.spring.scheduler.example.spring; import org.springframework.stereotype.Service; @ ...
вопрос задан: 4 March 2019 04:29
1
ответ

Android «пропускает» периодическое выполнение Thread с использованием ScheduledExecutorService

У меня есть приложение для Android, которое неоднократно собирает отпечатки пальцев из окружающих wifi-сетей (по научным причинам, чтобы не вторгаться в личную неприкосновенность). В любом случае, представьте, у меня есть функция, которая ...
вопрос задан: 25 August 2010 13:38
1
ответ

использование ScheduledExecutorService, чтобы запуститься и остановить таймер

От моих чтений кажется, что ScheduledExecutorService является правильным способом запустить и остановить таймеры в Java. Я должен портировать некоторый код, который запускает и останавливает таймер. Это не периодический таймер. Это...
вопрос задан: 23 June 2010 19:43
1
ответ

Изящно реализующие индикаторы длины очереди к ExecutorServices

Да ведь о, почему не делает java.util.concurrent, предоставляют длине очереди индикаторы для ее ExecutorServices? Недавно я делал что-то вроде этого: очередь ExecutorService = Исполнители....
вопрос задан: 15 February 2010 17:36
0
ответов

Java: необходимо синхронизировать ExecutorService?

У меня есть класс, содержащий ExecutorService, который может использоваться совместно потоки: class MyExecutor {ExecutorService e = Executors.newSingleThreadExecutor (); .... .... public void add (...
вопрос задан: 24 April 2019 15:00
0
ответов

ScheduledThreadPoolExecutor инициализирует ресурс при запуске потока и вставляет его в работоспособный

У меня есть ресурс (в моем случае сокет zmq, но эту деталь можно игнорировать). Ресурс не является потокобезопасным, и может использоваться только из потока, который открыл соединение. Я хочу использовать это в ...
вопрос задан: 18 March 2019 17:59
0
ответов

Создать поток одноэлементного класса, используя ExecutorService.submit () в самом конструкторе?

У меня есть класс, который синглтон по своей природе и реализует вызываемый интерфейс. Ожидается, что я должен запустить поток этого синглтон-класса, как только он будет создан. Пытался ...
вопрос задан: 21 January 2019 06:28
0
ответов

Java Executor правильно?

У меня есть проблема с исполнителями. Это правильный способ их использования? Все работает отлично в течение нескольких часов с момента выполнения программы, но потом я предполагаю, что потоки начинают вести себя немного странно ... ...
вопрос задан: 13 July 2018 20:25
0
ответов

Использование InheritableThreadLocal с ThreadPoolExecutor - или - ThreadPoolExecutor, который не использует повторно потоки

Я пытаюсь использовать как InheritableThreadLocal, так и ThreadPoolExecutor. Это не работает, потому что ThreadPoolExecutor повторно использует потоки для каждого пула (в конце концов, это пул), что означает ...
вопрос задан: 4 November 2017 05:09
0
ответов

Выберите между отправкой ExecutorService и выполнением ExecutorService

Как мне выбрать между отправкой или выполнением ExecutorService, если возвращаемое значение меня не касается? Если я тестирую оба, я не вижу никаких различий между ними, кроме возвращаемого значения. ...
вопрос задан: 12 October 2017 23:50
0
ответов

завершение работы и ожидание завершения, какой первый вызов имеет какую-либо разницу?

В чем разница между ExecutorService eService = Executors.newFixedThreadPool (2); eService.execute (new TestThread6 ()); eService.execute (new TestThread6 ()); eService.execute (new TestThread6 ()) ...
вопрос задан: 26 August 2017 17:57
0
ответов

Требуется запрос MySQL: мне нужно удалить все данные в одном поле из 300 таблицы

У меня есть магазин электронной коммерции, над которым я сейчас работаю, и есть около 300 продуктов, в которых есть поле с именем "product_url". Эти поля содержат старый URL, который мне нужно полностью удалить. ...
вопрос задан: 26 August 2017 07:16
0
ответов

Java: ExecutorService, который блокируется при отправке после определенный размер очереди

. Я пытаюсь написать решение, в котором один поток создает задачи с интенсивным вводом-выводом, которые могут выполняться параллельно. Каждая задача имеет важные данные в памяти. Итак, я хочу иметь возможность ограничить количество ...
вопрос задан: 27 July 2017 02:59
0
ответов

Разница в Java между фиксированным пулом потоков и запланированным пулом потоков

У меня есть фиксированный пул потоков, который запускает 7 параллельных потоков в любое время (с очередью), и я хочу превратить его в запланированный пул потоков, который выполняет только 7 одновременных заданий, но может ставить в очередь / планировать
вопрос задан: 23 July 2017 06:14
0
ответов

Целесообразно ли добавлять задачи в BlockingQueue для ThreadPoolExecutor?

В JavaDoc для ThreadPoolExecutor неясно, допустимо ли добавлять задачи непосредственно в BlockingQueue, поддерживающую исполнителя. В документации говорится, что вызов executeor.getQueue () «предназначен ...
вопрос задан: 23 May 2017 12:22
0
ответов

Где для перехвата исключений, генерируемых Callable.call () [дубликат]

Возможный дубликат: обработка исключений из задач Java ExecutorService Я использую ExecutorService из Java для координации потоков. Для запуска потоков я использую pool = new ExecutorService (2); ...
вопрос задан: 23 May 2017 12:17
0
ответов

ExecutorService медленная многопоточная производительность

Я пытаюсь выполнить простой расчет (он вызывает Math.random () 10000000 раз). Удивительно, но запуск простым методом работает намного быстрее, чем использование ExecutorService. Я прочитал другой ...
вопрос задан: 23 May 2017 12:13
0
ответов

Как я могу сделать внешние методы прерываемыми?

Проблема Я запускаю несколько вызовов какого-либо внешнего метода через ExecutorService. Я хотел бы иметь возможность прерывать эти методы, но, к сожалению, они не проверяют флаг прерывания ...
вопрос задан: 23 May 2017 11:47
0
ответов

Будущая задача ExecutorService не отменяется по-настоящему

Я помещаю свои фьючерсы из ExecutorService в хэш-карту. Позже я могу вызвать отмену фьючерсов из хэш-карты. результат верен, позже я попадаю в точки останова внутри Callable...
вопрос задан: 6 May 2017 13:21
0
ответов

Java: Принудительная остановка потоков ExecutorService

Мой код: String [] torrentFiles = новый файл ("/ root / torrents /"). List (); если (torrentFiles.length == 0 || torrentFiles == null) {System.exit (0); } ex = ...
вопрос задан: 29 April 2016 17:30
0
ответов

Как назвать потоки пула потоков в Java [дубликат]

У меня есть приложение Java, которое использует платформу Executor, и у меня есть код, который выглядит следующим образом protected ScheduledExecutorService scheduleExecutorService = new ScheduledThreadPoolExecutor (5) My ...
вопрос задан: 1 March 2016 05:44
0
ответов

Именование потоков и пулов потоков ExecutorService

Допустим, у меня есть приложение, которое использует платформу Executor как такую ​​Executors.newSingleThreadExecutor () .submit (new Runnable () {@Override public void run () {// делать что-нибудь} } ...
вопрос задан: 6 February 2016 00:02
0
ответов

ScheduledExecutorService - несколько потоков параллельно

Мне интересно использовать ScheduledExecutorService для создания нескольких потоков для задач, если предыдущая задача еще не завершилась. Например, мне нужно обрабатывать файл каждые 0,5 секунды. Первая задача начинает обработку ...
вопрос задан: 11 November 2015 20:22
0
ответов

Как отключить ExecutorService?

Всякий раз, когда я вызываю shutdownNow ()или shutdown (), он не выключается. Я читал несколько тем, где говорилось, что отключение не гарантируется -, может ли кто-нибудь предоставить мне хороший способ сделать это?
вопрос задан: 24 June 2015 17:30
0
ответов

Как прервать потоки ExecutorService

При использовании ExecutorService, возвращаемого Executors.newSingleThreadExecutor (), как мне его прервать?
вопрос задан: 6 May 2015 16:14
0
ответов

ExecutorCompletionService? Зачем он нужен, если у нас есть invokeAll?

Если мы используем ExecutorCompletionService, мы можем отправить ряд задач как Callables и получить результат, взаимодействующий с CompletionService в виде очереди. Но есть еще и invokeAll из...
вопрос задан: 29 June 2014 07:00
0
ответов

ExecutorService.invokeAll НЕ поддерживает сбор выполненных задач

Требуется запустить коллекцию задач Runnable с помощью метода invokeAll (..) ExecutorService. Но это не поддерживается на данный момент (поддерживает сбор только для вызываемой задачи) Есть какая-то конкретная причина для этого? ...
вопрос задан: 6 June 2014 12:16
0
ответов

Как использовать ExecutorService с Android AsyncTask?

Мне нужно выполнить несколько AsyncTasks а затем собрать все их результаты, объединить и затем вернуть окончательный результат моему пользователю. Я ищу способ управлять несколькими AsyncTasks в Android. Я ...
вопрос задан: 11 November 2013 14:35
0
ответов

Tomcat 7 и ScheduledExecutorService.shutdown

Я использую ScheduledExecutorService для запуска запланированных потоков. Я реализовал ServletContextListener.contextDestroyed и вызвал ScheduledExecutorService.shutdownNow и awaitTermination. Вот ...
вопрос задан: 21 October 2013 14:04