Resultados da pesquisa a pedido "executorservice"
Como escolher um executor para CompletableFuture :: supplyAsync
CompletableFuture::supplyAsync(() -> IO bound queries) Como escolhi um Executor para CompletableFuture :: supplyAsync para evitar poluir oForkJoinPool.commonPool(). Existem muitas opções emExecutors (newCachedThreadPool, ...
Como é uma recursão de terminação de executor em java?
Este é um programa que lê o site de informações para o formato anterior, usa recursão e executor. Funciona bem, meu problema é testar se o programa foi concluído e a notificação de sucesso. public class NewClass { static String levels[] = { ...
Como verificar se todas as tarefas em execução no ExecutorService foram concluídas
Eu tenho o ConcurrentLinkedDeque que estou usando para elementos push / pop sincrônicos e algumas tarefas assíncronas que estão tirando um elemento da pilha e, se esse elemento tem vizinhos, está pressionando-o para empilhar. Código de ...
Bloco ThreadPoolExecutor quando a fila está cheia?
Estou tentando executar muitas tarefas usando um ThreadPoolExecutor. Abaixo está um exemplo hipotético: def workQueue = new ArrayBlockingQueue<Runnable>(3, false) def threadPoolExecutor = new ThreadPoolExecutor(3, 3, 1L, TimeUnit.HOURS, ...
Java: Como obter threads concluídos para capturar tarefas da execução de threads
Estou trabalhando em um aplicativo multithread com tarefas com tempos de execução variados. Quando um encadeamento termina, existe uma maneira de assumir algumas tarefas de um encadeamento ainda em execução? Aqui está um exemplo. Eu inicio o meu ...
Como esperar por um thread que gera seu próprio thread?
Estou tentando testar um método que funciona em um thread separado, simplificado é assim: public void methodToTest() { Thread thread = new Thread() { @Override public void run() { Clazz.i = 2; } }; thread.start(); }No meu teste de unidade, ...
Como capturar exceções no FutureTask
Depois de descobrir queFutureTask correndo em umExecutors.newCachedThreadPool() no Java 1.6 (e do Eclipse) engole exceções no diretórioRunnable.run() método, tentei encontrar uma maneira de capturá-los sem adicionar throw / catch a todos os ...
programa para enviar e-mails por threads diferentes ao mesmo tempo através de processamento paralelo
Eu tenho o programa abaixo que envia o email usando java mail API, agora este é o programa simples que desenvolvi agora e quero modificar em termos de execução paralela usando o executorframework que eu quero que 5 threads ...
Como desligar corretamente java ExecutorService
Eu tenho um java simplesExecutorService que executa alguns objetos de tarefa (implementaCallable) ExecutorService exec = Executors.newSingleThreadExecutor(); List<CallableTask> tasks = new ArrayList<>(); // ... create some tasks for ...
invokeAll () não está disposto a aceitar uma coleção <Callable <T>>
Não consigo entender por que esse código não será compilado ExecutorService executor = new ScheduledThreadPoolExecutor(threads); class DocFeeder implements Callable<Boolean> {....} ... List<DocFeeder> list = new LinkedList<DocFeeder>(); ...