转载需注明出处：http://blog.csdn.net/minimicall?viewmode=contents
这节开始我们要开始说明另外一个模块：实时事件处理模块。
这个模块的工作是什么呢。它就是用来设置一些在特定时间需要执行的任务。比如，每天开盘的时候，你可以做一个什么动作，比如每天收盘的时候你也可以做一个动作。当然还有更为广泛的运用。
在Lean中，是开启一个单独的线程来处理这种定时任务的。
实时事件：RealTimeEvent
实时事件处理接口：IRealTimeHandler
下面我们通过代码来说明，说明都在注释里面。废话少说：
/*
* QUANTCONNECT.COM - Democratizing Finance, Empowering Individuals.
* Lean Algorithmic Trading Engine v2.0. Copyright 2014 QuantConnect Corporation.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*
*/
using System;
using QuantConnect.Logging;
namespace QuantConnect.Lean.Engine.RealTime
{
///
/// Realtime event object for holding information on the event time and callback.
/// 实时时间对象：保存时间相关的的事件信息和回调
///
public class RealTimeEvent
{
/********************************************************
* CLASS VARIABLES
*********************************************************/
// Trigger Timing
private readonly DateTime _triggerTime;//触发时间
private readonly Action _callback;//回调方法（没有参数、返回值）
private readonly bool _logging;//是否写日志
// Trigger Action
private bool _triggered;//是否已经触发
/********************************************************
* CLASS PROPERTIES
*********************************************************/
///
/// Flag indicating the event has been triggered
/// 事件是否已经触发了的标志
///
public bool Triggered
{
get { return _triggered; }
}
/********************************************************
* CONSTRUCTOR METHODS
*********************************************************/
///
/// Setup new event to fire at a specific time. Managed by a RealTimeHandler thread.
/// 设置一个新的事件，在特定的时间触发，由RealTimeHandler线程管理
///
///
Time of day to trigger this event ///
Action to run when the time passes. ///
Enable logging the realtime events /// public RealTimeEvent(DateTime triggerTime, Action callback, bool logging = false) { _triggered = false; _triggerTime = triggerTime; _callback = callback; _logging = logging; } /******************************************************** * CLASS METHODS: *********************************************************/ /// /// Scan this event to see if this real time event has been triggered. /// 扫描，检查该事件是否已经被触发 /// ///
Current real or simulation time 当前时间（真实交易或者模拟交易的时间） public void Scan(DateTime time) { if (_triggered) {//如果已经触发过，就直接返回，不需要返回了 return; } //When the time passes the trigger time, trigger the event. //如果当前时间比设定的触发时间更晚了，那么就需要触发该事件 if (time > _triggerTime) { _triggered = true;//标志为已经触发 try { if (_logging) { Log.Trace("RealTimeEvent.Scan(): Eventhandler Called: " + time.ToString("u")); } _callback();//调用回调函数 } catch (Exception err) { Log.Error("RealTimeEvent.Scan(): Error in callback: " + err.Message); } } } /// /// Reset the triggered flag. /// public void Reset() { _triggered = false; } } }
/*
* QUANTCONNECT.COM - Democratizing Finance, Empowering Individuals.
* Lean Algorithmic Trading Engine v2.0. Copyright 2014 QuantConnect Corporation.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*
*/
using System;
using System.Collections.Generic;
using QuantConnect.Packets;
namespace QuantConnect.Lean.Engine.RealTime
{
///
/// Real time event handler, trigger functions at regular or pretimed intervals
/// 实时事件处理，周期性触发回调方法，或者在设定的时间触发
///
public interface IRealTimeHandler
{
/********************************************************
* INTERFACE PROPERTIES
*********************************************************/
///
/// The real time handlers internal record of current time used to scan the events.
/// 现在的时间
///
DateTime Time
{
get;
}
///
/// List of events we're monitoring.
/// 我们监控的事件列表
///
List Events
{
get;
}
///
/// Thread status flag.
/// 本线程是否活跃
///
bool IsActive
{
get;
}
///
/// Data for the Market Open Hours Today
/// 市场交易时间
///
Dictionary MarketToday
{
get;
}
/********************************************************
* INTERFACE METHODS
*********************************************************/
///
/// Main entry point to scan and trigger the realtime events.
/// 线程入口
///
void Run();
///
/// Given a list of events, set it up for this day.
///
void SetupEvents(DateTime day);
///
/// Add a new event to the processing list
/// 增加事件
///
///
Event information void AddEvent(RealTimeEvent newEvent); /// /// Trigger a scan of the events. /// 触发事件 /// void ScanEvents(); /// /// Reset all the event flags for a new day. /// 重置所有事件标志，为新的一天 /// /// Realtime events are setup as a timespan hours since void ResetEvents(); /// /// Clear all the events in the list. /// void ClearEvents(); /// /// Set the current time for the event scanner (so we can use same code for backtesting and live events) /// 设置现在的时间 /// ///
Current real or backtest time. void SetTime(DateTime time); /// /// Trigger and exit signal to terminate real time event scanner. /// 退出该线程 /// void Exit(); } }
