Resultados de la búsqueda a petición "future"
Opción Scala [Futuro [T]] a Futuro [Opción [T]]
¿Cómo puedo convertirOption[Future[T]] aFuture[Option[T]] en scala? Quiero usarlo en: val customerAddresses = for { a <- addressDAO.insert(ca.address) // Future[Address] ia <- ca.invoiceAddress.map(addressDAO.insert) // Option[Future[Address]] ...
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 ...
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, ...
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 ...
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 / ...
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") ...
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 ...
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 ...
¿Cuál es la ventaja de usar FutureTask sobre Callable?
Hay dos enfoques para enviar y sondear tareas para obtener resultados FutureTask futureTask = new FutureTask<String>(callable);Usar combinación deCallable yFuture y presentar enExecutorService. Recuperar resultado usandofuture.get(). Future ...
Confusión acerca de los hilos lanzados por std :: async con el parámetro std :: launch :: async
Estoy un poco confundido sobre elstd::async función. La especificación dice: la operación asincrónica se ejecuta "como en un nuevo hilo de ejecución" (C ++ 11 §30.6.8 / 11). Ahora, ¿qué se supone que significa eso? A mi entender, el ...