Estou tentando usar a ThreadPoolExecutorclasse Java para executar um grande número de tarefas pesadas com um número fixo de threads. Cada uma das tarefas possui muitos locais nos quais pode falhar devido a exceções. Subclassifiquei ThreadPoolExecutore substituí o afterExecutemétodo que deve...
newCachedThreadPool() versus newFixedThreadPool() Quando devo usar um ou outro? Qual estratégia é melhor em termos de utilização de
Digamos que eu tenha 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 é: Tome uma tarefa da fila Envie para o executor Ligue para .get no futuro retornado e bloqueie até que um resultado...
Parece ser impossível criar um pool de threads em cache com um limite para o número de threads que ele pode criar. Aqui está como Executors.newCachedThreadPool estático é implementado na biblioteca Java padrão: public static ExecutorService newCachedThreadPool() { return new...
Qual é exatamente a diferença entre o tamanho do pool principal e o tamanho máximo do pool quando falamos em termos de ThreadPoolExecutor? Isso pode ser explicado com a ajuda de um
Quero criar um ThreadPoolExecutortal que, quando atingir seu tamanho máximo e a fila estiver cheia, o submit()método bloqueie ao tentar adicionar novas tarefas. Preciso implementar um personalizado RejectedExecutionHandlerpara isso ou existe uma maneira de fazer isso usando uma biblioteca Java...
Já faz algum tempo que estou frustrado com o comportamento padrão ThreadPoolExecutorque sustenta os ExecutorServicepools de threads que tantos de nós usamos. Para citar os Javadocs: Se houver mais de corePoolSize, mas menos de threads maximumPoolSize em execução, um novo thread será criado...