Resultados da pesquisa a pedido "concurrent.futures"
CompletableFuture não está sendo executado. Se eu usar o pool ExecutorService, seu trabalho conforme o esperado, mas não com o pool comum forkJoin padrão
Eu estou tentando executar a seguinte classe está sendo finalizada sem executar o CompletableFuture. public class ThenApplyExample { public static void main(String[] args) throws Exception { //ExecutorService es = ...
Python: concurrent.futures Como torná-lo cancelável?
Python concurrent.futures e ProcessPoolExecutor fornecem uma interface elegante para agendar e monitorar tarefas. Futuros aindaprovidenciar [https://docs.python.org/3/library/concurrent.futures.html#concurrent.futures.Future] um método .cancel ...
Tempos limite de espera para concurrent.futures
Vejo duas maneiras de especificar tempos limites emconcurrent.futures [https://docs.python.org/3/library/concurrent.futures.html]. as_completed()wait()Ambos os métodos lidam com N executando futuros. Gostaria de especificar um tempo limite ...
fila de multiprocessamento cheia
Estou usando concurrent.futures para implementar o multiprocessamento. Estou recebendo uma fila.Erro completo, o que é estranho, porque estou atribuindo apenas 10 trabalhos. A_list = [np.random.rand(2000, 2000) for i in range(10)] ...
Qual é a diferença entre concurrent.futures e asyncio.futures?
Para esclarecer o motivo desta pergunta: É confuso usar dois módulos com o mesmo nome. O que eles representam que os diferencia? Que tarefa (s) um pode resolver que o outro não pode e vice-versa?
Como você mata futuros depois que eles começam?
Estou usando o novoconcurrent.futures [https://docs.python.org/3/library/concurrent.futures.html]módulo (que também possui um backport Python 2) para executar algumas E / S simples multithread. Estou com problemas para entender como eliminar ...
Scala Futures: manipulador de erros padrão para todas as novas exceções criadas ou mapeadas
Existe alguma possibilidade de sempre criar um bloco Future {...} com um manipulador onFailure padrão? (por exemplo, escreva o rastreamento de pilha no console)? Esse manipulador também deve ser anexado automaticamente aos futuros mapeados (novos ...
Compartilhar multiprocessamento objetos unserializable entre processos
Há três perguntas possíveis, duplicatas (mas muito específicas): Como configurar corretamente os objetos proxy de multiprocessamento para objetos que já ...
Como gerar futuro apenas se o trabalhador livre estiver disponível
Eu estou tentando enviar informações extraídas de linhas de um arquivo grande para um processo em execução em algum servidor.Para acelerar isso, gostaria de ...
Página 1 do 2