Resultados da pesquisa a pedido "future"
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()); ...
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) ...
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 ...
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 ...
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 ...
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") ...
O Doctest não reconhece a divisão __futuro __.
Eu tenho o seguinte doctest escritox.doctest: This is something: >>> x = 3 + 4 foo bar something else: >>> from __future__ import division >>> y = 15 >>> z = int('24') >>> m = z / y >>> print (m) 1.6Mas quando eu corripython -m doctest x.doctest ...
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 ...