dotnet 读 WPF 源代码 聊聊 DispatcherTimer 的实现
本文来告诉大家在 wpf 框架里面，是如何实现 dispatchertimer 的功能。有小伙伴告诉我，读源代码系列的博客看不动，原因是太底层了。我尝试换一个方式切入逻辑，通过提问题和解决问题的方法，一步步告诉大家 wpf 是如何实现 dispatchertimer 的功能
假定咱是 wpf 框架的开发者（虽然我就是，尽管是格式化代码工程师）咱需要实现一个 dispatchertimer 的功能，请问可以如何写呢
在 windows 上有很多方式来实现计时器的功能，但是 dispatchertimer 和其他的计时器有一点不同的在于，毕竟这是 dispatcher 的，看到 dispatcher 就可以了解到，这是一个需要在主线程执行的定时器
在那么如何在定时器里面回到主线程呢？假定咱现在啥都没有，毕竟咱现在是在从零开发 wpf 框架的，那有什么可以使用呢？在 windows 上提供了 settimer 这个放在 user32.dll 的函数，通过这个 win32 方法可以调用 windows 提供的底层定时器的功能
写过 win32 代码的小伙伴就知道，如果直接使用 win32 的方法，无论是参数还是需要了解的知识都是非常多的。作为一个有追求的框架，咱肯定是需要再做一层封装，让调用更加简单。回到 settimer 这个 win32 函数的功能上，咱可以调用 settimer 给定一个窗口句柄以及计时的时间，接下来 windows 将会定时发送 wm_timer 给到咱的窗口
假定咱已经有了接收窗口消息的统一入口，接受窗口调度的模块的功能就是调度执行，也就是 dispatcher 的一个功能。那不妨就将 wm_timer 的处理也放在 dispatcher 里面吧。刚好咱选用的 settimer 是发送窗口消息，自然就是被主线程收到了，咱也就不需要去尝试解决后台线程的计时器需要调度到主线程
对于上层的 api 封装呢？给开发者使用的计时器肯定是需要封装一个类，那就叫 dispatchertimer 好了。至于 dispatchertimer 里面有哪些 api 呢，就抄 wpf 的设计好了
这里有一个问题是，假定我使用的是 dispatchertimer 有多个，我使用其中的一个 dispatchertimer 通过 settimer 这个 win32 函数进行定时，在 dispatcher 收到 wm_timer 消息时，如果知道是需要调用哪个 dispatchertimer 来执行？
通过分析需求，事实上这个问题不好解决，因为 win32 的 wm_timer 消息是不会告诉咱这个消息是被哪个逻辑调用的 settimer 方法调用的，不能通过 wm_timer 获取 dispatchertimer 对象
但是从需求分析，其实咱不需要关注收到消息对应的是哪个 dispatchertimer 对象，因为 dispatchertimer 对象的功能是执行 tick 事件，而只要是时间刚好到达，就需要执行 tick 事件了。为了实现此功能，咱也就需要有一个集合用来管理当前主线程所有的 dispatchertimer 对象，用来了解在收到 wm_timer 需要调用的 dispatchertimer 对象有哪些
这个 dispatchertimer 集合为了方便调用管理，不妨先放在 dispatcher 类里面，毕竟一个线程就刚好有一个 dispatcher 对象
public sealed class dispatcher
{
private list<dispatchertimer> _timers = new list<dispatchertimer>();
internal void addtimer(dispatchertimer timer)
{
lock(_instancelock)
{
// 忽略代码
_timers.add(timer);
}
// 忽略代码
}
}
那在啥时候需要调用 addtimer 呢？在 dispatchertimer 对象创建的时候？如果我只是创建一个空的 dispatchertimer 对象，这个对象啥都不干，好像加入到 dispatcher 的 _timers 也不合适。不如就在 dispatchertimer 启动的时候添加
public class dispatchertimer
{
public void start()
{
lock(_instancelock)
{
if(!_isenabled)
{
_isenabled = true;
_dispatcher.addtimer(this);
}
}
}
private dispatcher _dispatcher;
private bool _isenabled;
// 忽略代码
}
在收到 wm_timer 事件，就需要 dispatcher 去遍历所有的 dispatchertimer 对象，看哪个对象当前需要被执行了。为了了解哪个 dispatchertimer 需要被执行，就需要让 dispatchertimer 记录两个信息，一个是距离下次执行的时间和调用执行 start 函数的时间。通过判断调用 start 的时间加上距离下次执行的时间是否小于或等于当前的时间，就可以判断当前的 dispatchertimer 是否需要执行
咱来加一点代码在 dispatchertimer 里面，在启动时记录时间
public void start()
{
lock(_instancelock)
{
if(!_isenabled)
{
_isenabled = true;
_dispatcher.addtimer(this);
_starttime = datetime.now;
}
}
}
private datetime _starttime;
private timespan _interval;
作为一个追求性能的框架，自然咱需要在每个地方都追求一下性能，例如获取当前时间，是否有更快的方法？通过 environment.tickcount 属性可以获取更快的时间，使用 environment.tickcount 获取的是毫秒数，表示的是开机到当前的时间，相对来说抽象一点，不过也刚好不会受到用户修改当前系统时间的影响，自然也就更稳定一些啦
既然都使用 environment.tickcount 了，不如将 判断调用 start 的时间加上距离下次执行的时间 合在一起计算吧，这样后续每次 wm_timer 消息过来的时候，就不用每次都做一次加法了，直接判断值的大小即可
public void start()
{
lock(_instancelock)
{
if(!_isenabled)
{
_isenabled = true;
_dispatcher.addtimer(this);
// 如果只是记录当前调用 start 方法的时间，也就是 environment.tickcount 时间。那么后续收到 wm_timer 消息，都需要判断当前时间加上 _interval 的时间之后是否小于等于当前的时间。而这个加法计算是每次都需要调用的，为了性能优化，不如一开始就加上，后续就只需要判断大小
_duetimeinticks = environment.tickcount + (int) _interval.totalmilliseconds;
}
}
}
// 删除 datetime 的定义，因为获取的性能不够，而且用户也许修改系统时间
// private datetime _starttime;
private timespan _interval;
// 用这个代替 datetime 的方法，单位是毫秒。其实字段从规范来说是不应该 internal 公开的，然而在 wpf 里面，古老的开发者为了减少改动就公开了这个字段
internal int _duetimeinticks; // used by dispatcher
在 dispatcher 里面就可以通过 dispatchertimer 的 _duetimeinticks 字段和当前的时间比较大小而决定是否触发 dispatchertimer 的事件。从规范的角度来说，是不能公开 dispatchertimer 的 _duetimeinticks 字段的，然而在 wpf 里面，古老的开发者为了减少改动就公开了这个字段
在 dispatcher 里面的代码如下
public sealed class dispatcher
{
private list<dispatchertimer> _timers = new list<dispatchertimer>();
private intptr wndprochook(intptr hwnd, int msg, intptr wparam, intptr lparam, ref bool handled)
{
windowmessage message = (windowmessage) msg;
// 忽略代码
if(message == windowmessage.wm_timer && (int) wparam == timerid_timers)
{
// 忽略代码
promotetimers(environment.tickcount);
}
}
internal void promotetimers(int currenttimeinticks)
{
dispatchertimer timer = null;
int itimer = 0;
var timersversion = _timersversion;
do
{
lock(_instancelock)
{
timer = null;
// if the timers collection changed while we are in the middle of
// looking for timers, start over.
if(timersversion != _timersversion)
{
// 如果在循环过程，有其他逻辑加入了 _timers 的元素，意味着 _timers 的数量变更了
// 需要重新开始
timersversion = _timersversion;
itimer = 0;
}
while(itimer < _timers.count)
{
// warning: this is vulnerable to wrapping
if(_timers[itimer]._duetimeinticks - currenttimeinticks <= 0)
{
timer = _timers[itimer];
// 忽略代码
break;
}
else
{
itimer++;
}
}
}
// now that we are outside of the lock, promote the timer.
if(timer != null)
{
timer.promote();
}
} while(timer != null);
}
}
以上判断是通过 _timers[itimer]._duetimeinticks - currenttimeinticks <= 0 决定是否当前的 timer 需要执行。因为 _timers[itimer]._duetimeinticks - currenttimeinticks <= 0 等价于 _timers[itimer]._duetimeinticks <= currenttimeinticks 也就是在 dispatchertimer 下次执行的时间，小于或等于当前的时间，这个 dispatchertimer 就应该被执行。因为相同的时间需要执行的 dispatchertimer 也许有多个，因此就做了两重循环。而同时为了解决在 dispatchertimer 执行过程，也许有其他逻辑再加入新的 dispatchertimer 因此也就需要判断一下 _timersversion 当前版本适合和进入的版本相同，如果不同，就证明有其他逻辑更改了集合，需要重新开始
从上面代码可以看到，咱判断 dispatchertimer 是否需要被执行，如果需要执行，调用 dispatchertimer 的 promote 方法进行执行，最简单的方法执行就是通过调用 tick 事件触发，简单的代码如下
private void firetick()
{
// 忽略代码
if(tick != null)
{
tick(this, eventargs.empty);
}
}
internal void promote() // called from dispatcher
{
firetick();
}
既然所有的 dispatchertimer 都被 dispatcher 放在一起，那是否可以共用一个 win32 的计时器，不需要每个 dispatchertimer 都独立调用。如上面的代码，其实都是在判断统一的时间，不需要多个 win32 计时器也能实现效果
只需要有一个 win32 计时器，定时是当前的 dispatchertimer 里面最短的时间，就可以实现多个 dispatchertimer 使用相同的一个 win32 计时器。那这个逻辑可以放在哪呢？是否还记得咱在启动计时器时加入到 dispatcher 里面，既然咱期望多个 dispatchertimer 使用相同的一个 win32 计时器，不妨找到一对多的关系，刚好这里的一就是 dispatcher 类，这里的多就是 dispatchertimer 类。 因此这个 win32 计时器的管理，放在 dispatcher 里面就刚好。启动或者重新设置 win32 计时器可以放在 dispatcher 的 addtimer 方法里面
public sealed class dispatcher
{
private list<dispatchertimer> _timers = new list<dispatchertimer>();
private long _timersversion;
internal void addtimer(dispatchertimer timer)
{
lock(_instancelock)
{
_timers.add(timer);
_timersversion++;
}
updatewin32timer();
}
}
在加入 addtimer 调用 updatewin32timer 更新计时器时间，原因是如果我原有一个是定时是 10 秒的计时器在启动了。接下来运行了 5 秒，我再加入一个需要等 1 秒的计时器，那么原有的 win32 计时器是不是就需要更新一下时间？从原来的等待 10 秒，判断距离现在还有 5 秒才执行，而新加入的等待 1 秒的计时器，在接下来的 1 秒就需要执行，那么就需要更新 win32 计时器，修改定时时间
而如果原有一个是定时是 10 秒的计时器在启动了。接下来运行了 9 秒，我再加入一个需要等 3 秒的计时器，显然新加入的计时器还需要等待 3 秒才执行，而原有的计时器，只需要再等待 1 秒就足够 10 秒了，可以执行。此时的 win32 计时器自然是不需要重新启动的
似乎上面的逻辑稍微有一点绕，但是看起来代码也是很简单的
public sealed class dispatcher
{
private int _duetimeinticks;
private bool _duetimefound;
internal void updatewin32timer() // called from dispatchertimer
{
bool oldduetimefound = _duetimefound;
int oldduetimeinticks = _duetimeinticks;
_duetimefound = false;
_duetimeinticks = 0;
if(_timers.count > 0)
{
// we could do better if we sorted the list of timers.
for(int i = 0; i < _timers.count; i++)
{
dispatchertimer timer = _timers[i];
if(!_duetimefound || timer._duetimeinticks - _duetimeinticks < 0)
{
_duetimefound = true;
_duetimeinticks = timer._duetimeinticks;
}
}
}
if(_duetimefound)
{
if(!_iswin32timerset || !oldduetimefound || (oldduetimeinticks != _duetimeinticks))
{
setwin32timer(_duetimeinticks);
}
}
else if(oldduetimefound)
{
killwin32timer();
}
}
}
大概这样就算完成了 dispatchertimer 的核心实现了，不过此时让咱去天台将性能优化组救下。性能优化组说如果有连续的多个 dispatchertimer 在执行，此时界面上就卡不动了。因为咱上面的代码，多个 dispatchertimer 执行之间是没有切换调度的，也就是说刚好有多个 dispatchertimer 都在执行，那么主线程的资源都在去处理其他业务逻辑里，没有资源去处理界面渲染等
产品大佬也加了需求，要求在 dispatchertimer 可以加入优先级，优先级相等于 dispatcher 的优先级，于是咱的逻辑代码也需要改改
在 dispatchertimer 的 promote 方法里面，看起来不能调用 firetick 开始执行代码逻辑，而是需要有优先级调度，也需要有切换调度，不能将全部的 dispatchertimer 一次性执行。最简单的方法自然就是 dispatcher.invokeasync 等方法来实现优先级调度等功能
产品大佬的需求实现了，但性能优化组还在天台上，咱还需要再优化一下。既然都将 dispatchertimer 加入到 dispatcher 里面了，那为什么还需要 dispatcher.invokeasync 调度呢？最简单的方法就是在 dispatchertimer 启动的时候，将任务加入到 dispatcher 里面，但是设置优先级为不执行。当 dispatchertimer 的 promote 调用时，设置刚才的加入的任务的优先级为 dispatchertimer 的执行优先级，自然就会被 dispatcher 进行调度了
public class dispatchertimer
{
public dispatchertimer(dispatcherpriority priority) // note: should be priority
{
_priority = priority;
}
private void start()
{
lock(_instancelock)
{
if (_operation != null)
{
// timer has already been restarted, e.g. start was called form the tick handler.
return;
}
// begininvoke a new operation.
_operation = _dispatcher.begininvoke(
dispatcherpriority.inactive,
new dispatcheroperationcallback(firetick),
null);
_duetimeinticks = environment.tickcount + (int) _interval.totalmilliseconds;
_dispatcher.addtimer(this);
}
} // 这确实是 wpf 的格式化，这是花括号前面没有空格
internal void promote() // called from dispatcher
{
lock(_instancelock)
{
// simply promote the operation to it's desired priority.
if(_operation != null)
{
_operation.priority = _priority;
}
}
}
private object firetick(object unused)
{
if(tick != null)
{
tick(this, eventargs.empty);
}
return null;
}
private dispatcherpriority _priority; // note: should be priority
}
通过上面的代码，性能优化组从天台上下来了，但产品大佬又说，有一些用户喜欢在 tick 里面里面将 dispatchertimer 停下，而以上的代码，其实咱没有实现停下的功能，刚好两个功能一起做
在 dispatchertimer 里面定义 isenabled 属性，咱需要支持在 isenabled 里面进行赋值从而进行停止或启动计时器
public class dispatchertimer
{
/// <summary>
/// gets or sets whether the timer is running.
/// </summary>
public bool isenabled
{
get
{
return _isenabled;
}
set
{
lock(_instancelock)
{
if(!value && _isenabled)
{
stop();
}
else if(value && !_isenabled)
{
start();
}
}
}
}
private bool _isenabled;
}
既然有不断的开启和停止，那不如就再加一个 restart 方法好了，让 start 方法调用 restart 方法
public class dispatchertimer
{
public void start()
{
lock(_instancelock)
{
if(!_isenabled)
{
_isenabled = true;
restart();
}
}
}
private void restart()
{
lock(_instancelock)
{
if (_operation != null)
{
// timer has already been restarted, e.g. start was called form the tick handler.
return;
}
// begininvoke a new operation.
_operation = _dispatcher.begininvoke(
dispatcherpriority.inactive,
new dispatcheroperationcallback(firetick),
null);
_duetimeinticks = environment.tickcount + (int) _interval.totalmilliseconds;
_dispatcher.addtimer(this);
}
}
}
那 stop 方法呢？其实就是从 dispatcher 队列里面干掉 _operation 对象
public class dispatchertimer
{
public void stop()
{
if(_operation != null)
{
_operation.abort();
_operation = null;
}
}
}
当然了，如果当前计时最短就是当前的被 stop 的 dispatchertimer 那还需要更新一下 win32 的计时器时间。例如当前已设置了最短的计时是 1 秒的 dispatchertimer 被 stop 了，而后续的 dispatchertimer 是再等 5 秒，此时就需要修改 win32 的计时器，关闭等待 1 秒的计时器，再开启等待 5 秒的计时器。另外咱将 dispatchertimer 加入到 dispatcher 的一个集合里面，自然就需要在 stop 里面移除，否则将会让 dispatchertimer 对象无法释放
咱更改 stop 方法，加上告诉 dispatcher 的方法
public class dispatchertimer
{
public void stop()
{
bool updatewin32timer = false;
lock(_instancelock)
{
if(_isenabled)
{
_isenabled = false;
updatewin32timer = true;
// if the operation is in the queue, abort it.
if(_operation != null)
{
_operation.abort();
_operation = null;
}
}
}
if(updatewin32timer)
{
_dispatcher.removetimer(this);
}
}
}
在 dispatcher 的里面，先从集合里面将 dispatchertimer 移除。当然，从这里也可以看到，即使在业务代码里面没有对 dispatchertimer 进行引用，但是只要这个 dispatchertimer 还在运行，那么 dispatchertimer 的对象就不会被释放。接着在 dispatcher 更新计时器
public sealed class dispatcher
{
internal void removetimer(dispatchertimer timer)
{
lock(_instancelock)
{
if(!_hasshutdownfinished) // could be a non-dispatcher thread, lock to read
{
_timers.remove(timer);
_timersversion++;
}
}
updatewin32timer();
}
}
再接下来，产品大佬告诉咱，加需求。可以让开发者修改 dispatchertimer 的计时时间，在修改 interval 属性时，需要咱自己去更新 dispatcher 的计时器
在 isenabled 开启时，如果用户修改 interval 属性，那么需要告诉 dispatcher 更新计时器。而如果没有开启计时器，那更新 dispatcher 做什么
public class dispatchertimer
{
/// <summary>
/// gets or sets the time between timer ticks.
/// </summary>
public timespan interval
{
get
{
return _interval;
}
set
{
bool updatewin32timer = false;
lock(_instancelock)
{
_interval = value;
if(_isenabled)
{
_duetimeinticks = environment.tickcount + (int)_interval.totalmilliseconds;
updatewin32timer = true;
}
}
if(updatewin32timer)
{
_dispatcher.updatewin32timer();
}
}
}
private timespan _interval;
}
当然了，作为对外公开的 api 还需要判断一下调皮的用户的行为。如果传入的时间是负数呢？如果传入的时间太长了，例如超过 int 的 maxvalue 也就是说这个 dispatchertimer 是不执行的吧，是不是就需要告诉用户
public timespan interval
{
set
{
bool updatewin32timer = false;
if (value.totalmilliseconds < 0)
throw new argumentoutofrangeexception("value", sr.get(srid.timespanperiodoutofrange_toosmall));
if (value.totalmilliseconds > int32.maxvalue)
throw new argumentoutofrangeexception("value", sr.get(srid.timespanperiodoutofrange_toolarge));
// 忽略代码
}
}
产品大佬还说，咱的 dispatchertimer 是允许在后台线程启动的，毕竟不想让用户需要写 dispatcher 调度到主线程再开启 dispatchertimer 计时，允许在后台线程开启。如上面代码，其实咱加了很多锁了，问题也不大。这部分逻辑实现太简单了，这里就不告诉大家了
以上大概就是 dispatchertimer 的核心逻辑，可以看到 dispatchertimer 里面的细节还是很多的。实际的 wpf 代码里面也有很多细节部分是本文没有告诉大家的，还请大家自己去阅读 wpf 源代码
更多 dispatchertimer 请看： wpf 如何知道当前有多少个 dispatchertimer 在运行
当前的 wpf 在 完全开源，使用友好的 mit 协议，意味着允许任何人任何组织和企业任意处置，包括使用，复制，修改，合并，发表，分发，再授权，或者销售。在仓库里面包含了完全的构建逻辑，只需要本地的网络足够好（因为需要下载一堆构建工具），即可进行本地构建
上一篇： PyTorch学习笔记01: PyTorch基本概念
下一篇： 是否包含中文