量化交易系統任務框架的演化之路（2）狀態管理

通過這個流程圖就可以很明顯的看出，重入的問題一下子就解決了。道理明白了，那麼實現起來就很簡單了。直接把框架**放這裡，供參考。

通過註解來表示是否為要管理的任務，在這裡指定了乙個屬性name，管理容器可以很方便通過這個名字找到對應任務例項，完成一系列的操作。

@target()
@retention(retentionpolicy.runtime)
@component
public @inte***ce
quantmanagedtask

下面這個類是所有任務的基類，裡面包含了任務的框架方法，start方法用來啟動任務，啟動時會檢查當前任務的狀態，如果沒有在執行則啟動，否則直接跳過；stop方法用來停止任務。

public
abstract
class
quanttask 
// 實際的任務內容
public
abstract
void
dotask();
/*** 停止當前任務，改變狀態
*/public
void
stop()
/*** 獲取任務是否在執行中
*/public
boolean
isrunning()
}

下面就是任務的管理容器，容器負責任務的啟動和結束。在系統啟動時，會將所有通過註解標註和繼承了quanttask的任務類預先載入進來，建立任務名稱和任務例項對應的map，那麼就可以很容易的通過名字找到相應的任務例項。

@component
public
class
quanttaskmanager
implements
beanpostprocessor
@override
public object postprocessafterinitialization(object bean, string s) throws bean***ception catch (exception e)
}return bean;
}public
void
execute(string taskname) 
}

下面這個就是乙個示例任務類，可以直接通過其名字sample_task啟動它。

@quantmanagedtask(name="sample_task")
public
void samplequanttask extends quanttask()
}

增加了管理容器，我們就可以很容易的實現在頁面上對任務進行管理的功能。當然了，這裡只是通過乙個isrunning欄位解決了最簡單的狀態，可是有很多時候，狀態可能更加複雜，尤其是在通過頁面管理時，可能還要什麼時候執行過、現在是什麼狀態等等。

現在還有乙個任務依賴的問題還沒有解決，那麼如果基於上面的設計，應該如何去解決呢？

量化交易系統任務框架的演化之路（2）狀態管理

量化交易系統（一）資金管理

量化交易系統行情模擬回放系統設計 16

開源分布式量化交易系統初識ZeroMQ

量化交易系統任務框架的演化之路（2）狀態管理

量化交易系統（一）資金管理

量化交易系統 行情模擬回放系統設計 16

開源分布式量化交易系統 初識ZeroMQ

相關推薦

量化交易系統行情模擬回放系統設計 16

開源分布式量化交易系統初識ZeroMQ