家住海边喜欢浪 💎

家住海边喜欢浪 💎

0个粉丝

1

问答

0

专栏

0

资料

家住海边喜欢浪 💎  发布于  2021-01-08 16:07:59
采纳率 0%
1个问答
2302

大佬们想问一下  Reactor3  在哪里体现的  异步非阻塞

大佬们想问一下  Reactor3  在哪里体现的  异步非阻塞
我来回答
回答1个
时间排序
认可量排序

生时

0个粉丝

0

问答

0

专栏

0

资料

生时 2021-03-24 17:06:44
认可0
@Test
public void testJust() throws InterruptedException {
    for(int g =0;g<100;g++){
        int finalG = g;
        createFx(finalG).subscribe(m->{

            System.out.println("rm,i=:"+m+",time:"+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
        });
    }
    Thread.sleep(10000L);
}

public Flux<Integer> createFx(int i){
    return Flux.create(f->{
        int rm  = new Random().nextInt(50);
        int finalRm = rm;
        new Thread(()->{

            try {
                Thread.sleep(finalRm);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            f.next(i);

        }).start();
        f.next(i);
    });
}
或将文件直接拖到这里
悬赏:
E币
网盘
* 网盘链接:
* 提取码:
悬赏:
E币

Markdown 语法

  • 加粗**内容**
  • 斜体*内容*
  • 删除线~~内容~~
  • 引用> 引用内容
  • 代码`代码`
  • 代码块```编程语言↵代码```
  • 链接[链接标题](url)
  • 无序列表- 内容
  • 有序列表1. 内容
  • 缩进内容
  • 图片![alt](url)
+ 添加网盘链接/附件

Markdown 语法

  • 加粗**内容**
  • 斜体*内容*
  • 删除线~~内容~~
  • 引用> 引用内容
  • 代码`代码`
  • 代码块```编程语言↵代码```
  • 链接[链接标题](url)
  • 无序列表- 内容
  • 有序列表1. 内容
  • 缩进内容
  • 图片![alt](url)
相关问答
无更多相似问答 去提问
举报反馈

举报类型

  • 内容涉黄/赌/毒
  • 内容侵权/抄袭
  • 政治相关
  • 涉嫌广告
  • 侮辱谩骂
  • 其他

详细说明

易百纳技术社区