Executando uma tarefa em paralelo a outra tarefa

Eu tenho o seguinte

xecutores Java: como ser notificado, sem bloquear, quando uma tarefa é concluíd

Digo que tenho uma fila cheia de tarefas que preciso enviar para um serviço executor. Eu quero que eles sejam processados um de cada vez. A maneira mais simples de pensar é: Execute uma tarefa da filaEnvie para o executor Ligue para o futuro ...

Como implementar PriorityBlockingQueue com ThreadPoolExecutor e tarefas personalizadas

Pesquisei bastante, mas não consegui encontrar uma solução para o meu problema. Eu tenho minha própria turmaBaseTask, que usa umThreadPoolExecutor para lidar com tarefas. Se eu não quiser priorizar (ou seja, usar umLinkedBlockingQueue) isso ...

asyncio: É possível cancelar um futuro executado por um Executor?

Gostaria de iniciar uma função de bloqueio em um Executor usando a chamada assíncrona loop.run_in_executor e depois cancelá-la mais tarde, mas isso não parece estar funcionando para mim. Aqui está o código: import asyncio import time from ...

Vários threads gravando no mesmo CSV em Python

Eu sou novo no multi-threading em Python e atualmente estou escrevendo um script que anexa a um arquivo csv. Se eu tivesse vários threads enviados para umconcurrent.futures.ThreadPoolExecutor que anexa linhas a um arquivo csv. O que eu poderia ...

Como fazer o bloco de métodos submit () do ThreadPoolExecutor se ele estiver saturado?

ExecutorService desempenho lento de vários threads

Estou tentando executar um cálculo simples (chamaMath.random() 10000000 vezes). Surpreendentemente, executá-lo no método simples executa muito mais rápido do que usar o ExecutorServic Li outro tópico em O surpreendente ponto de equilíbrio de ...

Chamar o Looper mais de uma vez causa "o envio de mensagem para um manipulador em um encadeamento"

Estou usando um Executor [pool de threads fixos] com meu próprio ThreadFactory que adiciona um Looper: Handler HANDLER = new Handler(); Executor THREADS = Executors.newFixedThreadPool(THREAD_POOL_SIZE, new ThreadFactory() { @Override public ...

Como parar a execução do próximo thread em um ScheduledThreadPoolExecutor

Eu tenho um ScheduledThreadPoolExecutor que possui um thread e é executado a cada 30 segundos. Agora, se o segmento em execução atual gerar alguma exceção, preciso garantir que o próximo segmento não seja executado e o ...

Precisão do executor agendado Java

á uma peculiaridade que encontrei ao usar executores agendados Java e fiquei imaginando se o que eu experimentei é norma Preciso agendar tarefas que são executadas a uma taxa predefinida de 5 segundos. Espera-se que essas tarefas levem mais de ...