Resultados da pesquisa a pedido "executorservice"
Como usar o executor personalizado no Akka dispatcher
Estou tentando usar um executor personalizado para um despachante em Akka. Especificamente, quero agrupar um executor existente com o meu (registro, depuração etc.). Eu olhei para partes relevantes ...
Como posso terminar as tarefas que atingiram o tempo limite no multithreading?
Preciso criar uma biblioteca na qual terei métodos síncronos e assíncronos. executeSynchronous() - espera até que eu tenha um resultado, retorna o resultado.executeAsynchronous() - retorna um futuro imediatamente, que pode ser processado depois ...
Pool de segmentos dinâmicos
Eu tenho um processo de execução longa que escuta eventos e faz um processamento intenso. Atualmente eu usoExecutors.newFixedThreadPool(x) para diminuir o número de tarefas que são executadas simultaneamente, mas, dependendo da hora do dia e ...
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 ...
a execução do código java gera resultados diferentes na depuração sem pontos de interrupção e execução normal. O ExecutorService está quebrado?
TL: DRExecutorService executorService = Executors.newFixedThreadPool(8); na depuração é executado simultaneamente, mas no tempo de execução normal, ele é iniciado simultaneamente, mas depois é executado em um único thread. Eu tenho algum código ...
Como definir o tempo limite de gravação do soquete em java?
Eu tenho um problema com a manipulação de soquete em java. Estou executando um servidor TCP com várias conexões de cliente. Por motivos de desempenho, usei um pool de threads simples para manipular pacotes. Por favor, veja o código ...
Override método de interrupção para thread no threadpool
Diz que tenho isso: class Queue { private static ExecutorService executor = Executors.newFixedThreadPool(1); public void use(Runnable r){ Queue.executor.execute(r); } } minha pergunta é - como posso definir o thread que é usado no pool, ...
etorno de chamada @Java ExecutorService no encadeamento encerrado
Estou usando o ExecutorService do pool de threads em cache para executar algumas tarefas em segundo plano assíncronas. Forneci meu ThreadFactory que distribui threads para o ExecutorService (sempre que necessário). Meu entendimento do pool de ...
Como desligar um ExecutorService?
Sempre que eu chamo