当前位置： 首页 > news >正文

51一起做网站东莞网站开发公司

news 2025/8/13 13:20:49
51一起做网站,东莞网站开发公司,做机械外贸什么网站好,网站建设-好发信息网目录 一、基本概念 1.1 异步编程 1.2 CompletableFuture简介 二、创建和完成CompletableFuture 2.1 创建CompletableFuture对象 2.2 手动完成CompletableFuture 2.3 异常完成CompletableFuture 三、异步计算和回调 3.1 异步任务的执行 3.2 处理计算结果 四、组合多个…

目录

一、基本概念

1.1 异步编程

1.2 CompletableFuture简介

二、创建和完成CompletableFuture

2.1 创建CompletableFuture对象

2.2 手动完成CompletableFuture

2.3 异常完成CompletableFuture

三、异步计算和回调

3.1 异步任务的执行

3.2 处理计算结果

四、组合多个CompletableFuture

4.1 thenCombine

4.2 thenCompose

4.3 allOf和anyOf

五、异常处理

5.1 handle

5.2 exceptionally

六、高级特性

6.1 自定义执行器

6.2 超时控制

七、实战案例

7.1 需求描述

7.2 代码实现

Java的CompletableFuture是Java 8中引入的一个功能强大的类，用于处理异步编程。它不仅提供了一种方式来表示异步计算，还提供了丰富的API来进行复杂的异步编排和处理。本文将详细讲解CompletableFuture的基本概念、使用方法以及一些高级特性，并结合实例代码进行说明。

一、基本概念

1.1 异步编程

异步编程是一种并发编程的形式，通过非阻塞方式执行任务。传统的同步编程中，任务必须按顺序执行，每个任务必须等待前一个任务完成。然而，在异步编程中，任务可以在后台执行，主线程无需等待任务完成，因而可以继续处理其他任务。这种方式在提高程序响应速度和资源利用率方面有很大优势。

1.2 CompletableFuture简介

CompletableFuture是Java提供的一个实现Future接口的类，它不仅支持传统的Future接口方法，还引入了许多新的方法来支持回调、组合、处理异常等功能。通过这些方法，开发者可以更方便地编写异步代码。

二、创建和完成CompletableFuture

2.1 创建CompletableFuture对象

创建一个CompletableFuture对象非常简单，可以通过以下几种方式：

  1. 使用CompletableFuture的静态工厂方法：

    CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> "Hello, World!");

  2. 使用默认构造函数创建一个空的CompletableFuture，然后在未来的某个时间点手动完成它：

    CompletableFuture<String> future = new CompletableFuture<>();
// 在其他线程或任务中完成这个future
future.complete("Hello, World!");
2.2 手动完成CompletableFuture

你可以通过complete方法手动完成一个CompletableFuture：

CompletableFuture<String> future = new CompletableFuture<>();
future.complete("Hello, World!");

如果已经完成的CompletableFuture再次调用complete，将不会改变其状态。

2.3 异常完成CompletableFuture

CompletableFuture也可以以异常方式完成：

CompletableFuture<String> future = new CompletableFuture<>();
future.completeExceptionally(new RuntimeException("Something went wrong"));

三、异步计算和回调

3.1 异步任务的执行

CompletableFuture提供了多种方法来启动异步任务，例如：

  • runAsync：执行不返回结果的异步任务。

  • supplyAsync：执行并返回结果的异步任务。

CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {// 异步执行的任务System.out.println("Hello from a different thread!");
});
​
CompletableFuture<String> futureWithResult = CompletableFuture.supplyAsync(() -> {// 异步执行的任务，返回结果return "Result of the async computation";
});
3.2 处理计算结果

CompletableFuture提供了多种方法来处理异步任务的结果，例如：

  • thenApply：当CompletableFuture完成时，对其结果进行处理，并返回一个新的CompletableFuture。

  • thenAccept：当CompletableFuture完成时，消费其结果，但不返回新的CompletableFuture。

  • thenRun：当CompletableFuture完成时，运行一个任务，不关心其结果。

CompletableFuture.supplyAsync(() -> "Hello").thenApply(result -> result + ", World!").thenAccept(System.out::println);

上述代码中，supplyAsync方法执行异步任务并返回结果"Hello"。thenApply方法对结果进行处理，得到"Hello, World!"。thenAccept方法消费处理后的结果，并打印输出。

四、组合多个CompletableFuture

CompletableFuture提供了多种方式来组合多个异步任务：

4.1 thenCombine

thenCombine用于将两个CompletableFuture的结果进行组合，并返回一个新的CompletableFuture：

CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> "Hello");
CompletableFuture<String> future2 = CompletableFuture.supplyAsync(() -> "World");
​
CompletableFuture<String> combinedFuture = future1.thenCombine(future2, (result1, result2) -> result1 + " " + result2);
combinedFuture.thenAccept(System.out::println); // 输出 "Hello World"
4.2 thenCompose

thenCompose用于将一个CompletableFuture的结果作为另一个CompletableFuture的输入，类似于flatMap：

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> "Hello").thenCompose(result -> CompletableFuture.supplyAsync(() -> result + " World"));
​
future.thenAccept(System.out::println); // 输出 "Hello World"
4.3 allOf和anyOf

  • allOf：等待所有提供的CompletableFuture都完成。

  • anyOf：只要任意一个CompletableFuture完成即可。

CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> "Result from future1");
CompletableFuture<String> future2 = CompletableFuture.supplyAsync(() -> "Result from future2");
​
CompletableFuture<Void> allOfFuture = CompletableFuture.allOf(future1, future2);
allOfFuture.thenRun(() -> System.out.println("All futures completed"));
​
CompletableFuture<Object> anyOfFuture = CompletableFuture.anyOf(future1, future2);
anyOfFuture.thenAccept(result -> System.out.println("First completed future result: " + result));

