java8 协程使用

Java 8 引入了 Lambda 表达式和函数式接口的概念，但是并没有提供直接的协程支持。但是，使用 Java 8 的 Stream API 可以实现一些类似协程的效果。

在 Java 8 中，Stream API 可以将一个集合中的元素流式处理，而不需要在内存中保存整个集合。这就类似于协程的效果，它可以异步地处理数据，并在需要时返回部分处理结果。通过使用 Stream API 和 Lambda 表达式，可以实现一个简单的协程框架。

具体实现方式为：创建一个 Stream 对象，对其进行流式处理，并使用 CompletableFuture 来异步执行每个元素的处理逻辑。在处理逻辑完成后，使用 thenApply 方法将结果传递给下一个处理逻辑，并使用 CompletableFuture.join() 方法等待所有处理逻辑完成。最后，返回处理结果。

下面是一个示例代码，展示了如何使用 Stream API 和 CompletableFuture 实现简单的协程效果：

public static void main(String[] args) {
    List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);

    CompletableFuture<Void> future = CompletableFuture.completedFuture(null);

    for (int number : numbers) {
        final int n = number;
        future = future.thenApplyAsync((Void) -> {
            // 处理逻辑
            System.out.println(Thread.currentThread().getName() + ": " + n * 2);
            return null;
        });
    }

    future.join();
}

以上代码将列表中的每个元素乘以2，并在控制台输出结果。输出结果的顺序可能会与输入顺序不同，因为 CompletableFuture 使用了线程池来执行异步任务。