package com.tj.teamtalk.kafka; 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; /** * 基于jdk1.8实现任务异步处理 * * @author Administrator * */ public class JavaPromise { public static void main(String[] args) throws Throwable, ExecutionException { // 两个线程的线程池 ExecutorService executor = Executors.newFixedThreadPool(2); //jdk1.8之前的实现方式 CompletableFuture<String> future = CompletableFuture.supplyAsync(new Supplier<String>() { @Override public String get() { System.out.println("task started!"); try { //模拟耗时操作 Thread.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); } return "task finished!==="; } }, executor); System.out.println("main thread is running"); } }