6
ответов

Что такое фьючерсы?

Что такое фьючерсы? Это - что-то, чтобы сделать с отложенными вычислениями.
вопрос задан: 7 August 2012 12:07
5
ответов

Измените Seq [Future [Boolean]] в будущее [Seq [Boolean]] [duplicate]

У меня есть рабочее решение, но я просто хотел спросить, есть ли лучший способ сделать это. В принципе, я столкнулся с последовательностью Будущего, каждый из которых держит один объект с булевым как единственный ...
вопрос задан: 2 January 2014 01:01
5
ответов

Clojure изменяемые типы хранения

Я пытаюсь узнать о Clojure из API и документации, доступной на сайте. Я немного неясен об изменяемом устройстве хранения данных в Clojure, и я хочу удостовериться, что мое понимание корректно. Позвольте...
вопрос задан: 24 June 2009 16:16
3
ответа

В том, какие случаи делают Future.get () бросают ExecutionException или InterruptedException

Мой фрагмент кода: исполнитель ExecutorService = Executors.newSingleThreadExecutor (); попробуйте {Задачу t = новая Задача (ответ, inputToPass, pTypes, unit.getInstance (), methodName, unit.getUnitKey ()); Future&...
вопрос задан: 5 July 2016 14:39
3
ответа

Поток Java - странный Thread.interrupted () и future.cancel (истинное) поведение

Я хочу управлять списком объектов фьючерсов, возвращенных моим TaskExecutor. У меня есть что-то вроде этого Список <будущее <Строка>> список пустой процесс (ProcessThis processThis) {для (...) {...
вопрос задан: 8 November 2011 04:26
3
ответа

Фьючерсы в Haskell

Имеет ли Haskell эквивалент способности Алисы связывать переменную с будущим? val a = порождение foo; где foo - некоторая функция Я знаю, что Haskell поддерживает каналы и потоки; Я надеюсь на синтаксис ...
вопрос задан: 22 April 2011 18:26
3
ответа

java.util.concurrent. Future.get () не возврат

У меня есть следующий код Java: заключительное будущее будущее = exeService.submit (новый Выполнимый () {общественность освобождают выполненный () {myObject.doSomething (); }}); future.get (); где...
вопрос задан: 6 April 2010 15:26
2
ответа

Получить Seq сущностей из ответа akka http на основе массива json

Я пытаюсь использовать Flow как http-клиент Akka, и у меня возникли проблемы с получением Seq объектов класса case из массива json в ответе http. HTTP-ответ: {"bars": [], "foos": [{"id": ...
вопрос задан: 20 January 2019 16:23
2
ответа

Какой тип асинхронного FN?

Я хочу иметь функцию, которая принимает указатель на функцию async fn. Какой тип f должен быть в fn run? async fn foo () {} fn run (f: / * ??? * /) {} В соответствии с асинхронным / ожидающим RFC: асинхронный ...
вопрос задан: 20 January 2019 03:06
2
ответа

Разница между будущим и моно

В реактивном программировании (Java) чем отличается Future < T > и (Project Reactor) Mono < T & gt ;? Оба, кажется, средства для доступа к результату асинхронного вычисления в ...
вопрос задан: 17 January 2019 15:51
2
ответа

Не вызывает ли проблема Future.get какие-либо проблемы?

Я выполняю определенный поток, в котором я отправляю некоторую задачу в Callable и сохраняю вывод в Future & lt; gt; будущее. В некоторых случаях я не звоню в future.get (), чтобы получить значение, и я не ...
вопрос задан: 13 July 2018 11:09
2
ответа

Не удалось вывести параметр шаблона '_Fn' [duplicate]

Учитывая следующее MWE использования класса модуля, предназначенное для того, чтобы предлагать фьючерсную «перезагрузку» принадлежащего std :: unique_ptr content #include & lt; future & gt; #include & lt; memory & gt; #include & lt; string & gt; / ** .
вопрос задан: 12 September 2014 19:52
2
ответа

Понимание будущего/поточной обработки

Я пытаюсь использовать фьючерсы впервые. Это кажется умным, что можно отменить задание, но это не работает как ожидалось. В примере ниже, только отменяется первое задание. Остальные...
вопрос задан: 13 December 2013 01:43
2
ответа

Многопоточное Приложение Java - как динамично отменить объекты фьючерсов

Я думаю, что это - общий сценарий для многопоточных JAVA-приложений, таким образом, я попытаюсь описать его здесь. В моем Приложении Java у меня есть объект threadExecutor, который определяет Пул 5 Потоков. ExecutorService...
вопрос задан: 26 March 2010 15:05
2
ответа

способность получить достижения по будущему <T> объект

Со ссылкой на java.util.concurrent пакет и будущий интерфейс я замечаю (если я не ошибаюсь), что способность запустить длинные задачи и быть в состоянии запросить на прогрессе только прибывает...
вопрос задан: 16 February 2010 19:47
1
ответ

Невозможно прочитать простую полезную нагрузку, создающую HTTP-запрос через hyper :: client :: Client: ограничение черты `Body: Future` не выполнено

Я пытаюсь преобразовать результат в буфер: let ufc_root: String = String :: from ("https://www.ufc.com/athletes/all?filters%5B0%5D=status%3A23"); // let ufc_root: String = String :: from ("https: / ...
вопрос задан: 19 March 2019 13:15
1
ответ

Сопрограммы C ++ 20: реализация ожидаемого будущего

Поскольку Coroutines TS был принят в C ++ 20 на совещании ISO в Kona, я начал немного подыгрывать им. Clang уже имеет достойную поддержку сопрограмм, но ...
вопрос задан: 10 March 2019 14:43
1
ответ

Получение результата метода Future < T > флаттер

У меня есть метод Future < FirebaseUser > getCurrentUser () async {FirebaseUser user = await _firebaseAuth.currentUser (); возвратный пользователь; } Я хочу иметь возможность вызывать его в каком-то другом модуле ...
вопрос задан: 7 March 2019 01:46
1
ответ

Как я могу получить это для понимания, чтобы вернуться?

Я создаю контроллер, который общается с сервисом. Контроллер (основанный на библиотеке Play AbstractController) принимает неявный запрос и возвращает Future [Result]. Служба получает ...
вопрос задан: 20 January 2019 06:36
1
ответ

Shiny - Рендеринг нескольких выходов параллельно

Когда я хочу визуализировать несколько выходов, связанных с одним наблюдателем, они отображаются после того, как оба выхода рассчитаны. Если между выходами есть длительный расчет, потребуется много времени, прежде чем ...
вопрос задан: 16 January 2019 08:32
1
ответ

Как часто мы должны использовать фьючерсов и актеров? Есть альтернативы? [закрыто]

Я решил создать физический движок с помощью scala, используя параллелизм. Я знаю, что для большого числа вычислений можно распараллелить (что важно для оптимизации вещей). Однако я знаю ...
вопрос задан: 16 January 2019 07:58
1
ответ

Передать несколько параметров в concurrent.futures.Executor.map?

Concurrent.futures.Executor.map принимает переменное количество итераций, из которых вызывается данная функция. Как мне его назвать, если у меня есть генератор, который производит кортежи, которые обычно ...
вопрос задан: 8 April 2018 17:37
1
ответ

Вариант использования для Future.cancel (ложь)?

В какой ситуации можно было бы хотеть передать ложь для mayInterruptIfRunning параметра к Future.cancel ()? Если я понимаю правильно, если Вы передаете ложь, и задача отменяется, но поток не...
вопрос задан: 11 November 2011 05:02
1
ответ

Можно ли использовать объекты Future/Futuretask с Spring TaskExecutors?

Действительно ли возможно использовать Java FutureTask с Spring TaskExecutor для получения будущего объекта? Я ищу TaskExecutor, который реализует интерфейс Java ExecutorService, в особенности отправление ()...
вопрос задан: 8 November 2011 04:28
1
ответ

Что происходит, когда Scala “будущее” собран "мусор"?

Скажите, что у меня есть Поток, который это довольно дорого для вычислений. Я могу легко создать поток, который "вычисляет вперед" только путем записи чего-то как импорт scala.actors. Фьючерсы._ val s = будущее {stream.size}...
вопрос задан: 8 November 2011 04:24
0
ответов

Python concurrent.futures Ошибка BrokenProcessPool, возникающая из UMAP fit_transform в рекурсивной функции

Я пытаюсь распараллелить рекурсивную программу, которая использует UMAP fit_transform на каждом рекурсивном шаге, используя concurrent.futures. Программа по существу применяет UMAP fit_transform к пандам ...
вопрос задан: 25 June 2019 19:31
0
ответов

Вызов метода на дату / время

Я ищу современный способ выполнения данного метода в заданную дату / время (в частности, ZonedDateTime). Мне известны класс Timer и библиотека Quartz, как показано здесь (темы включают в себя ...
вопрос задан: 6 March 2019 09:04
0
ответов

Асинхронный HTTP-клиент Boost Beast + std :: future

У меня есть проект, который будет заниматься сетью и хотел бы обернуть базовую реализацию запросов Boost Beast HTTP (S) внутри фьючерсов. Я скопировал сессионный класс с https: //www.boost.org/doc / ...
вопрос задан: 4 March 2019 19:52
0
ответов

Продолжение вызова стиля, как .NET async-await в C ++?

Я работаю над проектом C ++, где я должен реализовать код для некоторой пользовательской радиосвязи. Это, очевидно, не может заблокировать основной поток в любой точке, ожидая join (), Future.get () и т. Д., ...
вопрос задан: 17 January 2019 20:36
0
ответов

Фьючерсы не запускаются до завершения программы

Я пытался воспроизвести пример с новой функцией фьючерсов Scala 2.10. Код, который я использовал: import scala.concurrent.Future import scala.concurrent.future object Test { def main(args: Array[...
вопрос задан: 9 November 2018 23:50