Вопросы с тегом 'future'

Количество результатов: 272

1 голос
2 ответа
While Loop с фьючерсами в Scala

У меня есть два метода: def getNextJob: Future[Option[Job]] def process(job: Job): Future[Unit] Я хотел бы, чтобы обработать все, пока не осталось рабочих мест. Я...

1 голос
1 ответ
Как не правильно ждать, пока будущее будет завершена в дротиком

Существует небольшая ошибка в моем приложении сделано с флаттером, что, когда пользователь вошел в системе, он получает информацию о пользователе из моей базы данных, ...

2 голоса
1 ответ
Как добавлять задачи в цикл обработки событий Tokio, который работает в другом потоке?

я бы хотел раскрутить цикл событий Tokio вместе с сервером Rocket, а затем добавлять события в этом цикле позже. Я читаю Есть ли способ запустить Tokio :: Задержка в н...

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

У меня есть длинный список фьючерсов, которые я хотел бы работать с использованием Stream::buffer_unordered/Stream::buffered. Я совмещаю этот поток в единое будущее с ...

2 голоса
1 ответ
Является Await.ready действительно блокирует основной поток?

У меня есть кусок кода в Scala, в котором я использую Await.ready в главном блоке, а затем использовать соответствующее значение. import scala.concurrent.{Future, Awa...

0 голосов
1 ответ
C++ - вектор фьючерсов

Следующий код не компилируется: #include <iostream> #include <future> #include <vector> class Calculator { public: static int add(int a, int b)...

2 голоса
1 ответ
дротик ждут от конструктора

Какой шаблон следует использовать в данном примере, чтобы загрузить и обработать некоторые данные. Как value возвращает значение, это не приемлемо иметь d как будущее....

1 голос
1 ответ
Java ExecutorService - Задача Контрол Завершение/Строка состояния

Таким образом, у меня есть ExecutorService успешно блокирует и работает линейно прямо сейчас. Моя беда в том, что я пытаюсь добавить обновление статуса, и я не могу по...

0 голосов
0 ответов
Подождите будущий строитель, прежде чем продолжить

У меня есть будущий блок строитель, который работает и мне нужно, чтобы загрузить видео, прежде чем она продолжает снова называть саму функцию. Вы не можете увидеть с...

4 голоса
1 ответ
Невозможно использовать метод GET на моем будущем параметр, чтобы получить результат нити с вызываемым интерфейсом

Я пытаюсь построить приложение многопоточность, что можно вычислить простые числа (расчеты, проведенные в другом классе), используя методы другого класса с помощью рез...

0 голосов
2 ответа
Перемещение задачи в отдельный поток, во избежание дублирования в то время как задача запуска и надлежащее использование Executors + Future

У нас есть компонент клея между унаследованным кодом и текущим кодом. По существу все унаследованное приложение однопоточно и имеет ужасные проблемы, где пользовательс...

1 голос
1 ответ
Как вернуть данные из сокета будущего в Дарте?

Скорее всего, я отправить данные на сервер и получить данные обратно даже очень большие данные, используя приведенный ниже код между =========== линиями. Это был мой э...

8 голосов
2 ответа
Детонация - Как вернуть ошибку из будущего в дартс?

В моем флаттере приложении, у меня есть будущее, которое обрабатывает запросы HTTP и возвращает декодированные данные. Но я хочу, чтобы иметь возможность отправить соо...

0 голосов
0 ответов
используя NamedJdbctemplate с помощью сервиса палача и отзывного интерфейса

Мои шаги: Я использую namedJDBCtemplate для выбора записей из таблицы. Использование вызываемую интерфейса и Java ИСПОЛНИТЕЛЬ службы Я пытаюсь обновить и вставить в...

0 голосов
1 ответ
Торнадо фьючерсы выхода оленьей кожи правильно

Мне нужно асинхронно сделать несколько звонков HTTP внутри обработчика запроса смерча. пытаясь вернуть фьючерсы не документирован хорошо, и практически невозможно сде...

1 голос
2 ответа
Flutter.wait() для нескольких фьючерсов

Я пытаюсь поймать ошибку, когда мое устройство не имеет подключения к Интернету. Я построил из 2 будущих методов, 1 для импорта и JSON 1 заглянуть в базу данных. У мен...

0 голосов
1 ответ
Как удалить тип будущего в новом будущем API?

Ниже не компилируется #![feature(await_macro, async_await, futures_api)] use core::future::Future; async fn foo() {} trait Bar { type Output: Future<Output =...

0 голосов
1 ответ
Как исправить: "найдено: (AnyVal, AnyVal) требуется: (Double, Double)" с фьючерсами

Компиляция ошибка: [Ошибка] найдено: ((Double, Double)) => scala.concurrent.Future [(Double, Double)] [Ошибка] требуется: ((AnyVal, AnyVal)) => scala.concurr...

0 голосов
0 ответов
Протоколирование сообщений R и ошибок при использовании future.batchtools

Я использовал, чтобы иметь возможность контролировать работу на нашем Torque/PBS вычислительного кластера, глядя на лог-файлов из задания. Я (или пакет я использую), д...

0 голосов
1 ответ
Возможен обратный вызов не зарегистрировавшись для springkafka-шаблона метода отправки

Я хочу, чтобы зарегистрировать обратный вызов для будущего объекта возвращается с весны kafkatemplate.send(). ListenableFuture<SendResult<K, V>> org.sprin...

0 голосов
1 ответ
Как совместить 2 Futures в Scala

Я пишу CRUD REST API и есть проблема с объединением 2 фьючерсов на уровне услуг. Идея состоит в том, чтобы вставить Entity в дБ, а затем извлечь все генерируется БД ...

1 голос
3 ответа
Как изящно остановить поток, который работает операцию блокировки?

У меня есть блокирующий операцию работает в потоке, что мне нужно, чтобы остановить: Future serverFuture = Executors.newCachedThreadPool().submit(() -> { var s...

1 голос
3 ответа
Scala Futures: Non детерминированным выход

Я новичок в Scala и я практикую на Lib Futures, создав несколько схем повторных попыток. Это я получил следующий фрагмент кода: import scala.concurrent.{Await, Future...

0 голосов
1 ответ
Java CompletableFuture.allOf() не находит каких-либо элементов массива

Очень простой фрагмент кода, как показано ниже: String[] list = {"a", "b", "c"}; List<CompletableFuture<String>> completableFutureList = new ArrayList<...

2 голоса
0 ответов
Подражать поведение thenAllOf с CompletableFuture

у меня есть три CompletableFutures следующим образом: public Object someMethod(){ CompletableFuture future1 = CompletableFuture.allOf(futureArray1).exceptionally...

1 голос
1 ответ
Будущее против Completablefuture? для этого случая использования Completablefuture будет делать какие-либо изменения?

У меня есть четыре службы. One will give hotels which is matching to the query. One will give City which is matching to the query. One will give Airports which is mat...

0 голосов
1 ответ
Что такое concurrent.futures-эквивалент multiprocessing.Lock?

Для согласованности, я пытаюсь порта некоторые старого кода на основе multiprocessing в concurrent.futures (с помощью ProcessPoolExecutor). В моем старом коде, я с пом...

0 голосов
0 ответов
Продолжить список заселения возможно с пользовательским потоком в флаттера

Будучи новым трепетать, я увидел очень хороший пример вещательного StreamController в это видео здесь (Который потребляет изображения из URL). У меня есть следующая п...

1 голос
1 ответ
Добавление данных в peroxided ответ в Actix-сети

Я хотел бы добавить данные запроса пользователя на peroxided ответ в actix-web, но type mismatch resolving ошибка случилась. Я думаю, что речь идет о ржавчине фьючерс...

0 голосов
0 ответов
Проблема с Akka фьючерсов на CF Buildpack cflinuxfs3 с ява-buildpack.git # v4.16.1

Недавно мы обновили CF (Cloud Foundry) buildpack от cflinuxfs2 до cflinuxfs3. Это происходит с изменениями Java buildpack из Java-buildpack.git # v4.8 для Java-buildpa...

1 голос
1 ответ
SetState в будущей-функции

Я хотел бы иметь автоматическую синхронизацию для моей будущей функции. Я попробовал SetState, но он не работает должным образом. У вас есть идея? Счастливый о предлож...

0 голосов
0 ответов
Идиоматический способ преобразовать щебетать будущее [FALSE] исключительное будущее?

Я хочу, чтобы преобразовать щебетать будущее [Boolean], что является ложным исключительному будущего. Один из способов сделать это будет фильтровать, а затем передать...

0 голосов
1 ответ
Есть ли способ запустить Tokio :: Задержка в новом потоке, чтобы позволить основной цикл продолжать?

Я пытаюсь запустить функцию в конце задержки, если таймер не будет отменен. Прецедент является нажать и удерживать/двойное нажатие для ввода данных пользователя. Осно...

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

Я создаю контроллер, который говорит на службу. Контроллер (который основан на библиотеке Play AbstractController) Принимает неявный запрос и возвращает Future[Result]...

1 голос
2 ответа
Получить Seq сущностей из Акки ответа HTTP на основе JSON массива

Я пытаюсь использовать поток как клиент HTTP Акко и попал в неприятности с получением Seq объектов случая класса из массива JSON в ответ HTTP. ответ HTTP: { "bars"...

1 голос
2 ответа
Что тип с асинхронным Fn?

Я хочу иметь функцию, которая принимает указатель на функцию из async fn.Что должен тип f находиться в fn run? async fn foo() {} fn run(f: /* ??? */) {} Согласно а...

0 голосов
0 ответов
Продолжение вызова стиль, как .NET асинхронным-ОЖИДАНИЕ в C++?

Я работаю на C++ проект, в котором я должен реализовать код какой-то custom radio communication. Это, очевидно, не может блокировать основной поток в любой точке, ож...

3 голоса
2 ответа
Разница между будущим и моно

В (Java) реактивном программировании, какая разница между Future<T> и (Реактор проекта) Mono<T>? Похоже, что оба являются средством доступа к результату ас...

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

Я решил создать физический движок с помощью scala, используя параллелизм. Я знаю, что для большого числа вычислений можно распараллелить (что важно для оптимизации вещ...

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

Когда я хочу визуализировать несколько выходов, связанных с одним наблюдателем, они отображаются после того, как оба выхода рассчитаны. Если между выходами имеется дли...

1 2 3 4 5 6 7 right