Как использовать CompletableFuture / Java

ReSQL.ru

Мобильная версия Контакт Правила FAQ Помощь

Гость

Войти | Регистрация | Профиль | Очистить

Новые сообщения | Избранное

Форумы | Пользователи | Статистика | Мод. лог | Поиск

Цитировать

Написать

Автор*:

Ввести пароль для входа

Тема*:

Сообщение

Данное сообщение тематическое

Сообщение содержит картинки или видео 18+

Автор:

ВНИМАНИЕ! На данном подфоруме действуют строгие правила. Удостоверьтесь, что ваше сообщение соответствует им!

Форум или тема закрыты для гостей. Необходима авторизация!

Загрузить последнюю сохраненную версию

Вложение:

Вставить как галерею

Максимальный размер вложений: 4,0 МБ, аудио/видео: 8,0 МБ. Картинки большего размера ужимаются, если возможно.

Введите код, изображенный на картинке. Если код нечитаемый, кликните картинку, чтобы загрузить другой вариант.

Отправляя сообщение, я выражаю свое согласие с правилами форума и принимаю пользовательское соглашение.

Доб. в избранное | Игнор. тему | Прикреп. тему | Пометить прочит. / непрочит. | Фильтр

Форумы / Java [игнор отключен] [закрыт для гостей] / Как использовать CompletableFuture

3 сообщений из 3, страница 1 из 1

Как использовать CompletableFuture

#39795284

Molasar

Участник

Сообщения: 838

Рейтинг: 0 / 0

Всем привет!

Использовал Future для вычисления чисел Фибоначчи. Класс Fibo callable.

Код: java

1.
2.

ExecutorService executorService = Executors.newCachedThreadPool();
Future<Long> future = executorService.submit(new Fibo(45));

Прочитал, что можно использовать CompletableFuture, чтобы выполнение кода не приостанавливалось при future.get();
Все статьи в инете описывают использование CompletableFuture с интерфейсом Supplier:

Код: java

1.
2.

CompletableFuture<String> future = CompletableFuture
        .supplyAsync(() -> "Hi", Executors.newCachedThreadPool());

А как мне воткнуть свой класс Fibo в CompletableFuture.supplyAsync()?

...

Рейтинг:

0 / 0

02.04.2019, 16:07

| Ответить | Цитировать | Написать

Как использовать CompletableFuture

#39795352

st07mnn

Гость

MolasarПрочитал, что можно использовать CompletableFuture, чтобы выполнение кода не приостанавливалось при future.get(); Где прочитали?

Код: java

1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.

import java.util.concurrent.*;

public class CompletableFutureDemo {

    public static void main(String[] args) throws TimeoutException {
        final ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
        final CompletableFuture<Long> future = CompletableFuture
                .supplyAsync(() -> new Fibo(45).call(), cachedThreadPool);
        try {
            System.out.println(future.get(500L, TimeUnit.MILLISECONDS));
        } catch (InterruptedException | ExecutionException e) {
            throw new RuntimeException(e);
        } finally {
            cachedThreadPool.shutdown();
        }
    }

}

class Fibo implements Callable<Long> {

    private int idx;

    public Fibo(int idx) {
        this.idx = idx;
    }

    @Override
    public Long call()  {
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }

        return 1L;
    }
}

Примеры задач, для которых удобен класс CompletableFuture:
1. Combining two asynchronous computations in one
2. Waiting for the completion of all tasks performed by a set of Futures
3. Waiting for the completion of only the quickest task in a set of Futures
4. Reacting to a Future completion via callback.

Хорошо описано в соответствующей главе "Java 8 In Action".

...

Рейтинг:

0 / 0

02.04.2019, 17:24

| Ответить | Цитировать | Написать

Как использовать CompletableFuture

#39795609

Molasar

Участник

Сообщения: 838

Рейтинг: 0 / 0

st07mnnMolasarПрочитал, что можно использовать CompletableFuture, чтобы выполнение кода не приостанавливалось при future.get(); Где прочитали?

Код: java

1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.

import java.util.concurrent.*;

public class CompletableFutureDemo {

    public static void main(String[] args) throws TimeoutException {
        final ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
        final CompletableFuture<Long> future = CompletableFuture
                .supplyAsync(() -> new Fibo(45).call(), cachedThreadPool);
        try {
            System.out.println(future.get(500L, TimeUnit.MILLISECONDS));
        } catch (InterruptedException | ExecutionException e) {
            throw new RuntimeException(e);
        } finally {
            cachedThreadPool.shutdown();
        }
    }

}

class Fibo implements Callable<Long> {

    private int idx;

    public Fibo(int idx) {
        this.idx = idx;
    }

    @Override
    public Long call()  {
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }

        return 1L;
    }
}

Код: java

.supplyAsync(() -> new Fibo(45).call(), cachedThreadPool);

try-catch и выбрасывание выше не помогают.
Как можно обработать Exception внутри функционального интерфейса?

...

Рейтинг:

0 / 0

03.04.2019, 10:25

| Ответить | Цитировать | Написать

3 сообщений из 3, страница 1 из 1

Форумы / Java [игнор отключен] [закрыт для гостей] / Как использовать CompletableFuture

Читали тему (0):

Читали форум (0):

Пользователи онлайн (0):

start [/forum/topic.php?fid=59&gotonew=1&tid=2121396]:	0ms
get settings:	9ms
get forum list:	13ms
check forum access:	4ms
check topic access:	4ms
track hit:	40ms
get topic data:	12ms
get first new msg:	9ms
get forum data:	3ms
get page messages:	44ms
get tp. blocked users:	1ms
others:	355ms

total:	494ms