例如， flux.map(i->{Thread.sleep(1000); return i*i;}).flatMap(i->Monn.just(i)) . map操作符本质上是异步执行的，还是我们必须更改线程以便它可以异步执行（就像我们切换到 flux.map(i->{Thread.sleep(1000); return i*i;}).subscribeOn(Schedulers.elastic()).flatMap(i->Monn.just(i)) )?
这个例子： flux.map(i->i*i).flatMap(i->Monn.just(i)) . map opeator本质上是异步执行的，还是我们必须改变线程才能像上一段一样异步执行？
1条答案
按热度按时间t3psigkw1#
获得通量或mono并不一定意味着它在专用线程中运行。相反，大多数操作符继续在前一个操作符执行的线程中工作。除非指定，否则最顶层的操作符（源）本身在进行subscribe（）调用的线程上运行。以上是我想知道的。