C#开发WPF程序中的弱事件模式
作者:天方 发布时间:2022-11-21 12:50:34
在C#中,得益于强大的GC机制,使得我们开发程序变得非常简单,很多时候我们只需要管使用,而并不需要关心什么时候释放资源。但是,GC有的时并不是按照我们所期望的方式工作。
例如,我想实现一个在窗口的标题栏中实时显示当前的时间,一个比较常规的做法如下:
var timer = new DispatcherTimer() { Interval = TimeSpan.FromSeconds(1) };
timer.Tick += (_s, _e) => this.Title = DateTime.Now.ToString();
timer.Start();
这种做法看起来非常简单而直接,它也确实能老老实实按照我们所设计的那样在窗口中实时显示并更新时间。但是,有经验的程序员们就知道,这里存在一个隐患:这个窗口永远不会释放。比较简单的验证方式是:手动关闭窗口,调用GC.Collect()函数,发现析构函数是不会调用的。
可能有的人会问了:不是有万能的GC嘛,为什么这个窗口不会释放?究其原因也非常简单,DispatchTimer的Tick事件中包含了对Window的引用,当窗口关闭时,DispatchTimer仍然在执行,因此Window就得不到释放。
知道了原因后,要解决也不难:在Window的关闭事件中,停止Timer的调用即可。这种方式确实行之有效,但显得不大优雅,感觉回到了要手动控制申请和释放的C语言年代,没有了GC自动管理下的"管杀不管埋"的便捷感觉。 那么,有没有一种我们只管使用,而不管释放的方案呢,答案就是弱事件模式。
在弱事件模式下,事件委托只保留对象的弱引用,这样GC仍然能将该对象给回收掉。例如,对于上述代码,可以修改如下:
var timer = new DispatcherTimer() { Interval = TimeSpan.FromSeconds(1) };
WeakEventManager<DispatcherTimer, EventArgs>.AddHandler(timer, "Tick", (_s, _e) => this.Title = DateTime.Now.ToString());
timer.Start();
由于Timer没有保存Window的强引用,当Windows关闭后,是会被GC回收掉的。
现在看起来没有什么问题了,不过,敏感的程序员们会发现,这里还存在一个隐患:DispatchTimer没有释放。虽然我们没有保存Timer的引用,但为了避免其被GC回收,内部仍然会维持其引用,必须显式停止。这里我们仍然可以利用弱事件模式,在感知到回调对象被释放时,手动停止Timer。要实现这个方法,必须我们实现自己的弱事件管理器:
public class DispatcherTimerManager : WeakEventManager
{
public static void Create(TimeSpan interval, EventHandler<EventArgs> handler)
{
var dispatcherTimer = new DispatcherTimer() { Interval = interval };
DispatcherTimerManager.AddHandler(dispatcherTimer, handler);
dispatcherTimer.Start();
}
public static void AddHandler(DispatcherTimer source, EventHandler<EventArgs> handler)
{
current.ProtectedAddHandler(source, handler);
}
public static void RemoveHandler(DispatcherTimer source, EventHandler<EventArgs> handler)
{
current.ProtectedRemoveHandler(source, handler);
}
static DispatcherTimerManager current;
static DispatcherTimerManager()
{
current = new DispatcherTimerManager();
SetCurrentManager(typeof(DispatcherTimerManager), current);
}
protected override ListenerList NewListenerList()
{
return new ListenerList<EventArgs>();
}
protected override void StartListening(object source)
{
var timer = (DispatcherTimer)source;
timer.Tick += OnSomeEvent;
}
protected override void StopListening(object source)
{
var timer = (DispatcherTimer)source;
timer.Tick -= OnSomeEvent;
timer.Stop();
}
void OnSomeEvent(object sender, EventArgs e)
{
DeliverEvent(sender, e);
}
}
代码比较简单:当感知到回调对象被释放时,会执行StopListening函数我们只需要重写改函数,加入停止Timer操作即可。同样,我们也可以基于弱事件模式实现一个IObservable的自动管理类:
public static class ObservableDispatcher
{
public static void AddHandler<T>(IObservable<T> source, EventHandler<DataEventArgs<T>> handler)
{
if ( Application.Current.Dispatcher != Dispatcher.CurrentDispatcher)
throw new InvalidOperationException("需要在主线程上调用");
AnymousDispatcher<T>.AddHandler(source, handler);
}
public static void RemoveHandler<T>(IObservable<T> source, EventHandler<DataEventArgs<T>> handler)
{
AnymousDispatcher<T>.RemoveHandler(source, handler);
}
class AnymousDispatcher<T> : WeakEventManager
{
public static void AddHandler(IObservable<T> source, EventHandler<DataEventArgs<T>> handler)
{
var wrapper = new ObservableEventWrapper<T>(source);
current.ProtectedAddHandler(wrapper, handler);
}
public static void RemoveHandler(IObservable<T> source, EventHandler<DataEventArgs<T>> handler)
{
var wrapper = new ObservableEventWrapper<T>(source);
current.ProtectedRemoveHandler(wrapper, handler);
}
static AnymousDispatcher<T> current;
static AnymousDispatcher()
{
current = new AnymousDispatcher<T>();
SetCurrentManager(typeof(AnymousDispatcher<T>), current);
}
protected override ListenerList NewListenerList()
{
return new ListenerList<DataEventArgs<T>>();
}
protected override void StartListening(object source)
{
var wrapper = source as ObservableEventWrapper<T>;
wrapper.OnData += wrapper_OnData;
}
void wrapper_OnData(object sender, DataEventArgs<T> e)
{
DeliverEvent(sender, e);
}
protected override void StopListening(object source)
{
var wrapper = source as ObservableEventWrapper<T>;
wrapper.OnData -= wrapper_OnData;
wrapper.Dispose();
}
}
class ObservableEventWrapper<T> : IDisposable
{
IDisposable disposeHandler;
public ObservableEventWrapper(IObservable<T> dataSource)
{
disposeHandler = dataSource.Subscribe(onData);
}
void onData(T data)
{
OnData(this, new DataEventArgs<T>(data));
}
public event EventHandler<DataEventArgs<T>> OnData;
public void Dispose()
{
disposeHandler.Dispose();
}
}
}
限制:
弱事件模式非常有用,但不知道为什么微软将其限制在了WPF框架中了,从其实现上来看,应该是在UI线程上调用,但在MSDN上也没有找到其限制的说明。我试过在非UI线程上调用它,也是弱事件,但是不能触发StopListening函数。不知道这样有没有什么影响,但最好还是在UI线程上调用它。
来源:https://www.cnblogs.com/TianFang/p/3424427.html
![](https://www.aspxhome.com/images/zang.png)
![](https://www.aspxhome.com/images/jiucuo.png)
猜你喜欢
- 投篮小游戏规则,点击投篮目标点,就会有一个球沿着相关抛物线,然后,判断是否进入篮子里,其实就是一个矩形,直接是按照碰撞检测来的,碰到就算进去
- 1、public String(char[] c,begin,length).从字符数组c的下标begin处开始,将长度为length的字符
- 最终效果如下大概就几个步骤1.安装 Docker CE 2.运行 Redis 镜像 3.Java 环境准备 4.项目准备 5.编写 Dock
- Mybatis条件if test使用枚举值1.正确package com.weather.weatherexpert.common.util
- 开篇:我们将前面的springboot整合H2内存数据库,实现单元测试与数据库无关性提供的Restful服务注册到spring cloud的
- 一、数组的基本用法1.什么是数组数组:存储一组相同数据类型的数据的集合。2.定义数组 int[] :int类型数组 do
- 一般来讲,项目更换JDK版本的情况比较少,但是有时难免会遇到。电脑安装不同版本的JDK这里不做介绍。这里记录一下修改项目JDK版本要注意的几
- 众所周知Web服务器与客户端之间的通信是使用HTTP协议的。HTTP是一个客户端和服务器端请求和应答的标准(TCP)。因为HTTP协议是基于
- 现在Web开发越来越倾向于前后端分离,前端使用AngularJS,React,Vue等,部署在NodeJS上,后面采用SpringBoot发
- Spring Cache设置缓存条件原理从Spring3.1开始,Spring框架提供了对Cache的支持,提供了一个对缓存使用的抽象,通过
- 1.例题题目描述迷宫由 n 行 m 列的单元格组成,每个单元格要么是空地,要么是障碍物。其中1表示空地,可以走通,2表示障碍物。给定起点坐标
- 在java程序开发中,ftp用的比较多,经常打交道,比如说向FTP服务器上传文件、下载文件,本文给大家介绍如何利用jakarta commo
- java的String对象底层是有字符数组存储的,理论上char[] 最大长度是int的最大值,实际思路:首先,String字面
- using System;using System.Collections.Generic;using System.ComponentMo
- 本文实例讲述了Java基于余弦方法实现的计算相似度算法。分享给大家供大家参考,具体如下:(1)余弦相似性通过测量两个向量之间的角的余弦值来度
- 通过ssh实现服务器文件上传下载写在前面的话之前记录过一篇使用apache的FTP开源组件实现服务器文件上传下载的方法,但是后来发现在删除的
- Struts2Struts2是在WebWork2基础发展而来的。和struts1一样, Struts2也属于MVC框架。不过有一点
- 之前给大家在博文中讲过如何通过eclipse快速搭建SSM开发环境,但相对而言还是有些麻烦的,今天玄武老师给大家介绍下如何使用Intelli
- mybatis 报错显示sql中有两个limit使用mybatis进行分页查询时,打印的查询sql中带有两个limit。经过审查:原因是由于
- java对象拷贝详解及实例Java赋值是复制对象引用,如果我们想要得到一个对象的副本,使用赋值操作是无法达到目的的:@Testpublic