Описание тега threadpoolexecutor

Описание тега Вопросы с тегом
In Java, an ExecutorService that executes each submitted task using one of possibly several pooled threads.
1 ответ

FixedThreadPool не выполняется должным образом

Я создал newFixedThreadPool размером 100 и запустил на нем 500 потоков. Все потоки запускаются правильно, и все занимают достаточно времени, которое они все должны занять. Но тогда исполнитель просто закрылся с каким-то потоком, и большинство из них…
20 июл '16 в 12:48
3 ответа

Какой исполнитель пула потоков Java использовать, чтобы легко изменить размер пула?

Мне нужно выполнить большое количество краткосрочных задач. я использую ThreadPoolTaskExecutor для этого, но мне нужно изменить минимальный / максимальный размер пула потоков автоматически во время выполнения. Как это сделать? Сейчас я использую вне…
22 май '15 в 17:24
4 ответа

Метод ThreadFactory newThread() вызывается только один раз для каждого вызова submit() в ThreadPoolExectutor

Я пытаюсь назначить номер для каждого из MyRunnable представлен ThreadPoolExecutor но мне не удалось. Мой фрагмент кода: import java.util.concurrent.*; class SimpleThreadFactory implements ThreadFactory { String name; static int threadNo = 0; public…
18 янв '16 в 14:58
2 ответа

Отмена задачи в threadPoolExecutor

Я создал экземпляр threadPoolExecutor и отправил асинхронную задачу в пул и получил объект Future, а затем попытался отменить задачу, операция отмены не работает... Задача связана с вызовами базы данных. Код как ниже, private ThreadPoolExecutor _sch…
13 май '14 в 07:27
1 ответ

Как отследить и реализовать опцию отмены для вложенного Runnable в Java

Я работаю над приложением Java, которое использует ZMQ обработать запрос. Мой код имеет несколько вложенных Runnable которые как в следующей структуре: private class SomeRunnable implements Runnable { @Override public void run() { while (!stop) { tr…
30 авг '18 в 10:01
1 ответ

Точность исполнения по расписанию

У меня проблема с ScheduledExecutorService в Java (я не сталкивался с этой проблемой пару дней назад, что делает его странным для меня). Пожалуйста, найдите код ниже и вывод на консоль. Задержка между повторным выполнением задачи составляет 1 мс, по…
13 мар '13 в 07:02
1 ответ

Невозможно скачать второй файл, когда первый в процессе

Я могу загрузить один файл за раз, но когда я пытаюсь загрузить другой файл, если первый выполняется, загрузка не начинается. Загрузка второго файла начинается только после завершения первого. Я хочу скачать два или более файлов одновременно. privat…
05 дек '14 в 10:05
1 ответ

Многопоточный обработчик против ThreadPoolExecutor

У меня есть несколько менеджеров, которые выполняют разные задачи, и мне нужно, чтобы эти задачи выполнялись в фоновом режиме, чтобы основной поток оставался свободным. Итак, я использую 3 потока и связываю их с обработчиками (с главным менеджером).…
29 ноя '17 в 15:32
0 ответов

Java: неожиданный параллелизм в однопоточном ThreadPoolExecutor

У меня есть ряд MyRunnable объекты запланированы на ExecutorService создано Executors.newFixedThreadPool(1), каждый stepX метод регистрирует, когда он начинает выполняться, и в соответствии с моим журналом у меня есть MyRunnable объекты с перекрываю…
31 окт '17 в 09:11
1 ответ

Исполнитель пула потоков Java

Я делаю заявку на напоминание. У меня есть задания в очереди приоритетов. Пример задания объекта {job_id : 1001, epoch : 1514140200000}, Задача состоит в том, чтобы заставить работу выполняться в то время. Я планирую исключить задание из очереди, на…
19 дек '17 в 16:28
0 ответов

Future.get() возвращает результаты намного позже, чем доступно в Java 8

Я использую исполнителя внутри веб-приложения, работающего в tomcat. Каждый запрос, поступающий на tomcat, отправляет новое задание в одноэлементную службу ExecutorService. Служба ExecutorService настроена на 12 потоков, что соответствует количеству…
21 фев '15 в 05:11
2 ответа

Использование пула потоков для добавления в список

Я пытаюсь прочитать файл и добавить каждую строку в список. Простой рисунок, объясняющий цель Основной класс - public class SimpleTreadPoolMain { public static void main(String[] args) { ReadFile reader = new ReadFile(); File file = new File("C:\\my…
28 апр '17 в 12:17
2 ответа

Выполнять запросы с помощью Retrofit внутри пользовательского Runnable

Я мигрирую из Volley к пользовательской реализации с использованием Retrofit, но я пытаюсь добавить в мою реализацию некоторые из Volley функции, которые мне понравились, например RequestQueue.cancel(строковый тег) Если Request имеет запрошенный тег…
24 апр '14 в 13:05
0 ответов

Как создать новый объект ThreadPoolTaskExecutor при его отключении в весеннем autowire

Я автоматически подключаю ThreadPoolTaskExecutor в свой класс весеннего пакетного редактора. Я должен проверить, жив ли исполнитель, прежде чем создавать поток. И если исполнитель выключен, он должен быть восстановлен. Можно ли это сделать весной? p…
22 май '18 в 14:24
1 ответ

Поток Task Executor не возвращается в пул в случае исключения

Когда во вложенной цепочке происходит сбой и она достигает потока канала ошибок, потоки исполнителя задач блокируются и не возвращаются в пул. Есть ли способ указать, что конец потока достигнут и их нужно вернуть в пул. например сплиттер разбивает п…
01 окт '15 в 16:55
1 ответ

Настройка тайм-аута ThreadPoolExecutor

Я хочу установить таймаут для моего ThreadPoolExecutor. Я знаю, что я могу использовать future.get(THREAD_TIMEOUT_MS, TimeUnit.MILLISECONDS); Но этот код блокирует. Чего я хочу добиться, так это того, что я могу создать несколько Runables, которые о…
18 июн '15 в 09:26
2 ответа

Как я могу проверить, все ли задачи были выполнены (нормально или внезапно)?

У меня есть следующий класс: public class Service{ private static final ExecutorService executor = Executors.newFixedThreadPool(4); public synchronized void execute(Collection<Runnable> runs){ for(Runnable r: runs){ executor.execute(r); } } pu…
31 авг '15 в 09:56
1 ответ

ScheduledExecutorService потребляет 100% ЦП, когда corePoolSize = 0

Я столкнулся с интересной проблемой в производстве. У меня было следующее ScheduledThreadPool код выделения: ScheduledExecutorService executorService = Executors.newScheduledThreadPool(Runtime.getRuntime().availableProcessors() - 1); Пул потоков пер…
20 ноя '18 в 20:42
1 ответ

Многопоточность внутри Java-сервлетов

В моем приложении пользователь может создавать фильтры данных во всех определенных приложениях. Я решил заставить эту задачу выполняться в другом потоке, поскольку обработка всех приложений может занять некоторое время. Я использую: private static f…
21 фев '16 в 15:16
1 ответ

ThreadPoolExecutor непредвиденная ошибка

Сложите ниже простую тестовую программу, которая должна параллельно выполнять некоторые задачи. Каждый раз мы отправляем 6 заданий и ждем завершения. Затем представлен другой набор задач. import java.util.concurrent.*; public class ThreadExecutorTes…
18 июл '18 в 20:15