FilesExpand file tree

 master

/

CompletableOperations.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

74 lines (73 loc) · 2.06 KB

 master

/

CompletableOperations.java

Copy path

Top

File metadata and controls

• Code
• Blame

74 lines (73 loc) · 2.06 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

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

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

// concurrent/CompletableOperations.java

// (c)2021 MindView LLC: see Copyright.txt

// We make no guarantees that this code is fit for any purpose.

// Visit http://OnJava8.com for more book information.

import java.util.concurrent.*;

import static onjava.CompletableUtilities.*;

public class CompletableOperations {

static CompletableFuture<Integer> cfi(int i) {

return

CompletableFuture.completedFuture(

Integer.valueOf(i));

}

public static void main(String[] args) {

showr(cfi(1)); // Basic test

voidr(cfi(2).runAsync(() ->

System.out.println("runAsync")));

voidr(cfi(3).thenRunAsync(() ->

System.out.println("thenRunAsync")));

voidr(CompletableFuture.runAsync(() ->

System.out.println("runAsync is static")));

showr(CompletableFuture.supplyAsync(() -> 99));

voidr(cfi(4).thenAcceptAsync(i ->

System.out.println("thenAcceptAsync: " + i)));

showr(cfi(5).thenApplyAsync(i -> i + 42));

showr(cfi(6).thenComposeAsync(i -> cfi(i + 99)));

CompletableFuture<Integer> c = cfi(7);

c.obtrudeValue(111);

showr(c);

showr(cfi(8).toCompletableFuture());

c = new CompletableFuture<>();

c.complete(9);

showr(c);

c = new CompletableFuture<>();

c.cancel(true);

System.out.println("cancelled: " +

c.isCancelled());

System.out.println("completed exceptionally: " +

c.isCompletedExceptionally());

System.out.println("done: " + c.isDone());

System.out.println(c);

c = new CompletableFuture<>();

System.out.println(c.getNow(777));

c = new CompletableFuture<>();

c.thenApplyAsync(i -> i + 42)

.thenApplyAsync(i -> i * 12);

System.out.println("dependents: " +

c.getNumberOfDependents());

c.thenApplyAsync(i -> i / 2);

System.out.println("dependents: " +

c.getNumberOfDependents());

}

}

/* Output:

1

runAsync

thenRunAsync

runAsync is static

99

thenAcceptAsync: 4

47

105

111

8

9

cancelled: true

completed exceptionally: true

done: true

java.util.concurrent.CompletableFuture@1629346[Complete

d exceptionally]

777

dependents: 1

dependents: 2

*/