Resultados da pesquisa a pedido "future"
Os futuros são executados em um único segmento? (Scala)
Usando o contexto de execução implícita padrão no Scala, cada novo futuro será calculado em um único thread dedicado ou o cálculo será dividido e distribuído para vários threads no pool de threads? Não sei se isso ajuda, o pano de fundo desta ...
Como implementar o Futuro como Aplicável no Scala?
Suponha que eu precise executar dois cálculos simultâneos, esperar pelos dois e depois combinar seus resultados. Mais especificamente, preciso executarf1: X1 => Y1 ef2: X2 => Y2 simultaneamente e depois chamef: (Y1, Y2) => Y para finalmente obter ...
Exceção de timeout do vôlei Android ao usar RequestFuture.get ()
No meu fragmento, estou tentando usar o banco de dados de filme aberto do TMDB para obter detalhes sobre os filmes "Em execução". Se eu usar o método RequestFuture.get (time, TimeUnit) para executar essa solicitação de vôlei, sempre recebo um ...
Por que o andThen of Future não encadeia o resultado?
oandThen ou seja, eu aprendi com issoresponda [https://stackoverflow.com/a/20292526/2210478]é um compositor de funções. Diz isso f andThen g andThen hserá igual a h(g(f(x)))Isto implica ah function receberá entrada deg(f(x)) Mas para oandThen ...
Como retorno condicionalmente diferentes tipos de futuros?
Eu tenho um método que, dependendo de um predicado, retornará um futuro ou outro. Em outras palavras, uma expressão if-else que retorna um futuro: extern crate futures; // 0.1.23 use futures::{future, Future}; fn f() -> impl Future<Item = usize, ...
Confusão sobre threads iniciados pelo parâmetro std :: async com std :: launch :: async
Estou um pouco confuso sobre ostd::async função. A especificação diz: operação assíncrona sendo executada "como se estivesse em um novo encadeamento de execução" (C ++ 11 §30.6.8 / 11). Agora, o que isso significa? No meu entendimento, o ...
qual é a vantagem de usar o FutureTask sobre o Callable?
Existem duas abordagens para enviar e pesquisar tarefas para obter resultados FutureTask futureTask = new FutureTask<String>(callable);Use combinação deCallable eFuture e enviar emExecutorService. Recuperar resultado usandofuture.get(). Future ...
palavra-chave de bloqueio no Scala
Qual é a diferença entreFuture(blocking(blockingCall())) eblocking(Future(blockingCall()))? Ambos são definidos emscala.concurrent._ Eu olheino scala docs [http://docs.scala-lang.org/overviews/core/futures.html#blocking]e alguma outra respostas ...
Futuros - mapa vs flatmap
Eu li os documentos sobremap eflatMap e eu entendo issoflatMap é usado para uma operação que aceita umFuture parâmetro e retorna outroFuture. O que não entendo completamente é por que gostaria de fazer isso. Veja este exemplo: O usuário acessa ...
O futuro não está completo?
object Executor extends App { implicit val system = ActorSystem() implicit val materializer = ActorMaterializer() implicit val ec = system.dispatcher import akka.stream.io._ val file = new File("res/AdviceAnimals.tsv") ...