MsBlog

Java8 CompletableFuture异步编程

CompletableFuture是Java 8引入的一个强大的异步编程工具，它实现了Future和CompletionStage接口，提供了丰富的API来简化异步操作。与传统的Future相比，CompletableFuture支持非阻塞的回调机制，允许通过观察者模式在计算结果完成时立即通知监听者，避免了轮询或阻塞主线程的问题。该类提供了一系列方法用于创建异步任务（如runAsync、supplyAsync）、处理任务完成后的结果（如whenComplete、handle）、以及组合多个异步任务（如thenCombine、applyToEither）。此外，CompletableFuture还支持多任务组合操作（如allOf等待所有任务完成, anyOf只要有一个任务完成），使得复杂的异步流程控制变得更加简单直观。示例代码展示了如何使用这些方法进行异步任务的创建、结果处理及任务间的协调。

2021-07-11

1018

java8:Stream

Java 8 引入了 Stream API，用于高效且易于使用的集合数据处理。Stream 提供了两种基本特征：Pipelining 和内部迭代。Pipelining 允许多个操作串联成一个管道，并支持延迟执行和短路；内部迭代则通过访问者模式实现。Stream 可以是顺序流（stream）或并行流（parallelStream），后者在多线程中并行执行操作。创建 Stream 的方法包括使用 Collection 的 stream() 和 parallelStream() 方法、将数组转为流、使用 Stream 的静态方法 of()、iterate() 和 generate()、BufferedReader 的 lines() 方法以及 Pattern 的 splitAsStream() 方法。流的操作涵盖了遍历/匹配、筛选、映射、聚合、归约、排序、收集等。其中，collect 操作依赖于 Collectors 类提供的多种方法，如 toList/toSet/toMap、统计、分组、接合和归约。此外，还可以进行流的合并、去重、限制和跳过等操作。这些功能使得 Stream API 成为处理集合数据的强大工具。

Java8:Lambad表达式

Lambda表达式，也可称为闭包，它是推动Java8发布的最重要新特性。Lambda允许把函数作为一个方法的参数（函数作为参数传递进方法中）。使用Lambda表达式可以使代码变的更加简洁紧凑。