说实在的,我最初打算做的事情和本文主要讨论的内容毫不相关。那时,我第一次发现我需要在.net中计算一个圆的面积,当然,首先需要一个pi(π)的精确值。system.math.pi用起来倒是很方便,但它只提供了20位的精度,我不禁为计算的精度而担心(其实21位的就可以绝对令我感到舒服)。所以和其他任何称职的程序员一样,我忘记了真正需要解决的问题,而埋头写出了一个自己喜欢的可以算出任意位小数的π值的程序。最终的结果如图1。
图1. 计算pi值的程序
耗时操作(long-running operations)的进度
虽然大多数的程序不需要计算pi的值,但是很多的程序都需要进行一些耗时的操作,比如打印、调用一个web service或者计算一位太平洋西北岸亿万富翁的利息收入。对用户来说,只要可以看到当前完成的进度,这样的等待通常还是可以接受的,甚至是一个抽身忙些其他事情的机会。所以我给我的每一个小程序都添加了一个进度条(progress bar)。我的这个计算pi值的程序所用的算法每次计算9位数字。一旦新的一组数字被计算出来,我的程序就更新textbox控件并移动progressbar来显示我们的进度。比如图2就是正在计算1000位pi值的情形(如果21位没有问题,1000位也必定更好)。
图2. 正在计算1000位pi值
下面的代码展示了pi值的数字被计算出来之后,用户界面(ui)是如何更新的:
void showprogress(string pi, int totaldigits, int digitssofar) {
_pi.text = pi;
_piprogress.maximum = totaldigits;
_piprogress.value = digitssofar;
}
void calcpi(int digits) {
stringbuilder pi = new stringbuilder("3", digits + 2);
// 显示进度
showprogress(pi.tostring(), digits, 0);
if( digits > 0 ) {
pi.append(".");
for( int i = 0; i < digits; i += 9 ) {
int ninedigits = ninedigitsofpi.startingat(i+1);
int digitcount = math.min(digits - i, 9);
string ds = string.format("{0:d9}", ninedigits);
pi.append(ds.substring(0, digitcount));
// 显示进度
showprogress(pi.tostring(), digits, i + digitcount);
}
}
}
一切进行的都很顺利,直到我在计算pi的1000位的过程中切换到了其他程序做了些什么然后再切换回来时……。我看到了图3显示的画面:
图3. 没有paint事件了
问题的根源当然在于我们的程序是单线程的。当这个线程忙于计算pi值时,就没有机会去绘制ui了。之前我之所以没有遇到这个问题是因为当我设置textbox.text属性和progressbar.value属性时,这些控件,作为设置属性操作的一部分,可以强制他们的绘画操作立即进行(尽管我注意到了progress bar的情况要比text box好一些)。然而,当我把这个程序放到后台然后再带回前台时,我需要重绘整个客户区,对窗口来说就是一个paint事件。因为当前正在处理的事件(calc按钮的click事件)返回之前其他事件是不会得到处理的,于是我们就没有机会看到更多的进度显示了。我现在需要做的就是把ui线程释放出来专做ui工作,把耗时的操作放到后台处理。为了实现这个目标,我们需要另外一个线程。
异步操作
现在我的同步click handler看起来是这样的:
void _calcbutton_click(object sender, eventargs e) {
calcpi((int)_digits.value);
}
回忆一下我们的问题是“直到calcpi返回,线程才可以从click handler返回,窗口才有机会处理paint(或其他)事件”。处理这种情况的一个方法是启动另外的线程,比如:
using system.threading;
int _digitstocalc = 0;
void calcpithreadstart() {
calcpi(_digitstocalc);
}
void _calcbutton_click(object sender, eventargs e) {
_digitstocalc = (int)_digits.value;
thread pithread = new thread(new threadstart(calcpithreadstart));
pithread.start();
}
现在,在button click事件返回之前无需再等待calcpi的完成了,我创建并启动了一个新的线程,thread.start方法将调度并启动新的线程,然后立即返回,让ui线程回到它自己的工作上来。现在如果用户和程序交互(比如放到后台,置到前台,改变窗口大小,关闭它),ui线程可以自由地处理这些事件,同时worker线程也在进行它的计算pi的工作。图4显示了两个线程工作的情形:
图4. 幼稚的多线程
你也许注意到了,我没有为worker线程的入口点——calcpithreadstart传递任何参数,而是把需要计算的位数放入一个字段(field)_digitstocalc中,调用线程的入口点,calcpi被调用。这是一种痛苦,也是我喜欢用delegate来作异步工作的一个原因。delegate支持参数,避免了我对增加一个额外的临时field和一个额外的函数而做激烈的思想斗争。
如果你对delegate(委托)不熟悉,就认为他们是调用static或instance函数的对象。在c#中它们的声明语法和函数是一样的。比如calcpi的一个委托看起来是这样的:
delegate void calcpidelegate(int digits);
一旦有了一个委托,我就可以实例化一个对象来同步调用calcpi函数:
void _calcbutton_click(object sender, eventargs e) {
calcpidelegate calcpi = new calcpidelegate(calcpi);
calcpi((int)_digits.value);
}
当然,我并不想同步调用calcpi;我想要异步调用它。然而,在我做这个之前我们需要了解一点委托的工作原理。上面的委托声明实际上声明了一个类,该类继承自一个自带有三个函数(invoke、begininvoke和endinvoke)的multicastdelegate类,像这样:
class calcpidelegate : multicastdelegate {
public void invoke(int digits);
public void begininvoke(int digits, asynccallback callback,
object asyncstate);
public void endinvoke(iasyncresult result);
}
当我先实例化一个calcpidelegate对象然后像调用函数一样调用它时,我实际上调用了他的同步invoke函数。它随后调用了我的calcpi。然而begininvoke和endinvoke是一对可以让你异步调用并收获(harvest)返回值的函数。所以,为了让calcpi在另外一个线程中运行,我需要像下面那样调用begininvoke:
void _calcbutton_click(object sender, eventargs e) {
calcpidelegate calcpi = new calcpidelegate(calcpi);
calcpi.begininvoke((int)_digits.value, null, null);
}
注意我们为begininvoke的最后两个参数传递了null。这两个参数在我们需要随后收获(harvest)函数的返回值时(endinvoke就是用来做这个的)就有用了。由于calcpi函数直接更新ui,我们仅需为这两个参数传递null。如果你对委托的细节(同步和异步)感兴趣,可以看看.net委托:一个c#睡前故事(中文翻译版)这篇文章。
到这时,我应该感到高兴。我已经在我的程序里显示耗时操作进度并保持了ui的良好交互性。
多线程安全
看起来我足够幸运(或者说不幸,看你怎么看待这些事情了)。microsoft windows(r)xp给我提供了一个非常健壮的windows forms赖以建立的windows系统底层实现。它是如此健壮,以至于优雅地帮我包揽了所有问题,即使我违反了主要的windows编程方针——不要在创建一个窗口的线程之外的线程操作这个窗口。不幸的是,不能保证其他不太健壮的windows实现不会同样优雅地给我脸色看。
问题当然是我自己造成的。回忆一下图4,我用两个线程同时访问一个窗口。然而,因为耗时操作在windows程序中是如此的普遍,以至于windows forms里的每个ui类(每一个本质上从system.windows.forms.control继承的类)都有一个可以在任何线程中安全访问的属性invokerequired。这个属性在一个线程调用控件的对象方法之前需要先封传该控件到创建这个控件的线程时返回true。我的showprogress函数中如果简单地增加一个assert就会立即显现出我上述做法的错误之处。
using system.diagnostics;
void showprogress(string pi, int totaldigits, int digitssofar) {
// make sure we're on the right thread
debug.assert(_pi.invokerequired == false);
...
}
实事上,.net文档在这一点上是很清晰的。它描述如下:“控件上有四种方法可以安全地从任何线程进行调用:invoke、begininvoke、endinvoke 和 creategraphics。对于所有其他方法调用,当从另一个线程进行调用时,应使用这些 invoke 方法之一。”所以,当我设置控件属性时,就明确地违反了这条规则。前三个函数的名字就明确地指出了我需要构建另外一个在ui线程中执行的委托。如果我不想像阻塞ui线程一样阻塞我的worker线程,我就需要使用异步的begininvoke和endinvoke。然而,由于我的worker线程生来就是为ui线程服务的,就让世界简单一点,使用同步的invoke方法吧。像下面:
public object invoke(delegate method);
public object invoke(delegate method, object[] args);
第一个重载的invoke接收一个包含我们将要在ui线程中调用的方法的委托的实例,这个委托(或方法)必须没有参数。然而我们想要用来更新ui的函数showprogress带有三个参数,所以我们需要第二个重载形式。我们同样需要为我们的showprogress方法定义一个单独的委托以便我们可以正确地传递参数。这里给出了如何使用invoke来确保我们调用的showprogress也包括我们对窗口的使用是在正确的线程中执行的方法:(请确认替换calcpi中两处对showprogress的调用)。
delegate
void showprogressdelegate(string pi, int totaldigits, int digitssofar);
void calcpi(int digits) {
stringbuilder pi = new stringbuilder("3", digits + 2);
// 准备异步显示进度
showprogressdelegate showprogress =
new showprogressdelegate(showprogress);
// 显示进度
this.invoke(showprogress, new object[] { pi.tostring(), digits, 0});
if( digits > 0 ) {
pi.append(".");
for( int i = 0; i < digits; i += 9 ) {
...
// 显示进度
this.invoke(showprogress,
new object[] { pi.tostring(), digits, i + digitcount});
}
}
}
invoke的使用最终让我在windows forms程序中安全的使用多线程。ui线程孵化出一个worker线程来执行耗时操作,当ui需要更新时worker线程把控制传递回ui线程。图5显示了我们的安全多线程构架。
图5. 安全的多线程
简化了的多线程
对invoke的调用多少有点麻烦,因为它在calcpi中调用了两次,我可以简化一下,改进showprogress让它自己来作异步调用。如果showprogress是在正确的线程中调用的,他将更新控件,但是如果它在不正确的线程中被调用,它就会使用invoke在正确的线程中回头调用它自身。这让我们回到了以前,简单些的calcpi:
void showprogress(string pi, int totaldigits, int digitssofar) {
// 确保我们在正确的线程中
if( _pi.invokerequired == false ) {
_pi.text = pi;
_piprogress.maximum = totaldigits;
_piprogress.value = digitssofar;
}
else {
// 异步显示进度
showprogressdelegate showprogress =
new showprogressdelegate(showprogress);
this.invoke(showprogress,
new object[] { pi, totaldigits, digitssofar});
}
}
void calcpi(int digits) {
stringbuilder pi = new stringbuilder("3", digits + 2);
// 显示进度
showprogress(pi.tostring(), digits, 0);
if( digits > 0 ) {
pi.append(".");
for( int i = 0; i < digits; i += 9 ) {
...
//显示进度
showprogress(pi.tostring(), digits, i + digitcount);
}
}
}
因为invoke是一个异步调用并且我们并不真的需要它的返回值(事实上,showprogress本身就不返回任何值),这里最好是使用begininvoke以便worker线程不阻塞。就像下面:
begininvoke(showprogress, new object[] { pi, totaldigits, digitssofar});
如果不需要函数调用的返回值,begininvoke总是应该优先考虑,因为它可以让worker线程立即回到自己的工作上来,并且避免死锁的可能性。
我们做了什么?
我用了一个简短的例子,演示了如何在执行耗时操作的同时显示进度并保持ui的用户操作的响应。为了完成这个任务,我用了一个异步委托来“孵化”出一个worker线程、主窗口上的invoke方法和另外一个要封传回ui线程执行的代理。
我非常小心地避免做一件事情,那就是在ui线程和worker线程之间共享数据。相反,对于那些必需的数据我传递它们的拷贝(要计算的位数、已经计算出来的数字和进度)。在最终的解决方案中,我从来都没有传递对象的引用,比如当前stringbuilder的引用(虽然传递引用可以节省每次回到ui线程时对字符串的拷贝)。如果我要在两个线程之间传递数据的引用,我就必须使用.net原始的同步手段来确保任一时刻只有一个线程访问一个对象,这将增加许多工作量。这样已经足够了,无需引入同步进制。
当然,如果你需要处理的是数据库,你肯定不会打算把数据库到处复制。然而在windows forms程序中,如果可能我推荐你在worker线程和ui线程之间使用异步委托和消息来实现耗时操作。
下载例子:asynchcalcpi.exe
新闻热点
疑难解答