从JDK8开始,在Concurrent包中提供了一个强大的异步编程工具CompletableFuture。在JDK8之前,异步编程可以通过线程池和Future来实现,但功能还不够强大。
实例代码:
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
public class CompletableFutureDemo {
public static void main(String[] args) throws ExecutionException, InterruptedException {
CompletableFuture future = new CompletableFuture();
new Thread(() -> {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
future.complete(\"hello world\");
}).start();
System.out.println(\"获取结果中。。。\");
String result = future.get();
System.out.println(\"获取的结果:\" + result);
}
}
CompletableFuture实现了Future接口,所以它也具有Future的特性:调用get()方法会阻塞在那,直到结果返回。另外1个线程调用complete方法完成该Future,则所有阻塞在get()方法的线程都将获得返回结果。
© 版权声明
THE END
请登录后查看评论内容