任務(wù)分步

一個(gè)簡(jiǎn)單任務(wù)可以拆分成多個(gè)執(zhí)行步驟（step），由不同的執(zhí)行器（handler）按順序執(zhí)行。前置步驟成功完成后才開始執(zhí)行下一個(gè)步驟。

例如，“對(duì)賬”任務(wù)的處理步驟是：下載銀行的清算文件 > 根據(jù)約定格式解析文件 > 文件數(shù)據(jù)與機(jī)構(gòu)日間交易數(shù)據(jù)核對(duì) > 結(jié)果處理（差錯(cuò)賬生成及處理）。每一個(gè)步驟可以由對(duì)應(yīng)的 handler 單獨(dú)執(zhí)行。

任務(wù)分片

任務(wù)分片功能適用于執(zhí)行時(shí)間很長(zhǎng)的任務(wù)。當(dāng)數(shù)據(jù)量很大時(shí)，任務(wù)調(diào)度系統(tǒng)支持在單個(gè)執(zhí)行步驟中把數(shù)據(jù)拆分成多個(gè)分片（data chunk），把一個(gè)任務(wù)的數(shù)據(jù)分散到不同的機(jī)器上運(yùn)行。

一個(gè)數(shù)據(jù)分片只由一個(gè)線程執(zhí)行。多個(gè)數(shù)據(jù)分片可以在多臺(tái)機(jī)器上調(diào)度執(zhí)行，也可以在一臺(tái)機(jī)器的多個(gè)線程上調(diào)度執(zhí)行，具體調(diào)度方式由調(diào)度中心根據(jù)負(fù)載進(jìn)度進(jìn)行調(diào)整。

使用任務(wù)分片可以縮短任務(wù)執(zhí)行時(shí)間，同時(shí)也可以解決單機(jī)計(jì)算能力上限的問(wèn)題，并降低部分任務(wù)失敗對(duì)整體系統(tǒng)的影響。

任務(wù)拓?fù)?/h2>

任務(wù)拓?fù)洌═opology）是由許多通過(guò)事件觸發(fā)的任務(wù)的集合，描述了任務(wù)依賴關(guān)系。子任務(wù)可以并發(fā)執(zhí)行或根據(jù)條件執(zhí)行。任務(wù)拓?fù)渲械娜蝿?wù)執(zhí)行流程均從開始節(jié)點(diǎn)開始，到結(jié)束節(jié)點(diǎn)終止，任務(wù)的執(zhí)行流程形成一張有向無(wú)環(huán)圖。