摘要：相對(duì)于最大的更新就是把對(duì)背壓問題的處理邏輯從中抽取出來產(chǎn)生了新的可觀察對(duì)象。由于基于發(fā)射的數(shù)據(jù)流，以及對(duì)數(shù)據(jù)加工處理的各操作符都添加了背壓支持，附加了額外的邏輯，其運(yùn)行效率要比慢得多。

背壓（backpressure）
當(dāng)上下游在不同的線程中，通過Observable發(fā)射，處理，響應(yīng)數(shù)據(jù)流時(shí)，如果上游發(fā)射數(shù)據(jù)的速度快于下游接收處理數(shù)據(jù)的速度，這樣對(duì)于那些沒來得及處理的數(shù)據(jù)就會(huì)造成積壓，這些數(shù)據(jù)既不會(huì)丟失，也不會(huì)被垃圾回收機(jī)制回收，而是存放在一個(gè)異步緩存池中，如果緩存池中的數(shù)據(jù)一直得不到處理，越積越多，最后就會(huì)造成內(nèi)存溢出，這便是響應(yīng)式編程中的背壓（backpressure）問題。
例如，運(yùn)行以下代碼：

public void demo1() {

    Observable
            .create(new ObservableOnSubscribe() {
                @Override
                public void subscribe(ObservableEmitter e) throws Exception {
                    int i = 0;
                    while (true) {
                        i++;
                        e.onNext(i);
                    }
                }
            })
            .subscribeOn(Schedulers.newThread())
            .observeOn(Schedulers.newThread())
            .subscribe(new Consumer() {
                @Override
                public void accept(Integer integer) throws Exception {
                    Thread.sleep(5000);
                    System.out.println(integer);
                }
            });
}

創(chuàng)建一個(gè)可觀察對(duì)象Observable在Schedulers.newThread()的線程中不斷發(fā)送數(shù)據(jù)，而觀察者Observer在Schedulers.newThread()的另一個(gè)線程中每隔5秒接收打印一條數(shù)據(jù)。
運(yùn)行后，查看內(nèi)存使用如下：

由于上游通過Observable發(fā)射數(shù)據(jù)的速度大于下游通過Consumer接收處理數(shù)據(jù)的速度，而且上下游分別運(yùn)行在不同的線程中，下游對(duì)數(shù)據(jù)的接收處理不會(huì)堵塞上游對(duì)數(shù)據(jù)的發(fā)射，造成上游數(shù)據(jù)積壓，內(nèi)存不斷增加，最后便會(huì)導(dǎo)致內(nèi)存溢出。

Flowable
既然在函數(shù)響應(yīng)式編程中會(huì)產(chǎn)生背壓（backpressure）問題，那么在函數(shù)響應(yīng)式編程中就應(yīng)該有解決方案。
Rxjava2相對(duì)于Rxjava1最大的更新就是把對(duì)背壓問題的處理邏輯從Observable中抽取出來產(chǎn)生了新的可觀察對(duì)象Flowable。

在Rxjava2中，F(xiàn)lowable可以看做是為了解決背壓問題，在Observable的基礎(chǔ)上優(yōu)化后的產(chǎn)物，與Observable不處在同一組觀察者模式下，Observable是ObservableSource/Observer這一組觀察者模式中ObservableSource的典型實(shí)現(xiàn)，而Flowable是Publisher與Subscriber這一組觀察者模式中Publisher的典型實(shí)現(xiàn)。

所以在使用Flowable的時(shí)候，可觀察對(duì)象不再是Observable,而是Flowable;觀察者不再是Observer，而是Subscriber。Flowable與Subscriber之間依然通過subscribe()進(jìn)行關(guān)聯(lián)。

雖然在Rxjava2中，F(xiàn)lowable是在Observable的基礎(chǔ)上優(yōu)化后的產(chǎn)物，Observable能解決的問題Flowable也都能解決，但是并不代表Flowable可以完全取代Observable,在使用的過程中，并不能拋棄Observable而只用Flowable。

由于基于Flowable發(fā)射的數(shù)據(jù)流，以及對(duì)數(shù)據(jù)加工處理的各操作符都添加了背壓支持，附加了額外的邏輯，其運(yùn)行效率要比Observable慢得多。

只有在需要處理背壓問題時(shí)，才需要使用Flowable。

由于只有在上下游運(yùn)行在不同的線程中，且上游發(fā)射數(shù)據(jù)的速度大于下游接收處理數(shù)據(jù)的速度時(shí)，才會(huì)產(chǎn)生背壓問題；
所以，如果能夠確定：
1、上下游運(yùn)行在同一個(gè)線程中，
2、上下游工作在不同的線程中，但是下游處理數(shù)據(jù)的速度不慢于上游發(fā)射數(shù)據(jù)的速度，
3、上下游工作在不同的線程中，但是數(shù)據(jù)流中只有一條數(shù)據(jù)
則不會(huì)產(chǎn)生背壓問題，就沒有必要使用Flowable，以免影響性能。