thread-multi.zip

package com.congge.thread; import java.util.ArrayList; import java.util.List; import java.util.Random; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; //实现任务串行化 public class ComplatableFuture1 { /*public static void main(String[] args) { List<Integer> res = new ArrayList<>(); ExecutorService service = Executors.newFixedThreadPool(3); ArrayList<Future> futures = new ArrayList<>(); for (int i = 0; i < 5; i++) { int k=i; Future<Integer> future = service.submit(() -> { Thread.sleep(1000); return k; }); futures.add(future); } //遍历获取结果 for (int i = 0; i <futures.size() ; i++) { Future future = futures.get(i); try { Integer result = (Integer)future.get(); res.add(result); System.out.println(result); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } } int sum = 0; int t1 = 6; res.add(t1); System.out.println("最后的结果是 ============"); System.out.println(res); service.shutdown(); }*/ //thenRun /*public static void main(String[] args) throws ExecutionException, InterruptedException { CompletableFuture<Void> future = CompletableFuture.supplyAsync(() -> { return 1; }).thenRun(() -> { //thenRun 直接执行第二个任务 System.out.println("执行第二个任务"); return; }); future.get(); System.out.println("任务完成"); }*/ //thenRunAsync /*public static void main(String[] args) throws ExecutionException, InterruptedException { CompletableFuture<Void> future = CompletableFuture.supplyAsync(() -> { return 1; }).thenRunAsync(() -> { try { Thread.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); } //thenRunAsync 直接执行第二个任务,不过是异步的 System.out.println("执行第二个任务"); return; }); future.get(); System.out.println("任务完成"); }*/ //thenAccept 可以拿到上一步的执行结果，但是没有返回值 /*public static void main(String[] args) throws ExecutionException, InterruptedException { ExecutorService service = Executors.newFixedThreadPool(5); CompletableFuture<Void> future = CompletableFuture.supplyAsync(() -> { return 1; }, service).thenAcceptAsync(res -> { //thenAccept 可以使用上一次的结果，但是没有返回值 System.out.println("执行第二个任务，上一步的而结果是：" + res); }, service); future.get(); System.out.println("任务完成"); }*/ //thenApplyAsync 可以有返回结果 /*public static void main(String[] args) throws ExecutionException, InterruptedException { ExecutorService service = Executors.newFixedThreadPool(5); CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> { return 1; }, service).thenApplyAsync(res -> { //thenAccept 可以使用上一次的结果，但是没有返回值 System.out.println("执行第二个任务，上一步的而结果是：" + res); return res +10; }, service); Integer integer = future.get(); System.out.println("任务完成,最终的结果是:" + integer); service.shutdown(); }*/ public static void main(String[] args) throws ExecutionException, InterruptedException { List<Integer> res = new ArrayList<>(); ExecutorService service = Executors.newFixedThreadPool(3); Future<Integer> submit = service.submit(() -> { return 1; }); int cc = 10; System.out.println(cc + submit.get()); service.shutdown(); } }