Вопросы по теме 'threadpoolexecutor'
Тестирование PriorityBlockingQueue в ThreadPoolExecutor
Я реализовал свой ThreadPoolExecutor с помощью PriorityBlockingQueue, как в этом примере: https://stackoverflow.com/a/12722648/2206775
и написал тест:
PriorityExecutor executorService = (PriorityExecutor)...
4349 просмотров
schedule
27.02.2022
Как мы узнаем, что threadPoolExecutor завершил выполнение
У меня есть родительский поток, который отправляет сообщения в MQ, и он управляет ThreadPoolExecutor для рабочих потоков, которые слушают MQ и записывают сообщение в выходной файл. Я управляю пулом потоков размером 5. Поэтому, когда я запускаю свою...
2600 просмотров
schedule
03.12.2022
Прервать поток, выполняющий HTTP-вызов в Java
Я пишу java-программу для HTTP-вызова сервера в другом потоке. Следующий код я выполняю в отдельной вызываемой задаче в исполнителе пула потоков.
public static class MyRunnable implements Callable<Boolean>{
@Override
public Boolean...
2041 просмотров
schedule
05.02.2022
Как мне получить доступ к членам класса в хуках beforeExecute и afterExecute в ThreadPoolExecutor?
Я расширяю класс ThreadPoolExecutor. Внутри него я хочу установить значение члена в beforeExecute (Thread t, Runnable r) и afterExecute (Runnable r, Throwable t). Я не уверен, как это сделать. Может ли кто-нибудь помочь мне с этим?
308 просмотров
schedule
13.10.2022
Как остановить выполнение задачи в исполнителе пула потоков Android
У меня есть асинхронная задача в моем проекте, как показано ниже.
@SuppressLint("NewApi")
private void callTask() {
new Task() {
@Override
protected void doInBackground(String... params) {
}...
2451 просмотров
schedule
25.10.2022
Очередь блокировки пула потоков Java, выполнять всегда последние несколько
У меня есть несколько задач, которые создаются каким-то событием. Я хочу всегда выполнять последние несколько задач (допустим, 6).
Я использую фиксированный пул потоков. Но проблема, с которой я столкнулся, заключается в том, что он использует...
349 просмотров
schedule
27.06.2023
cancel() не работает при попытке отменить задачи в ThreadPoolExecutor Android
У меня есть несколько загрузок, которые отправляются в качестве задач на ThreadPoolExecutor . Теперь я создаю этот ThreadPoolExecutor в глобальном классе, который расширяет Application . Я храню все отправленные задачи в хэш-карте с...
670 просмотров
schedule
22.10.2023
реализация PriorityQueue на ThreadPoolExecutor
Боролся с этим уже более 2-х дней.
реализовал ответ, который я видел здесь Указать выполнение порядка задач в Java
public class PriorityExecutor extends ThreadPoolExecutor {
public PriorityExecutor(int corePoolSize, int maximumPoolSize,...
3796 просмотров
schedule
20.02.2024
Объем службы исполнителя в java?
Недавно я использовал шаблон виртуальной машины для записи некоторого содержимого в файл .vm, а затем сохранял содержимое файла vm в виде файла .txt на своем компьютере. Сначала я создавал отдельный поток для каждого процесса создания файла, что не...
797 просмотров
schedule
22.09.2022
ThreadPoolTaskExecutor продолжает работать, как контролировать завершение работы?
Я пишу весеннее загрузочное приложение с помощью ThreadPoolTaskExecutor. Вот мой класс приложения:
import info.gandraweb.apns.service.MessageService;
import info.gandraweb.apns.settings.AppSettings;
import org.slf4j.Logger;
import...
3392 просмотров
schedule
14.10.2022
Java: я хочу настроить размер пула потоков. Как я могу определить начало сбора данных CMS или другие общесистемные факторы, влияющие на доступный ЦП?
(Специфика этого вопроса касается мода для Minecraft. В общем, вопрос касается изменения размера пула потоков в зависимости от загрузки системы и доступности ЦП).
Я исхожу из фона Objective C и Apple libdispatch (Grand Central Dispatch) для...
502 просмотров
schedule
28.06.2023
Как выбрать исполнителя для CompletableFuture::supplyAsync
CompletableFuture::supplyAsync(() -> IO bound queries)
Как выбрать Executor для CompletableFuture::supplyAsync, чтобы не загрязнять ForkJoinPool.commonPool() .
В Executors есть много вариантов ( newCachedThreadPool , newWorkStealingPool...
6308 просмотров
schedule
18.02.2022
Реализация пула потоков в API JAX-RS
В API JAX-RS я хочу реализовать пул потоков для выделения новых входящих запросов новому потоку из пула. Мой API в настоящее время выглядит так:
@Service
@Path("/")
public class SampleService {
@POST
@Path("/pass")...
1024 просмотров
schedule
05.03.2024
java ThreadPoolExecutor не может создать собственный поток
Мне нужно иметь глобальный пул потоков в моей системе для обработки заказов клиентов. Система основана на tomcat и должна принимать запросы клиентов 24/7. Я использовал ThreadPoolExecutor следующим образом:
private ThreadPoolExecutor exec = new...
164 просмотров
schedule
14.01.2023
Шаблон параллелизма Java для внешнего общего ресурса (смарт-карт)
У меня есть служба веб-сервера, где клиенты запрашивают вычисление смарт-карты и получают результат. Доступный номер смарт-карты может уменьшаться или увеличиваться во время работы сервера, например, я могу физически добавить или удалить...
1722 просмотров
schedule
02.01.2023
Метод ThreadFactory newThread() вызывается только один раз для каждого вызова submit() в ThreadPoolExectutor
Я пытаюсь присвоить номер каждому из MyRunnable , отправленному ThreadPoolExecutor , но мне это не удалось.
Мой фрагмент кода:
import java.util.concurrent.*;
class SimpleThreadFactory implements ThreadFactory {
String name;
static...
727 просмотров
schedule
16.11.2023
Будет ли количество одновременно запущенных потоков в пуле потоков фиксированного размера всегда меньше, чем corePoolSize, если очередь не заполнена?
В javadoc говорится:
Когда отправляется новая задача [...] и выполняется меньше потоков corePoolSize, создается новый поток для обработки запроса, даже если другие рабочие потоки простаивают. Если запущено больше, чем corePoolSize, но...
328 просмотров
schedule
17.12.2023
Динамически изменять corePoolSize для ThreadPoolExecutor
Предположим, что на машине с 4 процессорами работает пул потоков, и я хочу выполнить динамическое управление нагрузкой для этого пула. Можно ли изменить corePoolSize, когда в пуле запущены какие-то потоки? То есть при низкой нагрузке допускается...
782 просмотров
schedule
30.01.2023
Почему мои темы все еще активны после моей попытки закрыть их?
В моем классе есть следующие функции: https://codeshare.io/kvze0
public void startFtp(String address, int port, String username, String password, String filepath, String file)
{
//...parsing parameter to class variables
try {...
110 просмотров
schedule
03.01.2024
Как узнать статус каждой задачи, выполняемой в исполнителе пула потоков в java
Я использую Spring ThreadPoolTaskExecutor для выполнения задач. Я хочу знать статус потока в ThreadPoolTaskExecutor , например, завершен ли он, выполняется или завершен. Если поток выполнения задачи завершается с ошибкой, мне нужно обновить...
1262 просмотров
schedule
03.06.2024
