使用Reactive实现List<Mono<Object>>的并行处理

import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

public class ParallelProcessingExample {
    public static void main(String[] args) {
        List<Mono<Object>> monos = new ArrayList<>();

        // 添加异步操作到monos列表中
        monos.add(Mono.just("Result 1").delayElement(Duration.ofSeconds(1)));
        monos.add(Mono.just("Result 2").delayElement(Duration.ofSeconds(2)));
        monos.add(Mono.just("Result 3").delayElement(Duration.ofSeconds(3)));

        // 并行处理monos列表中的异步操作
        Flux.fromIterable(monos)
                .flatMap(mono -> mono)
                .doOnNext(result -> System.out.println("Processed result: " + result))
                .blockLast();
    }
}