先上一波使用方式倦微，有用過Rxjava的童鞋應該感覺很熟悉吧韵卤，里面參考了很多Rxjava里面的想法（雖然代碼完全不一樣）

TaskFlow.create()
        .with(file)
        .flatMap(new ScanPlugin() {
            @Override
            public FileNameFilter getFileNameFilter() {
                return new FileNameFilter() {
                    @Override
                    public boolean accept(String fileName) {
                        if (fileName.endsWith("XML")){
                            return true;
                        }
                        return false;
                    }
                };
            }
        })
        .doOnNext(new TransferPlugin() {
            @Override
            public String getDistPath() {
                return path;
            }
        })
        .doOnNext(new Plugin<String, Integer>() {
            private Integer mSuccess;

            @Override
            public String excute() {
                if (mSuccess>1) {
                    return "haha";
                }else {
                    return "aaaa";
                }
            }
            @Override
            public void setParameter(Integer success) {
                mSuccess = success;
            }
        })
        .start(new TaskFlow.Excuter() {
            @Override
            public void onNext(Object obj) {
                SuperLogger.e(obj);
            }

            @Override
            public void onError(Throwable e) {
                SuperLogger.e("任務出錯了");
                e.printStackTrace();
            }

            @Override
            public void onComplete() {
                SuperLogger.e("完成了");
            }
        });

做過文件掃描入庫應該都能明顯感覺到稠通，入庫流程里面有很多動作是可復用的钮科，文件的處理是多個動作的組合裤园。不同的文件可能執(zhí)行的順序不一樣，需要的執(zhí)行的動作有些不同泻肯。

TaskFlow 解決什么問題：

1渊迁、數(shù)據(jù)有了明確的流向，從上往下灶挟，上一個點的輸出是下一個點的輸入琉朽，代碼再長，一眼便知處理的流程;
2稚铣、處理步驟可以無限多箱叁，可隨意組合，每一個任務就是一個plugin惕医，強大的擴展性耕漱；

特別功能介紹：

1、掃描后的文件的List抬伺，可以通過flatMap可以拆分成一個個的單元發(fā)射給后面的任務（此處是核心）
2螟够、能獲取每個任務處理后的結果，每次處理后的結果都會傳遞給Excuter 的onNext方法
3、異常唯一出口

關鍵代碼：

1妓笙、將普通的plugin包裝成FlatPlugin若河，跟其它plugin作區(qū)分

public <R,T> TaskFlow flatMap(final Plugin<List<R>,T> plugin) {
        FlatPlugin flatPlugin = new FlatPlugin<List<R>,T>() {
            @Override
            public List<R> excute() throws Exception {
                return plugin.excute();
            }

            @Override
            public void setParameter(T t) {
                plugin.setParameter(t);
            }
        };
        flatPlugin.setPlugin(plugin);
        doOnNext(flatPlugin);
        return this;
    }

2、這個很簡單寞宫，只是將每個plugin添加到任務列表

public <R,T> TaskFlow doOnNext(Plugin<R,T> plugin) {
        if (plugin==null){
            throw new RuntimeException("Plugin 不能為空");
        }
        if (mPlugins == null) {
            mPlugins = new ArrayList<>();
        }
        mPlugins.add(plugin);
        return this;
    }

3萧福、重頭戲來了，整個任務執(zhí)行的核心辈赋。使用遞歸可以使任務flatMap個數(shù)不受限制

private void excute(Excuter excuter,List<Plugin> plugins, Object result) throws Exception {
        for (int i = 0; i < plugins.size(); i++) {
            Plugin plugin = plugins.get(i);
            plugin.setParameter(result);
            if (plugin instanceof FlatPlugin){
                List list = (List) plugin.excute();
                List<Plugin> pluginList = plugins.subList(i+1,plugins.size());//去掉flatMap之前的那些任務
                plugins = plugins.subList(0,i);//不加會造成flatMap最后一個任務會多執(zhí)行一次
                for (int j = 0; j < list.size(); j++) {
                    result=list.get(j);
                    excute(excuter,pluginList,result);
                }
            }else {
                result = plugin.excute();
                excuter.onNext(result);
            }
        }
    }

github走起