Описание тега future

Описание тега Вопросы с тегом
Заполнитель для результата расчета до его завершения. Используется в параллельном программировании. Вопросы о будущих событиях не по теме в stackru.
1 ответ

Как бороться с java.net.SocketException: слишком много открытых файлов при отправке / перезагрузке?

У меня есть метод, который принимает URL-адрес и возвращает обещание [Материал]: def getStuff(url: String): Promise[Stuff] = Http(...).map(...) и я называю это большим (~ 1300 наименований) списком строк: Http.promise.all(urls.map(getStuff)).apply Н…
16 фев '13 в 18:00
2 ответа

Работа с несколькими Scala Futures

У меня больше одного Future, val actor1 : Future[ActorRef] = createActorA() val actor2 : Future[ActorRef] = createActorB() ... ... ... Теперь мне нужно извлечь ActorRefиз всех этих фьючерсов, чтобы я мог использовать их для создания Router, val rout…
17 июл '14 в 21:04
2 ответа

Бегущее будущее n раз

Я хотел бы выполнить мой будущий вызов n раз, например 5. Будущее "выполнение" займет некоторое время, и я хочу вызывать новый только тогда, когда предыдущий был завершен. Что-то вроде: def fun(times: Int): Future[AnyRef] = { def _fun(times: Int) = …
08 окт '13 в 13:22
1 ответ

Scala для понимания результата работы с картой прибывает как Int

Пожалуйста, посмотрите на приведенный ниже код, ` val d= for{ t <- db.getSomething() ids <- t.map(_.id).toSeq histo <- fetchOtherRelatedDetails(ids) } yield histo ` Здесь db.getSomething возвращает Future[Seq[SomeObject]], поэтому я пытаюсь…
09 май '18 в 15:49
1 ответ

Почему `Future::poll` не вызывается повторно после возврата`NotReady`?

Рассмотрим следующий код extern crate futures; use std::sync::{atomic, Arc}; use futures::*; struct F(Arc<atomic::AtomicBool>); impl Future for F { type Item = (); type Error = (); fn poll(&mut self) -> Result<Async<Self::Item>…
19 апр '17 в 18:56
1 ответ

Скала Фьючерсы и Многопоточность

Я новичок в Scala и пытаюсь разобраться с фьючерсами и многопоточностью У меня есть однопоточная версия программы, которая делает некоторые вычисления на матрице SingleThreadCalc { def run(matrix : Seq[Seq[Double]]) : Future[Seq[Seq[Double]] = Futur…
15 июн '17 в 15:48
1 ответ

Сообщения и коды ошибок Flutter/Dart & Firebase

Я внедряю Firebase Auth в мое приложение Flutter. Как получить доступ к кодам ошибок или дружественным сообщениям об ошибках из Firebase? Это уже доступно? Например, на iOS вы можете получить localisedDescription от ошибки. В дартсе у меня есть onEr…
18 июн '18 в 15:30
3 ответа

Как я могу знать, как задача завершилась при использовании класса Future Java

Я использую Java-класс Future для выполнения задачи, но метод isDone возвращает true, если задача выполнена. Завершение может быть связано с обычным завершением, исключением или отменой - во всех этих случаях этот метод вернет true. Есть ли способ у…
12 июл '11 в 16:54
0 ответов

scala DynamicVariable и play.api.libs.concurrent.Execution.Implicits.defaultContext

Я пытаюсь использовать DynamicVariable с платформой Scala Play 2.5 для распространения контекста на запрос. Пока что мой DynamicVariable прекрасно работает в потоке запросов, но не копируется при использовании Future и play.api.libs.concurrent.Execu…
22 апр '16 в 19:18
1 ответ

Будущее - не удалось остановить поток

Я использую следующий код (схема): ExecutorService executor = Executors.newFixedThreadPool(20); List<Future<statusModel>> futures = new ArrayList<Future<statusModel>>(); for (Map.Entry<String, String> url : urls.entrySe…
20 авг '13 в 13:49
2 ответа

Могу ли я остановить обещание Play Framework?

Есть ли рекомендуемый способ остановить обещание Play Framework? Например, import play.api.libs.concurrent.Promise val timeoutFuture = Promise.timeout({ Logger.info("timeout expired.") }, myTimeoutValue) Что было бы хорошим способом отменить это буд…
30 июл '14 в 09:58
0 ответов

C++ Future with Arguments Error

Ниже приведен код, который я использую для запуска packaged_task. Однако, когда я пытаюсь скомпилировать, я получаю сообщение об ошибке: 'std::function<_Ret(CStore &, FileDetails &)>::function(std::function<_Ret(CStore &, FileDe…
23 апр '16 в 15:15
1 ответ

Секвенирование `Будущее с таймаутом

Я использовал TimeoutScheduler представлен на Scala Futures - встроенный тайм-аут?, Тем не менее, теперь моя программа не заканчивается, как раньше без TimeoutScheduler, У меня два Futures: res1 а также res2, Оба с таймаутом 15 секунд. В конце я чер…
24 фев '14 в 09:11
2 ответа

Будущее в обратном вызове запускается в том же потоке

Когда я запускаю этот код: val intList = List(1, 6, 8) val listOfFutures = intList.map{ i => future { println("future " +i) Thread.sleep(i* 1000) if (i == 12) throw new Exception("6 is not legal.") i } } val futureOfList = Future.sequence(listOfF…
24 ноя '13 в 12:11
1 ответ

akka getSender() потерян в будущем

У меня проблема в akka (java) со ссылкой на отправителя, которая исчезает через некоторое время в будущем. Вот код: class MyActor extends UntypedActor { @Override public void onReceive(Object msg){ Future<Integer> future = Futures.future(new C…
10 авг '12 в 08:20
1 ответ

Scala: как посчитать, сколько раз удалась будущая пара

В следующем фрагменте кода вызывается getAmounts получить некоторые суммы, сгруппированные по валюте, а затем вызывает getRates применить соответствующий обменный курс: def getAmounts = Future(Map("EUR" -> 500d, "USD" -> 400d)) def getRates = …
07 май '15 в 14:04
1 ответ

Будущее Java и бесконечные вычисления

Я пытаюсь оптимизировать (бесконечный) алгоритм вычислений. У меня есть infinte Sum для вычисления ( Summ_{n-> infinity} (....)). Моя идея состояла в том, чтобы создать несколько потоков, используя конструкцию Future < >, а затем объединить промежут…
26 мар '10 в 10:07
1 ответ

Получаемые в будущем наблюдаемые обратные вызовы Scala не вызывают

Используя scala 2.11.7, rxscala_2.11 0.25.0, rxjava 1.0.16, мой oddFutures обратные вызовы не вызывают AsyncDisjointedChunkMultiprocessing.process(): package jj.async import scala.concurrent.Future import scala.concurrent.ExecutionContext import rx.…
15 ноя '15 в 04:16
1 ответ

Использование C++11 будущего: вложенные вызовы std::async crash: ошибка компилятора / стандартной библиотеки?

После возникновения сбоев при введении вложенных вызовов std::async в моей реальной программе я смог воспроизвести проблему в следующем минимальном примере. Вылетает часто, но не всегда. Вы видите что-то, что идет не так, или это ошибка компилятора …
19 фев '15 в 10:52
1 ответ

Использование Future[JsValue] в последующей функции Play framework 2.6x

Я новичок в фреймворке (2.6.x) и Scala. У меня есть функция, которая возвращает будущее [JsValue]. Как я могу использовать Future[JsValue] в последующей функции? def getInfo(): Future[JsValue] ={} Следующая функция будет использовать значение из JsV…
15 сен '17 в 04:04