點我啊，程式碼在這裡

原因

在code程式碼中，我們經常碰到非同步方法巢狀。比如提交檔案之後在提交表單，提交資料根據是否成功然後做出其他邏輯處理。kotlin裡面提出協程概念，利用語法糖來解決這個問題。在javaScript裡面也有async/await來使非同步用起來像同步。而在java中我暫時沒有找到該特性，使得寫起來非同步巢狀感覺就是地獄，像吃了屎一樣。利用這春節幾天時間，嘗試著按自己思路去解決這個問題，造個流式的輪子，於是寫了Flow小框子。

想法

從生活中思考程式碼，方法巢狀和水流的原理很相似，我們把每個非同步當成一個水管，水從一個個管道流過，每個管道可以對水進行加工轉換。轉換的這個過程我們當成一個事件Event。在包裝事件中，我們可以對它進行執行緒轉換，事件轉換，合併拆分等一系列轉換。如果碰到異常，則直接終止這個流。

功能

簡單使用

通過Flow 靜態create方法建立一個流，then串聯下個流，如果不需要返回Void泛型。Event有兩個泛型P、R,第一個是前個流Flow的返回值型別，第二個是當前流Flow返回型別。await exec方法是結束當前事件流，並將結果代入下個流。

列印兩句話

Flow.create(new Event<Void,Void>() {
          @Override
          public void run(Flow flow,Void aVoid,Await<Void> await) {
            System.out.println("this is first flow");
            await.exec(null);
          }
          
        }).then(new Event<Void,Await<Void> await) {
            System.out.println("this is two flow");
            await.exec(null); 
          }
        }).start();

Lambda簡化之後

Flow.create((NoneEvent) (flow,await) -> {
          System.out.println("this is first flow");
          await.exec(); 
        }).then((NoneEvent) (flow,await) -> {
            System.out.println("this is two flow");
            await.exec();
        }).start();

兩數相加

 Flow.create((FirstEvent<Integer>) (flow,await) -> 
            await.exec(3))
           .then((Event<Integer,Integer>) (flow,integer,await) -> 
               await.exec(integer + 5))
           .resultThen((flow,result) -> 
               System.out.println("total is"+result))
           .start();

resultThen方法返回是當前流的結果，每個flow後面使用resultThen都可以獲取流的結果。如果遇到異常，可以通過flow throwException方法丟擲，可以在flow後面catchThen立刻處理，也可以在最後flow catchThen處理。finallyThen是事件流結束一個通知。

 Flow.create((FirstEvent<Integer>) (flow,await) ->
            await.exec(0))
           .then((Event<Integer,perVal,await) ->{
             if(perVal == 0){
               flow.throwException("Dividend cannot be 0!");
             }else{
               await.exec(perVal/5);
             }
           })
           .resultThen((flow,result) ->
               System.out.println("total is"+result))
           .catchThen((flow,e) ->
               System.out.println(e.getMessage()))
            .finallyThen((flow,await) -> 
               System.out.println("this is flow end")).start();

切換執行緒

使用flow on方法可以切換執行緒，on傳遞一個Converter引數，代表下個流切換。如果兩個Converter引數，代表當前流和下個流都切換執行緒。當然你也可以實現Converter介面來實現其他功能。

Flow.create((FirstEvent<Integer>) (flow,await) ->
            await.exec(0))
           .on(AndroidMain.get(),SingleThread.get())  
           .then((Event<Integer,await) ->{
             if(perVal == 0){
               flow.throwException("Dividend cannot be 0!");
             }else{
               await.exec(perVal/5);
             }
           })
           .on(AndroidMain.get())
           .resultThen((flow,result) ->
               System.out.println("total is"+result))
           .on(AndroidMain.get())
           .catchThen((flow,e) ->
               System.out.println(e.getMessage()))
           .on(SingleThread.get())
           .finallyThen((flow,await) ->
               System.out.println("this is flow end")).start();

Collection結果轉換成多個流

Flow.each((FirstEvent<List<String>>) (flow,await) -> {
          ArrayList<String> list = new ArrayList<>();
          list.add("1");
          list.add("2");
          list.add("3");
          await.exec(list);
        }).then((LastEvent<String>) (flow,s,await) -> {
          System.out.println("this is"+s);
        }).start();

多個流結果轉換成一個流

 Flow.merge((flow,await) -> await.exec(1),(flow,await) -> await.exec(2),await) -> await.exec(2)).resultThen((flow,result)
            -> System.out.println"result"+result)).start();

條件選擇

根據條件判斷重新發起Flow流（返回引數可以不一樣）

 Flow.create((NoneEvent) (flow,await) ->{
          System.out.println("start");
          await.exec();
        })
         .on(SingleThread.get())
         .conditionThen((VoidCondition) () -> false,Flow.create((NoneEvent) (flow,await) -> {
                  System.out.println("this is true");
                  await.exec();
                }),await) -> {
                  System.out.println("this is false");
                  await.exec();
                })).start();

根據條件判斷執行Flow流，可以合併到一起。（返回引數必須一致）

Flow.condition2(() -> isGo,(FirstEvent<Integer>) (flow,await) -> {
          System.out.println("this is true");
          await.exec(1);
        },await) -> {
          System.out.println("this is false");
          await.exec(0);
        }).resultThen((flow,result) -> System.out.println("result"+result))
            .watch(this).start();

生命週期解綁

通過flow watch方法。被觀察者必須實現ILifeObservable介面。

 Flow.create((FirstEvent<Integer>) (flow,await) ->await.exec(0)) 
   .watch(this).start();

總結

框子也裡面提供了一些簡化的類，也可以和專案網路請求框架抽象自己的Event,這樣和js的網路的then就幾乎一樣了。後續根據實際需求再做調整，試驗中。

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支援我們。