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

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

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 голос
1 ответ
Соответствие будущим типам

Я пытаюсь работать с фьючерсами, чтобы искать асинхронно искать значение. Если это значение существует, я хочу его вернуть, а если его нет, я хочу его создать. // A n...

0 голосов
1 ответ
Оберните и выполните упакованную_таску внутри лямбды

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

0 голосов
1 ответ
Будет ли выполнение потока продолжаться при ожидании Future одного потока

Я хочу знать, что когда программа ожидает объект Future одного потока, другие потоки продолжат свое выполнение. Я пробовал приведенный ниже пример, кажется, когда моя...

0 голосов
1 ответ
Игнорирование неиспользованных фьючерсов с ThreadPoolExecutor

Я запускаю две функции, fast() а также slow(), параллельно используя ThreadPoolExecutor. Если fast() возвращает неNone результат, я хотел бы использовать его, в против...

1 голос
2 ответа
Как запланировать повторяющуюся задачу в Токио?

Я замена синхронного сокета кода, написанный на Русте с асинхронным эквивалентом с использованием Tokio. Tokio использует фьючерсы на асинхронную активность, так задач...

0 голосов
1 ответ
Простая программа с отзывным Будущим никогда не заканчивается

Я играл вокруг с отзывным и будущим и наткнулся на вопрос. Это кусок кода, который никогда не заканчивается и время ожидания, даже если IDE позволяет 5 секунд для зап...

4 голоса
3 ответа
Как отменить бесконечный поток внутри самого потока?

