JavaSocketLearn/JavaSocket/src/main/java/four/CompletableFutureTest1.java at master · a1422020484/JavaSocketLearn · GitHub

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
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
package four;

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.function.Supplier;

/**
 * @author yangxp 2019年12月6日上午11:50:20
 *         <p>
 *         描述：CompletableFuture使用,引用链形式的
 */
public class CompletableFutureTest1 {
	public static void main(String[] args) throws InterruptedException, ExecutionException {
		ExecutorService executorService = Executors.newCachedThreadPool();
//		CompletableFuture.supplyAsync(new MyThreadFutureTest1(), executorService).whenComplete((result, e) -> {
//			System.out.println(result + " " + e);
//		}).exceptionally((e) -> {
//			System.out.println("exception " + e);
//			return "execption";
//		});
//
//		CompletableFuture.supplyAsync(new MyThreadFutureTest2(), executorService).whenComplete((result, e) -> {
//			System.out.println(result + " " + e);
//		}).exceptionally((e) -> {
//			System.out.println("exception " + e);
//			return "execption";
//		});
//
//		CompletableFuture.supplyAsync(new MyThreadFutureTest2(), executorService).thenRun(new Runnable() {
//
//			@Override
//			public void run() {
//				System.out.println("fffff");
//			}
//
//		}).whenComplete((result, e) -> {
//			System.out.println(result + " " + e);
// });

		CompletableFuture<String> completableFuture = CompletableFuture.supplyAsync(new MyThreadFutureTest2(), executorService).thenCompose(result -> CompletableFuture.supplyAsync(() -> {
			// 模拟执行耗时任务
			System.out.println("task2 doing...");
			try {
				Thread.sleep(3000);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
			int result2 = Integer.valueOf(result) + 800;
			// 返回结果
			return String.valueOf(result2);
		}));
		executorService.shutdown();

		System.out.println(completableFuture.get());
	}
}

class MyThreadFutureTest1 implements Supplier<String> {

	@Override
	public String get() {
		int sum = 0;
		for (int i = 0; i < 10; i++) {
			try {
				Thread.sleep(300);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
			sum += i;
		}
		return String.valueOf(sum + 300000);
	}

}

class MyThreadFutureTest2 implements Supplier<String> {

	@Override
	public String get() {
		int sum = 999;
		for (int i = 0; i < 10; i++) {
			try {
				Thread.sleep(201);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
			sum += i;
		}
		return String.valueOf(sum + 300000);
	}

}