Java Mono 类【转载】

java

字数统计: 431阅读时长: 2 min

 2025/03/03 

//empty()：创建一个不包含任何元素，只发布结束消息的序列
Mono.empty().subscribe(System.out::println);
//just()：可以指定序列中包含的全部元素。创建出来的 Mono序列在发布这些元素之后会自动结束。
Mono.just("www.jackssybin.cn").subscribe(System.out::println);
//ustOrEmpty()：从一个 Optional 对象或可能为 null 的对象中创建 Mono。
//只有 Optional 对象中包含值或对象不为 null 时，Mono 序列才产生对应的元素。
Mono.justOrEmpty(null).subscribe(System.out::println);
Mono.justOrEmpty("jackssy").subscribe(System.out::println);
Mono.justOrEmpty(Optional.of("jackssy")).subscribe(System.out::println);
//error(Throwable error)：创建一个只包含错误消息的序列。
Mono.error(new RuntimeException("error")).subscribe(System.out::println, System.err::println);
//never()：创建一个不包含任何消息通知的序列。
Mono.never().subscribe(System.out::println);
//通过 create()方法来使用 MonoSink 来创建 Mono。
Mono.create(sink -> sink.success("jackssy")).subscribe(System.out::println);

//通过fromRunnable创建，并实现异常处理
Mono.fromRunnable(() -> {
    System.out.println("thread run");
    throw new RuntimeException("thread run error");
}).subscribe(System.out::println, System.err::println);

//通过fromCallable创建
Mono.fromCallable(() -> "callable run ").subscribe(System.out::println);

//通过fromSupplier创建
Mono.fromSupplier(() -> "create from supplier").subscribe(System.out::println);

// delay(Duration duration)和 delayMillis(long duration)：创建一个 Mono 序列，在指定的延迟时间之后，产生数字 0 作为唯一值。
long start = System.currentTimeMillis();
Disposable disposable = Mono.delay(Duration.ofSeconds(2)).subscribe(n -> {
    System.out.println("生产数据源："+ n);
    System.out.println("当前线程ID："+ Thread.currentThread().getId() + ",生产到消费耗时："+ (System.currentTimeMillis() - start));
});
System.out.println("主线程"+ Thread.currentThread().getId() + "耗时："+ (System.currentTimeMillis() - start));

while(!disposable.isDisposed()) {
  
} //empty()：创建一个不包含任何元素，只发布结束消息的序列

原文作者：Maple

原文链接：https://blog.vvcat.cn/2025/03/03/2025/01/Java_Mono/

发表日期：March 3rd 2025, 3:49:35 am

更新日期：November 17th 2025, 7:33:29 am

Next Post

setting.xml 配置 (by deepseek)
Previous Post

使用单页打印机打印双页

CATALOG