Resultados da pesquisa a pedido "future"
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 ...
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 ...
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 ...
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 compor Observables para evitar os retornos de chamada aninhados e dependentes?
Noeste blog [https://web.archive.org/web/20150712091623/http://benjchristensen.com:80/2013/05/01/functional-reactive-in-the-netflix-api-with-rxjava/] , ele dáesta [https://gist.github.com/benjchristensen/4677544](copie / cole o código a seguir) ...
Usando futuros e Thread.sleep
Ao executar esse código scala, não tenho saída no console. (Eu realmente não entendo o que está acontecendo) Se eu removerConsole.println("Console.println OK!") => tudo parece bem. Se eu removerThread.sleep(2000) => tudo parece bem. Você tem ...
falha no futuro da Scala para compreensão
Eu tenho três futuros sequenciais e uso no para compreensão como esta val comF = for { f1 <- future1 f2 <- future2 f3 <- future3 } yield { // something } comF onSuccess { } comF onFailure { // ---------------- Here is the problem ...
Os futuros em Scala são realmente funcionais?
Eu estou lendo este blogpostar [http://futurice.com/blog/an-example-of-functional-design]que afirmaFutures não são "funcionais", pois são apenas invólucros decom efeito colateral cálculos. Por exemplo, eles contêm chamadas RPC, solicitações HTTP, ...
Como usar CompletableFuture.thenComposeAsync ()?
Dado: public class Test { public static void main(String[] args) { int nThreads = 1; Executor e = Executors.newFixedThreadPool(nThreads); CompletableFuture.runAsync(() -> { System.out.println("Task 1. Thread: " + Thread.currentThread().getId()); ...
Existe Future.find seqüencial?
Eu tenho alguma função com efeito colateral, def f(): Future[Int] = { val n = Random.nextInt() println(s"Generated $n") Future(n) }e quero executá-lo repetidamente até que o predicado retorne verdadeiro. def success(n: Int): Boolean = n % 2 == ...