Reactor經(jīng)過buffer后是一個(gè)一個(gè)的發(fā)送數(shù)據(jù),如果使用publishOn或subscribeOn處理的話,只等待下游的subscribe處理完成才會(huì)重新request新的數(shù)據(jù),buffer操作符才會(huì)重新發(fā)送數(shù)據(jù)。如果此時(shí)subscribe消費(fèi)者耗時(shí)較長,數(shù)據(jù)流會(huì)在buffer流程阻塞,顯然并不是我們想要的。 理想的操作是消費(fèi)者在一個(gè)線程池里操作,可多線程并行處理,如果線程...
www.dbjr.com.cn/article/2065...htm 2025-6-5