future

4зной

2ответ

Как выполнять зависимые задачи в Java 8 без блокировки

Не так давно я ответил на этот вопрос: Executing Dependent tasks in parallel in Java Но использование future.get() блокирует текущий поток, и есть вероятность, что пул потоков заканчивается из потоков

5зной

3ответ

Scala для понимания с будущим и опциями

object Main extends App { val p1 = Promise[Option[String]]() val p2 = Promise[Option[String]]() val f1 = p1.future val f2 = p2.future val res = (for{ file1Opt <- f1

1зной

1ответ

Упаковочный Scala API через Java API

Я новичок в Scala, и я строю обертку Scala для моего Java API Я четыре Java Интерфейсы public interface Client<T> { <T> Handle<T> execute(App<T> app); } public interface App<T> extends Serializabl

2зной

1ответ

Фьючерсы и обратные вызовы для изменения значения переменной

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

1зной

1ответ

Управляется Блокировка необходима для вложенных фьючерсов Scala?

Для моего fork-join-pool (по умолчанию глобальный), чтобы иметь возможность выделять новые потоки, если у меня есть вложенные фьючерсы, мне нужно обернуть все отдельные фьючерсы блокировкой {...}, есл

0зной

2ответ

ThreadPoolExecutor проверяет, находится ли определенная задача в очереди

У меня есть последовательное соединение, которое должно использоваться только одним потоком. Но прежде чем я отправлю новую задачу исполнителям, я хочу проверить, действительно ли эта определенная зад

3зной

1ответ

Play 2.5.x (Scala) - Как установить значение, полученное через wsClient, в (ленивый) val

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