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

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

0 голосов
2 ответа
Scala - Как отправить неудовлетворительную реакцию в случае исключения с использованием фьючерсов

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

4 голоса
1 ответ
Как я могу захватить RejectedExecutionException брошенного в whenCompleteAsync вызове CompletableFuture в?

Следующий пример кода я впрыскивание biconsumer который спит в течение 100 мс с как завершение действия набора completable будущего. Я использовал whenCompleteAsync ме...

3 голоса
1 ответ
Функции Dart Будущих с обратными вызовами по запросам

У меня есть проблема с пониманием функций Future в дротика и асинхронном программировании. Примеры, которые я нашел в Интернете не ответили на мой вопрос, так что я бы...

2 голоса
2 ответа
как я трансформировать HashMap [Т, будущее [Н]] в будущее [HashMap [T, N]]

Я знаю, что существует Future.sequence для преобразования List[Future[T]] к а Future[List[T]] есть ли способ, чтобы преобразовать HashMap[T,Future[N]] в Future[Has...

1 голос
0 ответов
Как «слушать» для переменной будущего постановить ИСТИНА, не прерывая блестящие приложения

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

0 голосов
2 ответа
Почему моя карта() не работает?

У меня есть служба HTTP Akka, который возвращает строку, как показано ниже: val route1: Route = { path("hello") { get{ complete{ println("...

1 голос
1 ответ
Как вернуть исключение функции действий через внутри функции?

У меня есть функция простого действия: def someActionFunc() = Action.async { request => myService.doSomething1().map { res => logger.debug(res.getMess...

5 голосов
1 ответ
Блокировка по ListenableFuture с тайм-аут

Я использую Spring 4.2.3 AsyncRestTemplate.exchange(), чтобы вызывать некоторые API, который займет несколько секунд, и я ожидал, что listenableFuture.get (1, TimeUnit...

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

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

4 голоса
0 ответов
Scala - Простые Отображения над фьючерсами и производительность

Я сделал некоторый анализ производительности для Скаля Futureс с помощью ниже фрагменты. class Container(ec: ExecutionContext) { implicit val executionContext = ec...

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

Я реализовал простой ListActivity с обычаем ArrayAdapter. Компоновка содержит ImageView и TextView. В пользовательском адаптере getView метод, который я начало будущег...

1 голос
1 ответ
Akka Ask сохраняет таймаут в реализации сортировки слияния

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

21 голос
1 ответ
Dartlang ждать более одного будущего

Я хочу сделать что-то после того, как много будущей функции сделано, но я не знаю, как писать код в дротик? код, как это: for (var d in data) { d.loadData().then() ...

0 голосов
2 ответа
Есть только один запрос веб-службы из рамок игры

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

2 голоса
1 ответ
Как разделить RDD в параллельных заданий Спарк

Есть ли способ, чтобы использовать один и тот же RDD в двух параллельных рабочих мест Спарк? Например, в следующем приложении я пытаюсь написать b на диск (работа 1),...

1 голос
1 ответ
Java будущее: получить время для каждого запроса

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

2 голоса
1 ответ
Скала шаблон согласования с асинхронным (или любой монада) охранники

Сегодня я наткнулся на следующую проблему: Я имел некоторые типы соответствие шаблона происходит, упрощено глядя, как это: object Sync { sealed trait MatchType ca...

8 голосов
1 ответ
Как вы имеете дело с фьючерсами в Акко Flow?

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

1 голос
1 ответ
Что вызывает гонки данных в станд :: асинхронной здесь?

Недавно я создал шаблон на поиск программы в игре Конвея жизни, но он бежал слишком медленно, чтобы быть практичным.Поэтому я решил распараллелить, но мне не удалось; ...

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

Идея, которую я пытаюсь выполнить следующую. У меня есть 1000 URLs для загрузки данных из использовать его для последующей обработки (например, вычисляя некоторые ст...

3 голоса
1 ответ
Преобразование ListenableFuture цепи к эквивалентной структуре RxJava

Использование Guava Listenable Фьючерс Предположим, у меня есть следующий класс: public class FooService { ListenableFuture<Foo> getFoo() { //code ...

0 голосов
1 ответ
Играть 2.5.3 - Запуск Scalatest на консоли, получая java.lang.NoClassDefFoundError: Не удалось инициализировать класс play.api.Play $

Я получаю ниже ошибки при запуске модульных тестов с использованием SBT консоли дважды или более. Я не получаю сообщение об ошибке при запуске в первый раз. Если я вый...

2 голоса
1 ответ
ржавчины фьючерсы-cpupool: непоследовательное поведение объяснение

Я испытываю странное поведение с процессорные бассейны: #[macro_use] extern crate lazy_static; extern crate tokio_core; extern crate futures; extern crate futures_cpu...

5 голосов
1 ответ
Есть ли станд :: будущего спин-ждать?

Прежде чем объяснить этот вопрос более подробно, отмечу, что ответ, очевидно, зависит от реализации, поэтому я в первую очередь спрашивают о libstdc ++, но я бы также ...

9 голосов
1 ответ
Каков наилучший подход к инкапсуляции блокировки ввода/вывода в будущем-рс?

Я прочитал tokio документация и мне интересно, что это лучший подход для инкапсулирования дорогостоящего синхронного ввода/вывода в будущем. С рамками реактора, мы по...

1 голос
1 ответ
Создание фьючерсов без ExecutorService или FutureTask

Я использую JerseyClient сделать асинхронные вызовы на сервер HTTP, и я непосредственно создание Фьючерса для хранения ответа. Они даже могут быть пакетными вызовами в...

2 голоса
2 ответа
Rx Java Наблюдаемые не выполнить до некоторого условия

Я пытаюсь найти способ выполнить наблюдаемые до некоторого условие не выполнено. Рассмотрим следующий пример: myDelayedObservable = createListenerObserver(); pu...

0 голосов
2 ответа
как получить результат будущего без использования «ждать»

Я хочу, чтобы получить результат будущего без блокировки операций. Если я пишу свой код с «ждать», он работает, но это не хорошо для меня, потому что это блокирование:...

3 голоса
1 ответ
Как отправить список предметов через фьючерсный :: Sink?

У меня есть список пунктов, чтобы отправить через фьючерсы ::Sink: let mut list = VecDeque::new(); /* add a bunch of Packet items to list */ let (sink, stream) = tcp_...

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

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

1 голос
1 ответ
фьючерсные-RS с помощью комбинатора потока на `BoxStream`s

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

3 голоса
3 ответа
Java Будущее всегда возвращается нулем

Эй, я получил быстрый вопрос о Java Futures. Я сломалась проблему в этом фрагменте кода: ExecutorService service = Executors.newCachedThreadPool(); try { ...

0 голосов
1 ответ
Как вернуть значение, но продолжить цикл?

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

2 голоса
2 ответа
Скала: Как собрать результат списка фьючерсов, когда некоторые из них тайм-аут?

Моя практика в этой ситуации заключается в использовании .sequence превратить F[G[A]] к G[F[A]]. Затем используйте Await.result(future_of_a_list, time_out) чтобы получ...

2 голоса
1 ответ
ExecutorService будущего :: получает очень медленно

Я распараллеливание довольно сложная программы, чтобы получить его быстрее. Для этого я использую большую часть времени в ExecutorService. До сих пор он работал очень ...

0 голосов
0 ответов
Будущее задание просто исчезает

Я сталкиваюсь с довольно странной ситуацией при использовании std::future а также ThreadPool, хотя я не думаю, что это ThreadPool (Я использую https://github.com/bandi...

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

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

5 голосов
3 ответа
Вызов блестящего JavaScript Callback из будущего

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

0 голосов
1 ответ
Как значения передаются между потоками в фьючерсах Scala

Как Num доступ к новой теме. Будущее будет исполнено в новом потоке. как значение num, которое находится в кадре стека основного потока, доступно в новом потоке? Где э...

2 голоса
1 ответ
Методы foreachPartitionAsync не могут вызывать методы при остановленном SparkContext

У меня есть 2 файла с разными данными. Я пытаюсь прочитать их в двух RDD & затем преобразовать их в Dataframe & вставить в улей. Я смог сделать этот нормальный...

0 голосов
1 ответ
Торнадо: распакуйте много слоев будущего

В торнадо 4.3 + python3, если у меня много слоев асинхронной функции, например: @gen.coroutine def layer_2(): return(yield async_func()) @gen.coroutine def laye...

6 голосов
2 ответа
Vert.x java List < Futures > параметризация

Я столкнулся со странной проблемой с фьючерсами Vert.x на днях, которая не нарушает код, но все еще беспокоит меня. Будущее без параметра приводит к следующему предуп...

0 голосов
1 ответ
Как Будущее автоматически преобразуется в Наблюдаемое?

Код здесь: https://github.com/ReactiveX/RxPY/blob/master/examples/autocomplete/autocomplete_asyncio.py#L63 searcher = query.flat_map_latest(search_wikipedia) def se...

0 голосов
1 ответ
Как использовать возвращаемое значение из функции, возвращающей будущего (или [A, B]) в Скале?

У меня есть ниже функции. def get(id: Int): Future[Either[String, Item]] = { request(RequestBuilding.Get(s"/log/$id")).flatMap { response => response.sta...

3 голоса
4 ответа
играть - как обернуть код блокировки с фьючерсами

Я пытаюсь понять разницу между 2 методами, с точки зрения функциональности. class MyService (blockService: BlockService){ def doSomething1(): Future[Boolean] = { ...

6 голосов
1 ответ
Что не является блокировка и блокировка будущего в Scala?

Я использую рамку игры, я прочитал, что игра ручку каждый запрос в не блокирующем пути. Так что разница между блокировкой и без блокировки будущего в Scala? Кроме тог...

1 голос
4 ответа
Могу ли я использовать Action.async с несколькими фьючерсами?

В предыдущий SO вопрос, Я получил советы по использованию Scala Futures с Play Framework, спасибо. Теперь все стало немного сложнее. Допустим, что, прежде чем я только...

2 голоса
1 ответ
Будущее и бесконечный цикл в Scala

Я хочу, чтобы выполнить 2 независимых бесконечные циклы в Скале. Первая задача занимает около 1 секунды для каждого прогона, а второй занимает 0,5 секунды. Вот код: ...

1 голос
1 ответ
NHibernate - где .. в .. и будущее

У меня есть две модели: Thing и ThingStatus. Вещь имеет идентификатор и некоторые другие поля. ThingStatus представляет собой модель, которая хранит перечисление состо...

1 голос
2 ответа
Превратить будущее [Unit] в Try [Unit] в Scala

Я пытаюсь реализовать метод API (AsyncWriteJournal.asyncWriteMessages - часть Akka 2.4 по Persistence API), что требует от меня, чтобы возвращать Future[Seq[Try[Unit]]...

left 1 2 3 4 5 6 7 8 9 right