Resultados da pesquisa a pedido "future"
Como solicitar ao CompletableFuture usar threads não daemon?
Eu escrevi o seguinte código: System.out.println("Main thread:" + Thread.currentThread().getId()); CompletableFuture<Void> future = CompletableFuture.runAsync(() -> { try { System.out.println("Before sleep thread:" + ...
Como matar os tópicos relacionados ao CompletableFuture?
Eu tenho um método que está verificando o tempo de execução CompletableFuture. Se esse CompletableFuture estiver em execução por mais de 2 segundos, eu quero matar esta tarefa. Mas como posso fazer isso se não tenho controle sobre o thread onde ...
Tudo bem destruir uma std :: promessa antes que future.get () seja chamado?
Eu queria saber se não há problema em chamar promessa.get_future (), mover esse futuro para outro lugar (por exemplo, para um vetor) e, possivelmente, deixar a promessa morrer antes mesmo que o futuro.get () seja chamado. No exemplo a seguir, a ...
Como associar associações de carga sem duplicação no NHibernate?
Eu precisaria carregar uma lista de objetos muito grandes com tantos filhos e filhos de crianças. qual é a melhor abordagem a ser adotada? Estou usando o banco de dados Oracle 11g e escrevi o método abaixo, mas resulta em produto cartesiano ...
O que Future.cancel () faz se não interrompe?
Dejava docs em Future.cancel () [http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/Future.html#cancel%28boolean%29] boolean cancel(boolean mayInterruptIfRunning)Tenta cancelar a execução desta tarefa. Essa tentativa falhará se a ...
Por que isso não está compilando? (RValue como argumentos do segmento CTOR)
Olá, aqui está um código de teste que escrevi no MSVC12. Alguém poderia me dizer por que o std :: move quando passo parâmetros para o thread não está convertendo as variáveis em RValue refs ?? E o que eu devo fazer. Obrigado! ///some arbitrary ...
boost :: future e continuations - conjunto de valores, mas o futuro ainda bloqueia
Estou tentando fazer a seguinte continuação funcionar - masf.get() blocos. O que há de errado? #include <iostream> #define BOOST_THREAD_PROVIDES_FUTURE #define BOOST_THREAD_PROVIDES_FUTURE_CONTINUATION #include <boost/thread/future.hpp> struct ...
Usando Futuros em Atores Akka
Estou apenas começando a aprender Akka Actors em Scala. Meu entendimento é que as mensagens recebidas por um ator são colocadas em fila na caixa de correio de um ator e processadas uma por vez. Ao processar as mensagens uma de cada vez, ...
É possível instalar um retorno de chamada após a conclusão do processamento da solicitação no Spray?
Estou tentando servir grandes arquivos temporários do Spray. Preciso excluir esses arquivos quando a solicitação HTTP for concluída. Não consegui encontrar uma maneira de fazer isso até agora ... Estou usando um código parecido ...
O futuro objeto retornado por executorService.submit (Runnable) mantém alguma referência ao objeto executável?
Vamos supor que temos o seguinte código: List<Future<?>> runningTasks; ExecutorService executor; ... void executeTask(Runnable task){ runningTasks.add(executor.submit(task)); }Minhas perguntas são: FazrunningTasks mantenha uma referência aotask ...