Результаты поиска по запросу "future"
Фьючерс / Успех гонки
Я изучаю фьючерсы, и я пытаюсь создать метод, который принимает два фьючерса в качестве параметра (f а такжеg) и вернуть первое будущее, которое было успешно завершено, в противном случае оно возвращаетсяf или жеg. Вот некоторые примеры ...
Жду будущего, получай либо
Я хотел бы дождаться будущего скалы, которое, возможно, провалилось. Если я используюAwait.result исключение будет брошено. Вместо этого, если у меня естьf: Future[String] Я хотел бы методAwait.resultOpt(f): Option[String] ...
Что делает Future.cancel (), если не прерывает?
ИзДокументы Java на Future.cancel () [http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/Future.html#cancel%28boolean%29] boolean cancel(boolean mayInterruptIfRunning)Попытки отменить выполнение этого задания. Эта попытка потерпит ...
Невозможно использовать для понимания, чтобы отобразить список в будущем
У меня есть проблема, с которой мне приходится обходиться каждый раз. Я могу'не наносить на карту то, что содержится в будущем, используя для понимания.П...
Как отменить Future in Scala?
Ява Будущее имеет
Отмена с будущим и обещанием в Scala
Это продолжение кмой предыдущий вопросПредположим, у меня есть задача, которая выполняетпрерываемой блокировка вызова. Я хотел бы запустить его как
неудача в будущем Scala для понимания
У меня есть три последовательных фьючерса и использовать для понимания, как это
Spark работа с асинхронным HTTP-вызовом
Я строю RDD из списка URL-адресов, а затем пытаюсь получить данные с помощью асинхронного http-вызова. Мне нужны все результаты, прежде чем делать другие рас...
future.isDone возвращает false, даже если задача выполнена
У меня сложная ситуацияfuture.isDone() возвращаетсяfalse, даже если поток завершен. import java.util.ArrayList; import java.util.LinkedList; import java.util.List; import java.util.concurrent.ArrayBlockingQueue; ...
Утилита Future.cancel (логический) метод
Я просто изучал пакет java.util.concurrent. Я узнал, что классБудущееесть методлогическое отмена (логическое mayInterruptIfRunning) Пожалуйста, найдите прикрепленный тестовый код, который я написал: package com.java.util.concurrent; import ...