Запуск < /p>
Mono.fromRunnable(() -> log.info("Thread {}", Thread.currentThread().getName()))
.publishOn(Schedulers.boundedElastic())
.subscribe();
< /code>
logs < /p>
Thread boundedElastic-
< /code>
Это не совпадение, изменение планировщика влияет на именование потока соответственно. Почему Publishon () Планировщик влияет на то, где лямбда в mono.fromrunnable () запускается?Mono.just("x")
.doOnNext(_w -> log.info("Thread before {}", Thread.currentThread().getName()))
.publishOn(Schedulers.boundedElastic())
.doOnNext(_w -> log.info("Thread after {}", Thread.currentThread().getName()))
.subscribe();
< /code>
, где я получаю < /p>
Thread before Test worker
Thread after boundedElastic-
Подробнее здесь: https://stackoverflow.com/questions/796 ... omrunnable
