任务调度类图

Pipeline

+addFirst() : Pipeline+addLast() : Pipeline+fireActive() : void+fireInActive() : void

AbstractPipeline

-logger : Logger -ctxHandlers : ConcurrentHashMap

+addFirst() : Pipeline+addLast() : Pipeline+fireActive() : void+checkDuplicateName() : void+fireInActive() : void

TaskWrapperHandler

-logger : Logger

+handle() : void

TaskRouterHandler

-gson : Gson-logger : Logger -cacheService : CacheService

+getDepartureTime() : void+handle() : void+chooseAvailableDates() : List+isFutureSaleDay() : void+turnTask2Suspend() : void+caculateMinDepartureTime() : String

TaskFrontierHandler

-gson : Gson-logger : Logger

+generateTaskInfoInRedis() : void+handle() : void+genrateTaskDatesInRedis() : void+turnTask2Todo() : void

AbstractTaskScheduler

-logger : Logger -taskHandlerConfig : TaskHandlerConfig-cacheService : CacheService-taskRouterHandler : TaskRouterHandler-gson : Gson-workStart : String-workEnd : String-taskWrapperHandler : TaskWrapperHandler-taskCloneHandler : TaskCloneHandler

+buildBaseTaskConfigurable() : TaskConfigurable+generateTask() : Task+consume() : Task+buildTask() : Task+handleConsumeSuccess() : void+handleConsumeFail() : void+intercept() : boolean+waitForTask() : void

Handler

+process() : void

AbstractHandler

-ctx : AbstractHandlerContext

+process() : void+handle() : void

IScheduler

+startProcess() : void+stopProcess() : void

TaskAwakeScheduler

+buildTask() : Task+handleStart() : void+setHandlerConfig() : void+setWorkerThreadCnt() : void+generateTaskKey() : String

AbstractScheduler

-logger : Logger -workerThreadCnt : int-isStop : boolean-workThreads : List

+startProcess() : void+run() : void+generateTask() : E+consume() : E+handleConsumeSuccess() : void+handleConsumeFail() : void+intercept() : boolean+waitForTask() : void

TaskAcceptorScheduler

+buildTask() : Task+handleStart() : void+setHandlerConfig() : void+setWorkerThreadCnt() : void