Гость
Войти | Профиль | Очистить
Целевая тема:
Создать новую тему:
Автор:
Действия ...
Форумы / Java [игнор отключен] [закрыт для гостей] / Как использовать CompletableFuture / 3 сообщений из 3, страница 1 из 1
02.04.2019, 16:07
    #39795284
Molasar
Molasar
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Как использовать CompletableFuture
Всем привет!

Использовал 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, 17:24
    #39795352
st07mnn
st07mnn
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Как использовать CompletableFuture
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
| Ответить | Цитировать | Написать  
03.04.2019, 10:25
    #39795609
Molasar
Molasar
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Как использовать CompletableFuture
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;
    }
}



Примеры задач, для которых удобен класс 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".

NetBeans говорит необработанный Exception в методе Call()
Код: java
1.
.supplyAsync(() -> new Fibo(45).call(), cachedThreadPool);


try-catch и выбрасывание выше не помогают.
Как можно обработать Exception внутри функционального интерфейса?
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
Форумы / Java [игнор отключен] [закрыт для гостей] / Как использовать CompletableFuture / 3 сообщений из 3, страница 1 из 1
Найденые пользователи ...
Разблокировать пользователей ...
Читали тему (0):
Читали форум (0):
Пользователи онлайн (0):
Польз. соглашение
созд. / загр.: 143ms
Закрыть
start [/forum/topic.php?fid=59&mobile=1&tid=2121396]:
 0ms
get settings:
 8ms
get forum list:
 14ms
check forum access:
 5ms
check topic access:
 5ms
track hit:
 40ms
get topic data:
 10ms
get forum data:
 2ms
get page messages:
 44ms
get tp. blocked users:
 2ms
others: 13ms
total:  143ms
x
x
Закрыть


Просмотр
0 / 0
Close
Debug Console [Select Text]