FilesExpand file tree

 master

/

QuittingCompletable.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

35 lines (34 loc) · 1.26 KB

 master

/

QuittingCompletable.java

Copy path

Top

File metadata and controls

• Code
• Blame

35 lines (34 loc) · 1.26 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

// concurrent/QuittingCompletable.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.*;

import java.util.stream.*;

import java.util.concurrent.*;

import onjava.Nap;

public class QuittingCompletable {

public static void main(String[] args) {

List<QuittableTask> tasks =

IntStream.range(1, QuittingTasks.COUNT)

.mapToObj(QuittableTask::new)

.collect(Collectors.toList());

List<CompletableFuture<Void>> cfutures =

tasks.stream()

.map(CompletableFuture::runAsync)

.collect(Collectors.toList());

new Nap(1);

tasks.forEach(QuittableTask::quit);

cfutures.forEach(CompletableFuture::join);

}

}

/* Output:

6 7 5 9 11 12 13 14 15 16 17 18 19 20 21 22 23 10 24 26

27 28 29 30 31 32 25 33 8 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 75 76 77 78 79 80 81

82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99

100 101 102 103 104 105 106 107 108 34 110 111 112 113

114 115 116 117 118 119 120 121 109 123 124 125 126 127

128 129 130 131 35 132 122 134 133 136 135 138 140 141

142 143 144 145 146 147 148 149 137 139 3 1 2 4

*/