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

Исполнитель и демон в Java
У меня есть объект MyThread, который я создаю, когда мое приложение загружается через сервер, я помечаю его как поток демона и затем вызываю для него start() . Поток предназначен для ожидания информации из очереди, пока приложение активно. Моя...
12391 просмотров
schedule 02.04.2022

Java Executors: как установить приоритет задачи?
Есть ли возможность установить приоритет задач, выполняемых Исполнителями? Я нашел несколько утверждений в JCIP о том, что это возможно, но я не могу найти ни одного примера и не могу найти ничего, связанного с этим, в документации. Из JCIP:...
46429 просмотров

Политика ThreadPoolExecutor
Я пытаюсь использовать ThreadPoolExecutor для планирования задач, но у меня возникают проблемы с его политиками. Вот его заявленное поведение: Если выполняется меньше, чем corePoolSize потоков, Executor всегда предпочитает добавлять новый поток,...
5849 просмотров

ThreadPool не выполняет задачи последовательно
Я использую фреймворк Executor специально Executors.newCachedThreadPool(); У меня есть список Runnable , например. 100. Каждое из первых 50 создает значение (хранящееся в списке), которое будет использоваться последними 50. Я подумал, что если я...
11575 просмотров

Как обеспечить сборку мусора FutureTask, которая отправляется ThreadPoolExecutor, а затем отменяется?
Я отправляю Callable объекты в ThreadPoolExecutor , и кажется, что они застряли в памяти. Посмотрев дамп кучи с помощью инструмента MAT для Eclipse, вы увидите, что на объекты Callable ссылается вызываемая переменная FutureTask$Sync . На...
7522 просмотров

Остановить Executor, когда Callable возвращает определенный результат
Я хотел бы запретить исполнителю запускать какие-либо объекты Future, даже если они были отправлены исполнителю. Запуск нескольких потоков через Executor работает нормально, но Executor должен остановиться, когда один из Callable возвращает...
1677 просмотров
schedule 30.12.2023

ScheduledExecutorService несколько потоков параллельно
Я заинтересован в использовании ScheduledExecutorService для создания нескольких потоков для задач, если предыдущая задача еще не завершилась. Например, мне нужно обрабатывать файл каждые 0,5 секунды. Первая задача начинает обработку файла, через...
9879 просмотров

Последовательное выполнение нескольких AsyncTasks
Кто-нибудь знает, как легко упорядочить несколько вызовов выполнения AsyncTask в очереди или что-то в этом роде, а затем выполнить их последовательно? Я хочу, чтобы вызываемая асинхронная задача ждала завершения предыдущей, но, похоже, я не могу...
3801 просмотров

Java ThreadPoolExecutor перестает работать через некоторое время
У меня проблема с ThreadPoolExecutor. Работает нормально часами, но иногда (в рандомное время, иногда через 2 минуты или 3 часа) перестает выполнять поставленные задачи и программа зависает. Очередь заполнена, и все основные потоки в это время...
1663 просмотров
schedule 16.06.2023

ExecutorService замедляет многопоточную производительность
Я пытаюсь выполнить простой расчет (он вызывает Math.random() 10000000 раз). Удивительно, но запуск его в простом методе выполняется намного быстрее, чем при использовании ExecutorService. Я прочитал еще один поток в удивительной точке...
6385 просмотров

Когда указывать отдельные размеры ядра и максимального пула в ThreadPoolExecutor - хорошая идея?
Я пытаюсь понять смысл указания отдельных размеров ядра и максимального пула для ThreadPoolExecutor Java 5. Насколько я понимаю, количество потоков увеличивается только после заполнения очереди, что кажется немного запоздалым (по крайней мере, с...
2001 просмотров
schedule 14.04.2022

Запланировать задачу Java на указанное время
Я хотел бы иметь возможность запланировать задачу в определенное время в Java. Я понимаю, что ExecutorService имеет возможность планировать через определенные промежутки времени и после указанной задержки, но я больше смотрю на время суток, а не на...
12460 просмотров
schedule 27.11.2023

Точность запланированного исполнителя Java
Есть особенность, с которой я столкнулся при использовании запланированных исполнителей Java, и мне было интересно, нормально ли то, что я испытал. Мне нужно запланировать задачи, которые выполняются с предопределенной скоростью 5 секунд....
3226 просмотров
schedule 17.11.2022

Java Concurrency на практике: состояние гонки в BoundedExecutor?
Есть что-то странное в реализации BoundedExecutor в книге Java Concurrency in Practice. Предполагается, что он будет регулировать отправку задач исполнителю, блокируя отправляющий поток, когда в исполнителе достаточно потоков, либо поставленных в...
1710 просмотров
schedule 19.06.2022

Кража работы/задачи ThreadPoolExecutor
В моем проекте я создаю среду выполнения Java, которая получает рабочие запросы от клиента. Работа (различного размера) разбивается на набор задач, а затем ставится в очередь для обработки. Существуют отдельные очереди для обработки каждого типа...
6064 просмотров
schedule 11.10.2023

Исполнитель не обрабатывает задачи должным образом
Если я запускаю длительные задачи, Executor никогда не запускает новые потоки, если первая задача не завершена. Может ли кто-нибудь помочь мне понять, почему и как я могу это исправить? import java.util.concurrent.ExecutorService; import...
7240 просмотров
schedule 08.01.2023

Превышено время ожидания блокировки; попробуйте перезапустить транзакцию
Я пытаюсь вставить два разных потока в базу данных mysql. Вставка осуществляется подготовленным оператором. Вставка в партии 500. //g1 — это объект, сделанный глобальным для доступа к классам, реализующим runnable ExecutorService executor...
529 просмотров

Многопоточное приложение Java использует только одно ядро
У меня проблема с моей JVM, работающей на CentOS 6.0 с openJDK 1.7.0_51 64Bit. Моя система представляет собой 4-ядерную систему с 8 ГБ оперативной памяти. Я запускаю многопоточное приложение Java, которое написал сам. Он должен вставлять тонны...
6908 просмотров

Разница между Executors.newFixedThreadPool(1) и Executors.newSingleThreadExecutor()
Мой вопрос: имеет ли смысл использовать Executors.newFixedThreadPool(1)?? . В сценариях с двумя потоками (main + oneAnotherThread) эффективно ли использовать службу исполнителя? Является ли создание нового потока прямым вызовом new Runnable(){ }...
16808 просмотров
schedule 11.09.2022

Укажите предел запускаемых объектов, которые будут добавлены в ExecutorService.
Я знаю, что могу указать фиксированный размер пула потоков, используя ExecutorService executor = Executors.newFixedThreadPool(10); Я могу добавить исполняемые объекты в исполнитель, и они будут выполняться всякий раз, когда поток свободен в...
894 просмотров
schedule 20.07.2023