Я стараюсь, чтобы отменить интервал (interval_timer) После опорожнения очереди, но не уверен, что это правильная стратегия. let mut some_vars = vec![1, 2, 3, 4, 5, 6,...

0 голосов
2 ответа
Scala хвостовой рекурсия возвращается на будущей

как реализовать хвостовую рекурсию функцию в Скале с фьючерсами в качестве возвращаемого значения: Пример кода def getInfo(lists: List[Int]): Future[List[Int]] = { ...

0 голосов
1 ответ
Будущее Vert.x получает нулевое значение, поскольку обработчик вызывается перед будущим комплетного

Я пытаюсь понять основы Vert.x и у меня есть задача создать HTTP-сервер, который будет выполнять простые математические вычисления и клиент, который будет отправлять н...

0 голосов
2 ответа
FutureCallback никогда не выполняется

Я пытаюсь получить FutureCallbacks из Гуавы работы, потому что я хочу, чтобы использовать его в моем Java API для CloudFlare. Класс испытаний: import com.google.comm...

0 голосов
1 ответ
Если «требуется» идти внутри или вне будущего?

Как заменить мой первые условный с require функция в контексте будущего? Должен ли я обернуть весь метод InRange в будущем, и если я сделаю это, как я могу справиться ...

1 голос
2 ответа
Почему нет станд :: будущее :: try_wait()?

Учитывая, что есть std::future::wait_for/until(), Я не понимаю, почему нет std::future::try_wait(). В настоящее время я пишу пример производитель-потребитель, и я хочу...

0 голосов
1 ответ
Нетти клиент запрашивает таймаут при отправке на несколько серверов

Во-первых, я объясню фон:Я реализовал Netty Framework и имеющий один клиент отправляет запрос HTTP на более чем 44 серверов. Серверы реагируют на эту просьбу.На мой кл...

0 голосов
1 ответ
Используя будущее C++ в качестве промежуточного значения в стеке результатов функции в Segfault

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

1 голос
1 ответ
Scala - Future.sequence кортежей

У меня есть Seq кортежей: val seqTuple: Seq[(String, Future[String])] = Seq(("A", Future("X")), ("B", Future("Y"))) и я хочу, чтобы получить: val futureSeqTuple: F...

0 голосов
1 ответ
Параллельная Модификация исключения в отзывном классе

Я пытаюсь разделить список объектов в меньших подсписка и обрабатывать их по отдельности в разных потоках. Поэтому у меня есть следующий код: List<Instance...

4 голоса
2 ответа
Как вернуть результаты, отличные от фьючерсов в Scala, не прекращая в вложенных если заявлениях

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

2 голоса
1 ответ
Может ли ListenableFuture цепь обрабатывать внутреннюю ExecutionException?

Я снабжен апи (fnGrpc), который выполняет КПГРЫ вызова и возвращает ListenableFuture который разрешает до некоторого значения V (реализация которого является фиксирова...

0 голосов
1 ответ
Почему это выход приложения Akka Streams ненормально?

Я учусь о Akka Streams через модуль Akka Cookbook из Packt. Я бегу TransformingStreamsApplication.scala пример и получить это: Для того, чтобы выход системы актера,...

4 голоса
1 ответ
Реализация реального «ForAll» в списке SCALA фьючерсов

Я использую SCALA (2.12) фьючерсы применять параллельную разделяй и властвуй подход к сложной проблеме. Вот некоторые (упрощенный) контекст: def solve(list: List[Int]...

0 голосов
1 ответ
Concurrent.blocking в будущем не работает, как ожидается, в каком-то сценарии

Помощь объяснить 2 явление для будущего (лестницы Жирного в code4 & code5), спасибо. Code1 package com.tst import akka.actor.{Actor, ActorSystem, Props} import scala...

0 голосов
1 ответ
Переоборудование 2 с Java 7 будущего

Есть ли способ использовать переоснащение 2 с Java 7 фьючерсов (не ява 8 completablefutures)? Что-то вдоль линий interface MyService { GET("somepath") Future&lt...

2 голоса
2 ответа
«Спекулятивная исполнение» Скала Futures

Я хотел бы сделать что-то вроде создания двух фьючерсов, использования в зависимости от того возвращает первый в одном пути коды и отправить «медленное» Будущее вниз д...

-1 голос
1 ответ
Tokio эхо сервер. Не могу читать и писать в то же время

Я пытаюсь построить эхо-сервер в Токио. Я видел примеры, но все они, кажется, используют io::copy от Tokio IO, которые я не могу использовать, потому что я хочу, чтобы...

0 голосов
2 ответа
Будущее Scala для выполнения последовательных рабочих мест

Я пытаюсь запустить три задания последовательно, но когда я пытаюсь этот код: val jobs = Seq("stream.Job1","stream.Job2","stream.Job3") Future.sequence { ...

2 голоса
2 ответа
Как проверить, если никто не существует в списке Будущего [Option]

Скажем, у нас есть: val listOfYetToBeMaybePeople = List[Future[Option[Person]]] Есть ли неблокирующий способ получить Future[Boolean] из true тогда и только тогда в...

2 голоса
2 ответа
Почему добавление импорта `импорт cats.instances.future._` приведет к ошибке компиляции для неявного функтора [Future]

Код Scala использует кошка и хорошо работает: import cats.implicits._ import cats.Functor import scala.concurrent.ExecutionContext.Implicits.global import scala.concu...

1 голос
1 ответ
Scala будущий аварийный метод осветления

После просмотра этого заявления на Scala будущее fallback метод, который я пытался permutate success а также failure значения переменных. Я не в состоянии следовать за...

1 голос
2 ответа
Объединить список фьючерсов на карту в Scala

У меня есть два класса регистра P(id: String, ...) а также Q(id: String, ...), и две функции, возвращающие фьючерсы: Один, который возвращает список объектов данных ...

3 голоса
1 ответ
Как получить доступ к данным внутри Gathering Future законченного результата

Пытаюсь выяснить, как я могу получить доступ к своим данным после того, как я вернуть его. Это образец х, если я распечатать его: <_GatheringFuture finished result...

3 голоса
1 ответ
Нарушает ли Нетти договор (...) метод Future.cancel?

Согласно договору от метода java.util.concurrent.Future#cancel : После того, как этот метод возвращает последующие вызовы IsDone будет всегда   возвращает истину. ...

0 голосов
0 ответов
Хорошая практика ручка InterruptedException в JEE

У меня есть приложение JEE, который использует TimerService для запуска каждые 3 минуты. Каждый запустить вычисление может длиться максимум 1min30s. В довершение к ма...

3 голоса
2 ответа
Это неправильно использовать будущее Java для бесконечной работы?

Мне нужно реализовать бесконечную работу в программе Clojure. Я надеюсь, что синтаксис достаточно ясно для Java программистов тоже: (defn- my-operation (future ...

4 голоса
1 ответ
Почему будущее :: выбрать выбрать будущее с более длительным периодом сна в первую очередь?

Я пытаюсь понять, Future::select: В этом примере, будущее с более длительным временем задержки возвращается первым. Когда я читаю эта статья с его примером, я получаю...

left 1 2 3 4 5 6 7 8 9 right