五、异常处理

在处理异步任务时，异常处理是不可避免的。CompletableFuture提供了多种方式来处理异常：

5.1 handle

handle方法用于处理正常结果和异常情况：

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {if (Math.random() > 0.5) {throw new RuntimeException("Something went wrong");}return "Success";
});
​
future.handle((result, ex) -> {if (ex != null) {return "Exception: " + ex.getMessage();}return result;
}).thenAccept(System.out::println);
5.2 exceptionally

exceptionally方法仅处理异常情况：

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {if (Math.random() > 0.5) {throw new RuntimeException("Something went wrong");}return "Success";
});
​
future.exceptionally(ex -> "Exception: " + ex.getMessage()).thenAccept(System.out::println);

六、高级特性

6.1 自定义执行器

默认情况下，CompletableFuture使用ForkJoinPool.commonPool()作为其默认的线程池。你可以自定义执行器来控制任务的执行方式：

Executor executor = Executors.newFixedThreadPool(10);
​
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> "Hello", executor).thenApplyAsync(result -> result + " World", executor);
​
future.thenAcceptAsync(System.out::println, executor);
6.2 超时控制

在某些场景下，处理超时是必要的。Java 9引入了orTimeout和completeOnTimeout方法：

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {try {Thread.sleep(3000);} catch (InterruptedException e) {throw new IllegalStateException(e);}return "Result";
});
​
future.orTimeout(1, TimeUnit.SECONDS).exceptionally(ex -> "Timeout occurred: " + ex.getMessage()).thenAccept(System.out::println);

七、实战案例

为了更好地理解CompletableFuture，我们来看一个实际的例子：模拟一个复杂的业务场景，包含多个异步任务的组合和处理。

7.1 需求描述

假设我们在开发一个在线购物平台，用户下单时需要进行以下操作：

  1. 验证用户信息。

  2. 检查库存。

  3. 处理支付。

  4. 生成订单。

我们希望这些操作尽可能并行执行，以提高系统的响应速度。

7.2 代码实现
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
​
public class OnlineShopping {
​private static final ExecutorService executor = Executors.newFixedThreadPool(10);
​public static void main(String[] args) {CompletableFuture<Void> orderFuture = CompletableFuture.supplyAsync(() -> verifyUser("user123"), executor).thenCombineAsync(CompletableFuture.supplyAsync(() -> checkInventory("item456"), executor), (userVerified, inventoryChecked) -> {if (userVerified && inventoryChecked) {return processPayment("user123", "
​
item456");} else {throw new RuntimeException("User verification or inventory check failed");}}, executor).thenApplyAsync(paymentProcessed -> generateOrder("user123", "item456"), executor).thenAcceptAsync(order -> System.out.println("Order completed: " + order), executor).exceptionally(ex -> {System.err.println("Order processing failed: " + ex.getMessage());return null;});
​orderFuture.join(); // 等待所有操作完成}
​private static boolean verifyUser(String userId) {// 模拟用户验证System.out.println("Verifying user: " + userId);return true;}
​private static boolean checkInventory(String itemId) {// 模拟库存检查System.out.println("Checking inventory for item: " + itemId);return true;}
​private static boolean processPayment(String userId, String itemId) {// 模拟支付处理System.out.println("Processing payment for user: " + userId + " and item: " + itemId);return true;}
​private static String generateOrder(String userId, String itemId) {// 模拟订单生成System.out.println("Generating order for user: " + userId + " and item: " + itemId);return "Order123";}
}

在这个示例中，我们使用了多个CompletableFuture来并行执行用户验证、库存检查和支付处理。所有任务都在自定义的线程池中执行，最后通过生成订单来完成整个流程。如果在任何一个步骤中发生异常，系统会捕获并处理。

http://www.mnyf.cn/news/14234.html

相关文章：

  • 网站建设域名注册免费千锋教育培训收费一览表
  • php建立网站seo关键词优化软件
  • 保定建设招聘信息网站网站优化的意义
  • 长沙的企业网站建设发稿网
  • 网站用什么东西做长沙百度推广开户
  • 网站文件权限设置国外网站设计
  • 浏阳网站开发建设网站平台推广
  • 网站建设公司市场开发方案免费发帖推广网站
  • 新网网站制作渠道推广有哪些方式
  • 做外贸网站外包成人营销管理培训班
  • wordpress 教材主题新乡百度关键词优化外包
  • 帮你做海报网站手机百度app
  • 网站开发公司哪家最专业网站推广的方式有
  • 开发网站需要多少资金电商怎么做营销推广
  • 修改网站参数重庆seo排名公司
  • 有了源代码如何做网站全网seo优化电话
  • 泰安网络推广公司推荐天津seo顾问
  • 织梦响应式网站快速优化网站排名的方法
  • 室内设计在线设计深圳谷歌优化seo
  • 长春火车站是北站吗国外网站制作
  • wordpress链接的图片保存到本地seo需要懂代码吗
  • 网站ip被屏蔽怎么办网络营销推广论文
  • 用爬虫做网站国外seo大神
  • 观澜做网站八大营销模式有哪几种
  • 24小时自动发货网站建设网络推广精准营销推广
  • 网站规划与网站建设网店代运营和推广销售
  • 专业婚纱摄影网站制作新媒体运营培训
  • 电子商务做网站seo网站推广方法
  • 电子商务门户网站的研究与实现公司网站如何seo
  • 政府门户网站建设问卷调查网页自动点击软件