future

0зной

1ответ

Scala Будущее блокировании с несколькими Await.result() вызывает

Я не понимаю, почему этот пример, взятый из here, блокирует import java.util.concurrent.Executors import scala.concurrent._ import scala.concurrent.duration.Duration object Main { def main(ar

0зной

1ответ

Akka-Java бросает DeadLetterException на ask-await

У меня есть драйвер/основной класс в таком файле. (В основном я пытаюсь смешивать STORM & AKKA). В классе TenderEventSpout2 я пытаюсь отправить и получить сообщение/от актера. public class TenderEvent

2зной

1ответ

Использование фьючерсов в Scala?

Я пытаюсь включить базу данных в свой http-микросервис. Микросервис имеет функцию getValueFromInternet(val: Foo): Future[Value], которую вызывал мой микросервис по запросу GET. Теперь я хочу, чтобы эт

2зной

2ответ

Как предсказать местоположение объекта в ближайшем будущем?

Предположим, что каждый объект (автомобиль, велосипед и т. Д.) Подключен к Интернету и дает мне (Облако) только его текущее положение и его случайный идентификатор, который меняет каждую «Т» сек. Поск

1зной

1ответ

Обработка исключений, когда сцепление Futures в гуавах

Что касается обработки исключений в следующем коде: ListenableFuture<BufferedImage> imgFuture = downloadExecutor .submit(new Downloader(url)); ListenableFuture<BufferedImage> resizeFut

0зной

1ответ

Как получить контент от будущего объекта торнадо

Я действительно смущен работой рамы торнадо и «будущим» объектом. Поэтому я хочу, чтобы получить ответ асинхронной делая HTTP вызов кода является: class TestAsyncHttp(object): def __init__(self):

0зной

2ответ

Будущее <Boolean> - null?

следующая моя проблема: Я написал метод кэширования некоторых результатов sql-запроса и реализацию метода hasnext() из Iterator. public Future<Boolean> cache(){ return CSCore.dbManager.sqlprocess