Resultados de la búsqueda a petición "future"
bloqueo de palabras clave en Scala
Cuál es la diferencia entreFuture(blocking(blockingCall())) yblocking(Future(blockingCall()))? Ambos se definen enscala.concurrent._ He miradoen los documentos de scala [http://docs.scala-lang.org/overviews/core/futures.html#blocking]y alguna ...
Futuros - mapa vs plano
He leído los documentos sobremap yflatMap y entiendo queflatMap se utiliza para una operación que acepta unFuture parámetro y devuelve otroFuture. Lo que no entiendo completamente es por qué querría hacer esto. Toma este ejemplo: El usuario ...
El futuro no 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") ...
Mi acción PlayFramework regresa antes de que un futuro esté listo, ¿cómo actualizo un componente de página web?
Tengo una función Scala PlayFramework que llama a MongoDB y obtiene unFuture[Seq[Document]] resultado. Después de un evento de zoom / panorámica del mapa, este juegoAction La función se llama desde JavaScript en una página web a través de xhttp / ...
Esperando que un futuro cancelado termine realmente
tengo unSwingWorker que llama a un código que no verifica la interrupción del hilo. Después de la llamada aworker.cancel(true), elworker.get() método arrojaráCancellationException inmediatamente (como se supone que debe). Sin embargo, dado que el ...
Futuros en Haskell
¿Haskell tiene un equivalente de la capacidad de Alice para vincular una variable a un futuro? val a = spawn foo;donde foo es alguna función. Sé que Haskell admite canales e hilos; Espero una sintaxis tan natural como la de Alice para vincular ...
Doctest no reconoce __future __. Division
Tengo el siguiente documento 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.6Pero cuando corrípython -m doctest x.doctest ...
Futuro de Akka: ¿paralelo o concurrente?
De lo bien escritoConcurrencia Akka [http://www.artima.com/shop/akka_concurrency]: [/imgs/xFnqg.png] Comoentiendo, el diagrama señala, ambosnumSummer ycharConcat correrá en el mismo hilo. ¿Es posible ejecutar cadaFuture en paralelo, es decir, ...
Trabajo Spark con llamada HTTP asíncrona
Construyo un RDD a partir de una lista de URL, y luego trato de obtener datos con alguna llamada http asíncrona. Necesito todos los resultados antes de hacer otros cálculos. Idealmente, necesito hacer las llamadas http en diferentes nodos para ...
¿Cómo devuelvo condicionalmente diferentes tipos de futuros?
Tengo un método que, dependiendo de un predicado, devolverá un futuro u otro. En otras palabras, una expresión if-else que devuelve un futuro: extern crate futures; // 0.1.23 use futures::{future, Future}; fn f() -> impl Future<Item = usize, ...