Resultados de la búsqueda a petición "future"
¿El objeto futuro devuelto por executeorService.submit (Runnable) tiene alguna referencia al objeto ejecutable?
Supongamos que tenemos el siguiente código: List<Future<?>> runningTasks; ExecutorService executor; ... void executeTask(Runnable task){ runningTasks.add(executor.submit(task)); }Mis preguntas son: HacerunningTasks mantener una referencia a ...
Transforma el futuro de Java en un futuro completable
Java 8 presentaCompletableFuture, una nueva implementación de Future que es componible (incluye un montón de métodos thenXxx). Me gustaría usar esto exclusivamente, pero muchas de las bibliotecas que quiero usar solo devuelven ...
Obtener datos de un futuro en Scala
Tengo unaFuture[List[Person]][1] y quiero obtener elList[Person] de eso. Cómo puedo hacerlo ? import scala.concurrent.Future val futPersons : Future[List[Person]] = ....
¿Escala para manejar las condiciones en las comprensiones?
Estoy tratando de crear una construcción ordenada con comprensión de la lógica empresarial basada en futuros. Aquí hay una muestra que contiene un ejemplo de trabajo basado en el manejo de excepciones: (for { // find the user by id, findUser(id) ...
Tratar con futuros fallidos
En Play Framework 2.3, una acción puede producir un resultado de una llamada futura exitosa como esta: def index = Action.async { val futureInt = scala.concurrent.Future { intensiveComputation() } futureInt.map(i => Ok("Got result: " + i)) ...
Cómo invocar un método una y otra vez hasta que devuelva un valor `Futuro` que contenga` Ninguno`
Dado un método que devuelve unFuture Me gusta esto... def remove(id: String): Future[Option[User]] = Future { // removes and returns the user identified by `id` }... cómo lo invoco una y otra vez hasta que devuelva unFuture valor que ...
¿Hay secuencial Future.find?
Tengo alguna función de efecto secundario, def f(): Future[Int] = { val n = Random.nextInt() println(s"Generated $n") Future(n) }y quiero ejecutarlo repetidamente hasta que el predicado regrese verdadero. def success(n: Int): Boolean = n % 2 == ...
¿Cómo utilizar 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()); ...
¿Son los futuros en Scala realmente funcionales?
Estoy leyendo este blogenviar [http://futurice.com/blog/an-example-of-functional-design]que afirmaFutures no son "funcionales" ya que son solo envoltorios deefecto secundario cálculos Por ejemplo, contienen llamadas RPC, solicitudes HTTP, etc. ...
fracaso en el futuro de Scala para la comprensión
Tengo tres Futuros secuenciales y los uso para la comprensión como esta val comF = for { f1 <- future1 f2 <- future2 f3 <- future3 } yield { // something } comF onSuccess { } comF onFailure { // ---------------- Here is the problem ...