更新 Java_3-5.md
This commit is contained in:
parent
dc072b8b8a
commit
a911c16787
@ -20,7 +20,7 @@
|
||||
假定有3个Runnable对象,分别是task1、task2、task3作为查询函数对象,如何调度或者编排这3个task?
|
||||
</span>
|
||||
|
||||
```java
|
||||
```
|
||||
Runnable task1 = () -> System.out.println("Task 1");
|
||||
Runnable task2 = () -> System.out.println("Task 2");
|
||||
Runnable task3 = () -> System.out.println("Task 3");
|
||||
@ -32,7 +32,7 @@ Runnable task3 = () -> System.out.println("Task 3");
|
||||
使用 CompletableFuture 的 runAsync 函数,声明3个异步任务。通过 CompletableFuture 的 allOf 函数,添加3个异步任务,调用 get 函数阻塞。
|
||||
</span>
|
||||
|
||||
```java
|
||||
```
|
||||
CompletableFuture<Void> cf1 = CompletableFuture.runAsync(task1);
|
||||
CompletableFuture<Void> cf2 = CompletableFuture.runAsync(task2);
|
||||
CompletableFuture<Void> cf3 = CompletableFuture.runAsync(task3);
|
||||
@ -41,7 +41,7 @@ CompletableFuture.allOf(cf1, cf2, cf3).get();
|
||||
|
||||
**方案二、Future**或者**FutureTask**
|
||||
|
||||
```java
|
||||
```
|
||||
// 使用自定义线程池
|
||||
ExecutorService executor = Executors.newFixedThreadPool(3);
|
||||
// 把这3个任务提交给线程池并行执行
|
||||
|
||||
Loading…
Reference in New Issue
Block a user