diff --git a/Java_3-5.md b/Java_3-5.md index b4d65fc..2aa96b4 100644 --- a/Java_3-5.md +++ b/Java_3-5.md @@ -20,7 +20,7 @@ 假定有3个Runnable对象,分别是task1、task2、task3作为查询函数对象,如何调度或者编排这3个task? -```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 函数阻塞。 -```java +``` CompletableFuture cf1 = CompletableFuture.runAsync(task1); CompletableFuture cf2 = CompletableFuture.runAsync(task2); CompletableFuture cf3 = CompletableFuture.runAsync(task3); @@ -41,7 +41,7 @@ CompletableFuture.allOf(cf1, cf2, cf3).get(); **方案二、Future**或者**FutureTask** -```java +``` // 使用自定义线程池 ExecutorService executor = Executors.newFixedThreadPool(3); // 把这3个任务提交给线程池并行执行