Resultados da pesquisa a pedido "future"
Como invocar um método repetidamente até retornar um valor `Futuro` contendo` Nenhum`
Dado um método que retorna umFuture como isso... def remove(id: String): Future[Option[User]] = Future { // removes and returns the user identified by `id` }... como invocá-lo repetidamente até que retorne umFuture valor ...
Lidar com futuros falidos
No Play Framework 2.3, uma ação pode produzir um resultado de uma chamada futura bem-sucedida como esta: def index = Action.async { val futureInt = scala.concurrent.Future { intensiveComputation() } futureInt.map(i => Ok("Got result: " + i)) ...
Scala-maneira de lidar com as condições de compreensão?
Estou tentando criar uma construção elegante com compreensão da lógica de negócios baseada em futuros. Aqui está um exemplo que contém um exemplo de trabalho baseado no tratamento de exceções: (for { // find the user by id, findUser(id) returns ...
Obtendo dados de um futuro em Scala
Eu tenho umFuture[List[Person]][1] e eu quero pegar oList[Person] a partir dele. Como eu posso fazer isso ? import scala.concurrent.Future val futPersons : Future[List[Person]] = ....
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 ...
É 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 ...
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, ...
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 ...
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 ...
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 ...