Skip to content

Commit 60d467b

Browse files
committed
feat: 更新 java 示例
1 parent 85a8835 commit 60d467b

30 files changed

+728
-324
lines changed

codes/javacore-concurrent/src/main/java/io/github/dunwu/javacore/concurrent/LaunderThrowable.java

Lines changed: 0 additions & 26 deletions
This file was deleted.

codes/javacore-concurrent/src/main/java/io/github/dunwu/javacore/concurrent/Memoizer.java

Lines changed: 0 additions & 50 deletions
This file was deleted.

codes/javacore-concurrent/src/main/java/io/github/dunwu/javacore/concurrent/Memoizer1.java

Lines changed: 0 additions & 53 deletions
This file was deleted.

codes/javacore-concurrent/src/main/java/io/github/dunwu/javacore/concurrent/Memoizer2.java

Lines changed: 0 additions & 33 deletions
This file was deleted.

codes/javacore-concurrent/src/main/java/io/github/dunwu/javacore/concurrent/Memoizer3.java

Lines changed: 0 additions & 45 deletions
This file was deleted.

codes/javacore-concurrent/src/main/java/io/github/dunwu/javacore/concurrent/forkjoin/CompletableFutureDemo.java

Lines changed: 0 additions & 60 deletions
This file was deleted.

codes/javacore-concurrent/src/main/java/io/github/dunwu/javacore/concurrent/forkjoin/CompletableFutureDemo02.java

Lines changed: 0 additions & 47 deletions
This file was deleted.
Lines changed: 33 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,33 @@
1+
package io.github.dunwu.javacore.concurrent.tool.division;
2+
3+
import java.util.Arrays;
4+
import java.util.concurrent.CompletableFuture;
5+
import java.util.concurrent.ExecutorService;
6+
import java.util.concurrent.Executors;
7+
8+
/**
9+
* CompletableFuture 创建
10+
*
11+
* @author <a href="mailto:forbreak@163.com">Zhang Peng</a>
12+
* @date 2024-02-21
13+
*/
14+
public class CompletableFuture_创建 {
15+
16+
public static void main(String[] args) {
17+
// 无返回值的异步任务
18+
CompletableFuture.runAsync(() -> {
19+
System.out.println("无返回值的异步任务");
20+
}).join();
21+
22+
// 有返回值的异步任务
23+
String res = CompletableFuture.supplyAsync(() -> "有返回值的异步任务").join();
24+
System.out.println(res);
25+
26+
// 指定自定义线程池
27+
ExecutorService executor = Executors.newFixedThreadPool(1);
28+
String res2 = CompletableFuture.supplyAsync(() -> "自定义线程池且有返回值的异步任务", executor).join();
29+
System.out.println(res2);
30+
executor.shutdown();
31+
}
32+
33+
}

0 commit comments

Comments
 (0)