rockford lhotka
magenic technologies
2002年10月1日
从 msdn code center 下载 vbbackground.exe 示例文件(英文)。(请注意,在示例文件中,程序员的注释使用的是英文,本文中将其译为中文是为了便于读者进行理解。)
摘要:rocky lhotka 建议并实现了一个结构化架构示例,该架构可用于充当辅助线程和 ui 线程之间的媒介,从而简化编写多线程辅助代码和 ui 以对其进行控制的过程。该架构包括可下载的代码示例,可以根据您的应用需要进行调整。
使用多线程,可以使应用程序同时执行多项任务。使用多线程,可以让一个线程运行用户界面,让另一个线程进行复杂运算或在后台操作。由于 microsoft® visual basic® .net 支持多线程,因此我们很容易获得此功能。
但多线程也有其不足之处。当应用程序使用多个线程时,我们总会遇到这样的问题:多个线程同时尝试与相同的数据或资源进行交互。出现这种情况时,问题就会变得非常复杂并且难以调试。
更糟糕的是,多线程代码通常在最初开发期间似乎运行正常,但在生产过程中则会因为出现意外的情况(多个线程同时与相同的数据或资源进行交互)而导致失败。这样就增大了多线程编程的危险性!
由于设计和调试多线程应用程序非常困难,因此 microsoft 在 com 中创建了“单线程单元”(sta) 概念。visual basic 6 代码始终在 sta 中运行,因而代码只需考虑单线程即可。这样即可彻底避免共享数据或资源所带来的问题,但是同时也意味着,我们必须采取严格的措施才能利用多线程的优势。
.net 中不会出现 sta 中的这种常见问题。所有 .net 代码都在允许多线程操作的 appdomain 中运行。这意味着 visual basic .net 代码也在 appdomain 中运行,因此可以使用多线程操作。显然,任何时候进行此操作都必须小心编写代码,以避免线程之间的冲突。
要避免线程之间发生冲突,最简单的方法就是确保多个线程永远不会与相同的数据或资源进行交互。尽管不太可能,但是对于任何多线程应用程序来说,应该在设计时尽量避免使用或尽量少使用共享数据或共享资源。
这样不仅能简化编码和调试过程,还能提高性能。要解决线程之间的冲突,必须使用能够在某个线程完成操作之前阻止或暂停其他线程的同步技术。阻止线程也就是使线程处于空闲状态,不进行任何操作,因此会降低性能。
取消按钮和状态显示
在应用程序中使用多线程的原因有多种,但最常见的原因是我们一方面需要执行一个长时间运行的任务,另一方面又希望某些或所有用户界面对用户来说始终处于响应状态。
至少我们应该使 cancel(取消)按钮始终保持响应状态,使用户能够通过它告诉系统,他们希望终止长时间运行的任务。
在 visual basic 6 中,我们尝试使用 doevents、计时器控件和许多其他方法进行该操作。visual basic .net 中的操作则简单得多,因为我们可以使用多线程。而且,只要我们小心谨慎,就可以完成此操作且不会使代码或调试复杂化。
要在多线程环境中成功实现 cancel(取消)按钮,关键是要记住 cancel(按钮)的作用只是“请求”取消任务。由后台任务决定何时停止。
如果我们实现一个能够直接停止后台进程的 cancel(取消)按钮,则可能会在执行某些敏感性操作的过程中将其停止,或者在后台进程关闭重要资源(例如,文件处理程序或数据库连接)之前将其停止。而这有可能导致严重后果,引起死机、应用程序行为不稳定或应用程序完全崩溃。
因此,cancel(取消)按钮的作用应该只是请求停止后台任务。后台任务可以检查某一时间点上是否存在取消操作的请求。如果检测到取消操作的请求,后台线程则可以释放所有资源,停止所有重要操作并正常终止。
虽然请求取消操作非常重要,但是我们更希望能够通过 ui 为用户显示后台进程的状态信息。状态信息可以是文本格式的消息,也可以是完成任务的百分比,或者同时显示两种消息。
要在 visual basic .net 中实现 cancel(取消)按钮或状态显示,我们所面对的最复杂的问题在于 windows 窗体库不是对于线程并不安全。这意味着只有创建窗体的线程可以与该窗体或其控件进行交互。其他线程均不能安全地与该窗体或其控件进行交互。
但是,我们却无法避免编写多线程与给定窗体进行交互的代码。因此,运行时可能会产生不可预知的后果,甚至可能会导致应用程序崩溃。
这要求我们在编码时必须小心谨慎,还要确保只有我们的 ui 线程与 ui 进行交互。为此,我们可以建立一个简单的架构,管理后台辅助线程和 ui 线程之间的交互。如果能够实现,则可以使 ui 代码和长时间运行的任务的代码都相对清楚地了解到我们正在使用多线程。
线程和对象
如果要创建一个后台进程并使其可以使用它自己的数据在它自己的线程上运行,最简单的方法是创建专门用于该后台进程的对象。虽然不一定能实现,但它是一个积极的目标,因为它能够大大简化多线程应用程序的创建过程。
如果后台线程在其自身的对象中运行,则后台线程可以使用该对象的实例变量(在类中声明的变量),而无须担心这些变量会被其他线程使用。例如,请考虑下面的类:
public class worker
private minner as integer
private mouter as integer
public sub new(byval innersize as integer, byval outersize as integer)
minner = innersize
mouter = outersize
end sub
public sub work()
dim innerindex as integer
dim outerindex as integer
dim value as double
for outerindex = 0 to mouter
for innerindex = 0 to minner
do some cool calculation here
value = math.sqrt(cdbl(innerindex – outerindex))
next
next
end sub
end class
这个类适合在后台线程中运行,并且可以使用以下代码启动:
dim myworker as new worker(10000000, 10)
dim backthread as new thread(addressof myworker.work)
backthread.start()
worker 类中的实例变量可以存放其数据。后台线程可以安全地使用这些变量(minner 和 mouter),还可以确保其他线程不会同时访问这些变量。
我们可以用其中包含的 constructor 方法使用任何起始数据初始化该对象。实际启动后台线程之前,我们的主应用程序代码会创建此对象的实例,并使用后台线程将要操作的数据对其进行初始化。
后台线程将获取对象的 work 方法的地址,然后开始启动。此线程将立即在对象内部运行代码,并使用该对象的专用数据。
由于对象是自包含的,因此我们可以创建多个对象,每个对象在其自身的线程上运行并且对象之间相对独立。
但是,此实现方案并不理想。ui 无法获得后台进程的状态。我们也未实现任何机制,使 ui 能够请求终止后台进程。
要解决以上两个问题,后台线程与 ui 线程之间需要以某种方式进行交互。这种交互方式非常复杂,因此最好能够以某种方式将交互放到一个类中,这样 ui 和辅助代码就不必为细节而担心。
体系结构
我们可以创建使 ui 和辅助代码无需进行线程交互操作的体系结构。实际上我们可以实现此目标,还能实现一个能够通过某种方式实现复杂代码的架构,可以用来管理或控制后台线程及其 ui 交互。
我们先来讨论体系结构,然后再讨论如何设计和实现代码。从本文的相关链接可以下载此代码以及说明如何使用此代码的示例应用程序。
通常情况下,应用程序中首先会启动一个单一线程,来打开用户界面。我们将其命名为“ui 线程”以便于理解。“ui 线程”是许多应用程序中的唯一线程,因此它要处理 ui 并完成所有操作。
但是,现在我们创建一个“辅助线程”进行某些后台操作,让 ui 线程集中处理用户界面。这样即使辅助线程繁忙,ui 线程也可以对用户保持响应状态。
我们在 ui 线程和辅助线程之间插入一层代码,使其充当 ui 和辅助代码之间的接口。此代码实质上是一个“控制器”,用来管理和控制辅助线程及其与 ui 之间的交互。
图 1:ui 线程、控制器和辅助线程
控制器包含的代码可以安全地启动辅助线程,将任何状态消息从辅助线程中转给 ui 线程,以及将任何取消请求从 ui 线程中转回辅助线程。ui 代码和辅助代码不能直接交互,它们通常要通过控制器的代码进行交互。
但是辅助线程被激活“之前”和“之后”的时间段除外,这时 ui 代码可以与 worker 对象进行交互。启动辅助线程之前,ui 可以创建并初始化 worker 对象。终止辅助线程之后,ui 可以从 worker 对象中检索任何值。从 ui 的角度看,将形成以下事件流:
创建 worker 对象。
初始化 worker 对象。
调用 controller 以启动辅助线程。
worker 对象将通过 controller 将状态信息发送给 ui。
ui 可以通过 controller 将取消请求发送给 worker 对象。
worker 对象在完成操作后通过 controller 通知 ui。
值可以直接从 worker 对象中检索。
除了在辅助线程处于激活状态时 ui 代码无法与 worker 对象直接交互的限制外,对 ui 没有特殊的编码要求。即使正在运行后台操作,ui 也会对用户保持激活和响应状态。
从 worker 对象的角度看,将形成以下事件流:
ui 代码创建 worker 对象。
ui 代码使用所需的数据初始化 worker 对象。
controller 创建后台线程并调用 worker 对象的方法。
worker 对象运行辅助代码。
worker 对象将状态信息传递给 controller,以便 controller 将状态信息中转给 ui。
worker 对象适时检查是否存在取消请求,如果存在,则停止运行。
worker 对象完成后,告诉 controller 已完成,以便 controller 将该信息中转给 ui。
现在辅助线程已终止,因此 ui 可以与 worker 对象直接交互。
由于辅助代码只与 controller 交互,因此我们不必担心辅助线程会意外地与 ui 组件交互(这无疑会使应用程序不稳定)。现在,辅助代码依靠 controller 与 ui 线程进行正确通信,因此各项操作都很安全。
这意味着,只要处理好 worker 对象中的实例变量,就无需处理辅助代码中的任何线程问题。
使用图表通常能够很好地了解不同组件(尤其是不同线程上的组件)之间的交互。microsoft® visio® 支持创建 uml(通用建模语言)图表,对理解很有帮助。
以下是说明 ui、worker 对象和 controller 之间事件流的 uml 序列图表。此图表假设不存在任何取消操作请求。worker 和 controller 对象下面重叠在垂直线上的垂直活动栏突出了辅助线程上运行的代码。其他所有代码都在 ui 线程上运行。
图 2:说明进程流的序列图表
使用 uml 活动图表也可以查看事件流。这种图表形式的着重点在于任务而不是对象,因此其中显示了发生的一系列步骤以及各步骤之间的流程。我们很容易看出 ui 代码如何停留在左侧的线程中,而 worker 对象如何在右侧的线程上工作。worker 对象在其他线程中运行之前和运行之后可以直接由 ui 使用,以便初始化值,然后再检索结果。
图 3:显示进程流的活动图表
使用这样的图表可以帮助我们找出后台线程处于激活状态时,ui 与辅助线程(或反过来)无意中进行直接交互的位置。任何这样的交互都需要额外地进行编码,以避免出现可能使应用程序不稳定的错误。理想状态下,这种交互通过 controller 组件来实现,我们可以在其中包含所有编码,使交互安全进行。
下图说明了 ui 发出取消请求时的事件序列。
图 4:显示取消请求的序列图表
请注意,取消请求从 ui 发送到 controller,然后 worker 线程与 controller 进行核实,确定是否发生了取消请求。ui 和 controller 都不会强制辅助代码终止,而是允许辅助代码自己正常安全地终止。
架构设计
要实现我们讨论的行为,显然需要实现 controller 类。为了使此架构能够在多数方案中应用,我们还会定义一些正式接口,可以由 controller 在与 ui(或客户端)和辅助线程交互时使用。
通过为客户端和辅助线程定义正式接口,我们可以在不同的情况下使用相同的 controller 对象,还可以根据需要使用不同的 ui 要求和不同的 worker 对象。
下面的 uml 类图表显示了 controller 类以及 iclient 和 iworker 接口。它还显示了 icontroller 接口,辅助代码将通过它与 controller 对象交互。
图 5:controller 和相关接口的类图表
iclient 接口定义的方法将由 controller 对象调用,用于向客户端 ui 通报 worker 的开始时间、结束时间和任何中间状态消息。它还包含一个指示辅助代码失败的方法。
多数情况下,我们可以将这些方法作为由 controller 对象发出而由 ui 处理的事件来实现。但是,从辅助线程发出事件然后由 ui 线程正确处理并非易事,因而我们将其作为一组方法来进行实现。
使控制器代码(在辅助代码上运行)调用 ui 中的这些方法并由 ui 线程进行处理,这样相对要简单得多。
同样,iworker 接口定义了由 controller 对象调用的、使其可以与辅助代码交互的方法。使用 initialize 方法可以为辅助代码提供对 controller 对象的引用,而使用 start 方法可以启动后台线程上的操作。
由于线程的工作方式,start 方法无法包含任何参数。启动新线程时,必须将不接受任何参数的方法的地址传递给线程。
请注意,iworker 接口中不存在 cancel 或 stop 方法。我们不能强制辅助代码停止,同时也没有这个必要;但是辅助代码可以使用 icontroller 接口询问 controller 对象是否存在取消请求。
icontroller 接口定义了辅助代码可以在 controller 对象上调用的方法。它允许辅助代码检查 running 标志。如果存在取消请求,running 标志即为 false。它还允许辅助代码在工作完成或无法完成时告诉 controller,并允许使用状态消息和完成百分比值(0 到 100 之间的 integer)更新 controller。
最后我们定义了 controller 对象。该对象中包含一些可以被 ui 代码调用的方法。其中包括 start 方法,该方法可以通过为 controller 对象提供对 worker 对象的引用来启动后台操作。还包括 cancel 方法,该方法用于请求取消操作。ui 也可以检查 running 属性,查看是否存在取消请求;还可以检查 percent 属性,查看任务完成的百分比。
controller 类中包含的 constructor 方法接受 iclient 作为参数,还允许 ui 为 controller 提供对窗体(用于处理 worker 中的显示消息)的引用。
为了实现一系列动画点来显示线程的活动,我们将创建一个简单 windows 窗体控件,该控件使用计时器以更改一系列 picturebox 控件中的颜色。
实现方案
我们将在 class library(类库)项目中实现此架构,使其可用于需要运行后台进程的应用程序。
打开 visual studio .net,然后创建一个名为 background 的新 class library(类库)应用程序。由于此库将包含 windows 窗体控件和窗体,因此需要使用 add references(添加引用)对话框引用 system.windows.forms.dll 和 system.windows.drawing.dll。此外,我们可以使用项目的属性对话框在这些项目范围内导入命名空间,如图 6 所示。
图 6:使用项目属性添加项目范围内的命名空间 imports
此操作完成后,就可以开始编码了。让我们先从创建接口开始。
定义接口
在名为 iclient 的项目中添加一个类,并用以下代码替换其代码:
public interface iclient
sub start(byval controller as controller)
sub display(byval text as string)
sub failed(byval e as exception)
sub completed(byval cancelled as boolean)
end interface
然后添加名为 iworker 的类,并用以下代码替换其代码:
public interface iworker
sub initialize(byval controller as icontroller)
sub start()
end interface
最后添加名为 icontroller 的类,代码如下:
public interface icontroller
readonly property running() as boolean
sub display(byval text as string)
sub setpercent(byval percent as integer)
sub failed(byval e as exception)
sub completed(byval cancelled as boolean)
end interface
至此,我们已定义了本文前面所述的所有类图表中的接口。现在可以实现 controller 类了。
controller 类
现在,我们可以实现架构的核心,controller 类。此类中包含的代码可用于启动辅助线程,以及在辅助线程完成之前充当 ui 线程和辅助线程之间的媒介。
在名为 controller 的项目中添加一个新类。首先添加 imports,并声明一些变量:
imports system.threading
public class controller
implements icontroller
private mworker as iworker
private mclient as form
private mrunning as boolean
private mpercent as integer
然后需要声明一些委托。委托是方法的正式指针,而且方法的委托必须具有与方法本身相同的方法签名(参数类型等)。
委托的用途很广。在我们的示例中,委托非常重要,因为委托使我们可以让一个线程调用窗体上的方法,使其在该窗体的 ui 线程上运行。正如 iclient 所定义的那样,要在窗体上调用的三个方法都需要委托:
此委托签名与 iclient.completed
中的签名相匹配,并用于安全地
调用 ui 线程上的方法
private delegate sub completeddelegate(byval cancelled as boolean)
此委托签名与 iclient.display
中的签名相匹配,并用于安全地
调用 ui 线程上的方法
private delegate sub displaydelegate(byval text as string)
此委托签名与 iclient.failed
中的签名相匹配,并用于安全地
调用 ui 线程上的方法
private delegate sub faileddelegate(byval e as exception)
iclient 还定义了 start 方法,但是该方法可以从 ui 线程调用,因此不需要委托。
下面编写将从 ui 线程调用的代码。代码中包括 constructor 方法、start 和 cancel 方法以及 percent 属性。我将这些内容放入 region 中,便于大家清楚地了解它们是从 ui 线程调用的。
#region " 从 ui 线程调用的代码 "
使用客户端初始化 controller
public sub new(byval client as iclient)
mclient = ctype(client, form)
end sub
此方法由 ui 调用,因此在
ui 线程上运行。此处我们将
启动辅助线程
public sub start(optional byval worker as iworker = nothing)
如果辅助线程已经启动,将产生错误
if mrunning then
throw new exception("background process already running")
end if
mrunning = true
存储对辅助对象的引用,并
初始化辅助对象,使其包含
对 controller 的引用
mworker = worker
mworker.initialize(me)
创建后台线程
以进行后台操作
dim backthread as new thread(addressof mworker.start)
开始后台工作
backthread.start()
告诉客户端后台工作已开始
ctype(mclient, iclient).start(me)
end sub
此代码由 ui 调用,因此在 ui
线程上运行。它只设置了请求
取消的标志
public sub cancel()
mrunning = false
end sub
返回完成百分比值,并且
只被 ui 线程调用
public readonly property percent() as integer
get
return mpercent
end get
end property
#end region
此处唯一比较特殊的代码位于 start 方法中,我们可以在该方法中创建辅助线程然后启动该线程:
dim backthread as new thread(addressof mworker.start)
backthread.start()
要创建线程,需要在 worker 对象的 iworker 接口上传递 start 方法的地址。然后,只需调用线程对象的 start 方法即可开始操作。此时我们要特别注意,ui 不应直接与 worker 交互,worker 也不应直接与 ui 交互。
请注意,cancel 方法只设置一个标志,表明我们不希望继续运行。辅助代码应定期查看此标志,以确定是否应该停止运行。
现在,我们可以实现 worker 对象运行时将由辅助线程调用的代码。此代码比较有趣,因为它必须将 display 和 completed 从辅助线程中转至 ui 线程,同时还要在 ui 线程上完成此操作。
要完成此操作,我们可以使用 form 对象的 invoke 方法。此方法接受窗体应该调用的方法的委托指针,以及包含该方法的参数的 object 类型数组。
invoke 方法不直接调用窗体上的方法,而是请求窗体返回并使用窗体的 ui 线程调用该方法。此操作可通过向窗体发送 windows 消息在后台完成。这说明窗体获得这些方法调用的方式与从操作系统中获得 click 或 keypress 事件的方式基本相同。
通常,这些细节不会影响大局。结果由 invoke 方法触发一个进程,通过该进程窗体将终止其 ui 线程上运行的方法,这就是我们要实现的目标。
再次重申,此代码位于 region 内,目的是为了明确它将在辅助线程上调用:
#region " 从辅助线程调用的代码 "
从辅助线程调用,以更新显示
这将触发对包含状态文本的 ui 的
方法调用 – 该调用是在 ui 线程上
进行的
private sub display(byval text as string) _
implements icontroller.display
dim disp as new displaydelegate( _
addressof ctype(mclient, iclient).display)
dim ar() as object = {text}
调用 ui 线程上的客户端窗体
以更新显示
mclient.begininvoke(disp, ar)
end sub
从辅助线程调用,以表明出现故障
这将触发对包含异常对象的 ui 的
方法调用 – 该调用是在 ui 线程上
进行的
private sub failed(byval e as exception) _
implements icontroller.failed
dim disp as new faileddelegate(_
addressof ctype(mclient, iclient).failed)
dim ar() as object = {e}
在 ui 线程上调用客户端窗体
以表明出现故障
mclient.invoke(disp, ar)
end sub
从辅助线程上调用,以指出完成的百分比
值将转到 controller,由 ui 在需要时读取
private sub setpercent(byval percent as integer) _
implements icontroller.setpercent
mpercent = percent
end sub
从辅助线程调用,以表明已完成
我们还传递参数,以表明是否真正完成,
以及是否取消在 ui 线程上进行的对 ui
的调用
private sub completed(byval cancelled as boolean) _
implements icontroller.completed
mrunning = false
dim comp as new completeddelegate( _
addressof ctype(mclient, iclient).completed)
dim ar() as object = {cancelled}
调用 ui 线程上的客户端窗体
以表明已完成
mclient.invoke(comp, ar)
end sub
表明是否仍在运行或是否已请求取消
这将在辅助线程上进行调用,因此
辅助代码可以查看它是否应该正常
退出
private readonly property running() as boolean _
implements icontroller.running
get
return mrunning
end get
end property
#end region
failed 和 completed 方法利用窗体的 invoke 方法。例如,failed 方法可以执行以下操作:
dim disp as new faileddelegate(_
addressof ctype(mclient, iclient).failed)
dim ar() as object = {e}
调用 ui 线程上的客户端窗体
以表明出现故障
mclient.invoke(disp, ar)
首先创建一个委托,从 iclient 接口指向客户端窗体的 failed 方法。然后声明包含向方法传递参数值的 object 类型数组。最后调用客户端窗体的 invoke 方法,将委托指针和参数数组传递给窗体。
窗体将在 ui 线程(窗体在这里可以安全运行以更新显示)上使用这些参数调用此方法。
整个进程是同步进行的,即对窗体进行调用时辅助线程将停止。尽管可以在显示错误消息或完成消息时停止辅助线程,但我们并不希望显示每个小状态时都停止辅助线程。
为了避免显示状态时停止辅助线程,display 方法将使用 begininvoke,而不使用 invoke。begininvoke 使窗体上的方法调用异步进行,这样辅助线程可以一直保持运行状态,不需要等待窗体上的显示方法完成:
dim disp as new displaydelegate( _
addressof ctype(mclient, iclient).display)
dim ar() as object = {text}
调用 ui 线程上的客户端窗体
以更新显示
mclient.begininvoke(disp, ar)
以这种方式使用 begininvoke 可以防止辅助线程停止,使辅助线程具有尽可能高的性能。
activitybar 控件
最后,我们来创建显示动画点的 activitybar 控件。
在名为 activitybar 的项目中添加一个用户控件。
将该控件的宽度调整为约 110,高度调整为约 20。可以通过拖动边界进行调整,也可以通过在 properties(属性)窗口中设置 size 属性进行调整。
其余的操作将通过代码完成。要创建一系列在显示时不停闪烁的动画“灯”,可以使用带有 timer 控件的一系列 picturebox 控件。每次 timer 控件关闭时,我们将使下一个 picturebox 呈绿色显示,并将已经呈绿色显示的 picturebox 更改为窗体的背景色。
将 windows forms(windows 窗体)选项卡中的 timer 控件放入窗体中,然后将其名称更改为 tmanim。同时将 interval 属性设置为 300,以获得较好的动画速度。
顺便说一句,components(组件)选项卡中有一个不同的 timer 控件。它是一个多线程计时器。也就是说,该计时器将在后台线程中引发 elapsed 事件,而不是象 windows 窗体计时器那样在 ui 线程上引发 elapsed 事件。建立 ui 时这种方法通常会产生相反的效果,因为 elapsed 事件中的代码显然不能直接与我们的 ui 进行交互。
现在,在控件中添加以下代码:
private mboxes as new arraylist()
private mcount as integer
private sub activitybar_load(byval sender as system.object, _
byval e as system.eventargs) handles mybase.load
dim index as integer
if mboxes.count = 0 then
for index = 0 to 6
mboxes.add(createbox(index))
next
end if
mcount = 0
end sub
private function createbox(byval index as integer) as picturebox
dim box as new picturebox()
with box
setposition(box, index)
.borderstyle = borderstyle.fixed3d
.parent = me
.visible = true
end with
return box
end function
private sub graydisplay()
dim index as integer
for index = 0 to 6
ctype(mboxes(index), picturebox).backcolor = me.backcolor
next
end sub
private sub setposition(byval box as picturebox, byval index as integer)
dim left as integer = cint(me.width / 2 – 7 * 14 / 2)
dim top as integer = cint(me.height / 2 – 5)
with box
.height = 10
.width = 10
.top = top
.left = left + index * 14
end with
end sub
private sub tmanim_tick(byval sender as system.object, _
byval e as system.eventargs) handles tmanim.tick
ctype(mboxes((mcount + 1) mod 7), picturebox).backcolor = _
color.lightgreen
ctype(mboxes(mcount mod 7), picturebox).backcolor = me.backcolor
mcount += 1
if mcount > 6 then mcount = 0
end sub
public sub start()
ctype(mboxes(0), picturebox).backcolor = color.lightgreen
tmanim.enabled = true
end sub
public sub [stop]()
tmanim.enabled = false
graydisplay()
end sub
private sub activitybar_resize(byval sender as object, _
byval e as system.eventargs) handles mybase.resize
dim index as integer
for index = 0 to mboxes.count – 1
setposition(ctype(mboxes(index), picturebox), index)
next
end sub
窗体的 load 事件创建 picturebox 控件并将它们放入数组,这样便于我们在它们之间循环。timer 控件的 tick 事件循环显示,使各个控件依次呈绿色。
所有操作由 start 方法开始,由 stop 事件结束。由于 stop 是一个保留字,因此把这个方法名放在方括号内:[stop]。stop 方法不仅可以停止计时器,还可以灰显所有框,告诉用户这些框中当前没有活动。
创建 worker 类
本文前面已简单介绍了 worker 类。因为我们已经定义了 iworker 接口,所以可以增强该类,以利用我们创建的 controller。
首先创建 background.dll 文件。此步骤很重要,因为如果不完成此步骤,activitybar 控件将无法在我们建立测试窗体时显示在工具箱上。
在解决方案中添加名为 bgtest 的 windows forms application(windows 窗体应用程序)。在 solution explorer(解决方案资源浏览器)中用右键单击该项目并选择相应的菜单项,将该程序设置为启动项目。
然后使用 add references(添加引用)对话框中的 projects(项目)选项卡,添加对 background 项目的引用。
现在,在名为 worker 的项目中添加一个类。其中部分代码与前面所述的代码相同,但还包含一些不同的代码,用以实现 iworker 接口(此处突出显示的部分):
imports background
public class worker
implements iworker
private mcontroller as icontroller
private minner as integer
private mouter as integer
public sub new(byval innersize as integer, byval outersize as integer)
minner = innersize
mouter = outersize
end sub
由 controller 调用,以便获取
controller 的引用
private sub init(byval controller as icontroller) _
implements iworker.initialize
mcontroller = controller
end sub
private sub work() implements iworker.start
dim innerindex as integer
dim outerindex as integer
dim value as double
try
for outerindex = 0 to mouter
if mcontroller.running then
mcontroller.display("outer loop " & outerindex & " starting")
mcontroller.setpercent(cint(outerindex / mouter * 100))
else
它们请求取消
mcontroller.completed(true)
exit sub
end if
for innerindex = 0 to minner
此处进行一些有意思的计算
value = math.sqrt(cdbl(innerindex – outerindex))
next
next
mcontroller.setpercent(100)
mcontroller.completed(false)
catch e as exception
mcontroller.failed(e)
end try
end sub
end class
我们添加了能够实现 iworker.initialize 的 init 方法。controller 将调用此方法,因此以后我们可以引用 controller 对象。
我们还将 work 方法更改为 private,只是为了实现 iworker.start 方法。此方法将在辅助线程上运行。
我们增强了 work 方法,使其可以使用 try..catch 块。这样我们可以使用 controller 上的 failed 方法捕捉任何错误并将其返回给 ui。
假设代码正在运行,我们调用 controller 对象的 display 和 setpercent 方法,使它们随着代码的运行更新其状态和完成的百分比。
我们还定期检查 controller 对象的 running 属性,查看是否存在取消请求。如果存在取消请求,则停止进程,并指示由于取消请求而停止操作。
创建显示的窗体
最后,我们可以创建窗体,将其用于启动或取消后台进程。该窗体还将显示活动和状态信息。
打开 form1 的设计器并添加两个按钮(btnstart 和 btnrequestcancel)、两个标签(label1 和 label2)、一个 progressbar (progressbar1) 和一个 activitybar (activitybar1),如图 7 所示。
图 7:form1 控件的布局
该窗体需要实现 iclient,以便 controller 对象与之交互:
imports background
public class form1
inherits system.windows.forms.form
implements iclient
该窗体还需要 controller 对象和一个标志,用以跟踪后台操作是处于活动状态还是处于完成状态。
private mcontroller as new controller(me)
private mactive as boolean
然后,我们可以添加方法,以实现由 iclient 定义的接口。建议将这些方法放在 region 中,以表示它们实现的是辅助接口:
#region " iclient "
private sub taskstarted(byval controller as controller) _
implements iclient.start
mactive = true
label1.text = "starting"
label2.text = "0%"
progressbar1.value = 0
activitybar1.start()
end sub
private sub taskstatus(byval text as string) _
implements iclient.display
label1.text = text
label2.text = cstr(mcontroller.percent) & "%"
progressbar1.value = mcontroller.percent
end sub
private sub taskfailed(byval e as exception) _
implements iclient.failed
activitybar1.stop()
label1.text = e.message
msgbox(e.tostring)
mactive = false
end sub
private sub taskcompleted(byval cancelled as boolean) _
implements iclient.completed
label1.text = "completed"
label2.text = cstr(mcontroller.percent) & "%"
progressbar1.value = mcontroller.percent
activitybar1.stop()
mactive = false
end sub
#end region
请注意,这一段代码中的所有内容均与线程无关,其中的每一部分代码都可以在我们得知后台操作的状态时做出相应的响应。每次响应后,我们都会更新显示以表明进程的状态和完成百分比(以文字的形式或通过 progressbar 显示),并启动和停止 activitybar 控件。
mactive 标志非常重要。如果用户在辅助线程处于活动状态时关闭窗体,应用程序可能会挂起或变得不稳定。要防止出现这种情况,我们可以打断窗体的 closing 事件并取消关闭尝试(如果后台进程处于活动状态)。
private sub form1_closing(byval sender as object, _
byval e as system.componentmodel.canceleventargs) _
handles mybase.closing
e.cancel = mactive
end sub
我们还可以选择在这种情况下初始化取消操作,但是这取决于特定的应用程序要求。
其余的代码都是为了实现按钮的 click 事件。
private sub btnstart_click(byval sender as system.object, _
byval e as system.eventargs) handles btnstart.click
mcontroller.start(new worker(2000000, 100))
end sub
private sub btnstop_click(byval sender as system.object, _
byval e as system.eventargs) handles btnstop.click
label1.text = "cancelling …"
mcontroller.cancel()
end sub
start(开始)按钮只调用 controller 对象的 start 方法,并将 worker 对象的实例传递给它。
您可能需要调整用于初始化 worker 对象的值,以便在您的计算机上获得所需的结果。这些特定的值提供了双处理器 p3/450 计算机上的一个良好示例。显然,这只是用于测试目的。真正的 worker 对象将实现更有意义、运行时间更长的进程。
cancel(取消)按钮将调用 controller 对象的 cancel 方法,同时还会更新显示,以表明已请求取消。请记住,这只是一个取消“请求”,在辅助线程真正停止运行之前可能需要等待一些时间。最好能够为用户提供即时反馈,至少应让用户知道系统已经注意到用户的单击按钮操作。
现在,我们可以运行应用程序了。单击 start(开始)按钮时,worker 就应该开始运行,而且显示的内容会在运行时更新。您可以将窗体移动到屏幕上的任意位置,也可以与其交互,因为 ui 线程本质上还处于空闲状态,可以随时与您交互。
同时,辅助线程在后台进行大量复杂的工作,并定期将状态更新信息发送给 ui 线程以进行显示。
小结
多线程是一个功能强大的工具,我们可以在每次需要执行长时间运行的任务时使用该工具。我们可以用它运行辅助代码,而无需绑定用户界面。但同时要注意,多线程操作非常复杂,要正确操作并不容易,而且调试起来也比较困难。
尽管不一定能够实现,但我们还是应该尽量为每个辅助线程提供一组它可以操作的独立数据。要达到这个目的,最简单的方法就是为每个线程创建一个对象,对象中包含该线程可以操作的数据以及完成工作所需的代码。
通过实现结构化的架构,使之充当辅助线程和 ui 线程之间的媒介,我们可以大大简化编写多线程代码和 ui 以对其进行控制的过程。本文就介绍了这样一个架构,您可以根据需要使用或进行调整,以满足特定的应用需要。