C#的消息队列应用程序 -2

在这个数组内部，CWorker 类创建了 CWorkerThread类的一个实现版
本。CWorkerThread 类（将在下面讨论）是一个必须继承的抽象类。导出
类定义了消息的处理方式：
aThreads = new ArrayList();
for (int idx=0; idx〈sfWorker.NumberThreads; idx++)
{
　 WorkerThreadFormatter wfThread = new WorkerThreadFormatter();
　 wfThread.ProcessName = sfWorker.ProcessName;
　 wfThread.ProcessDesc = sfWorker.ProcessDesc;
　 wfThread.ThreadNumber = idx;
　 wfThread.InputQueue = sfWorker.InputQueue;
　 wfThread.ErrorQueue = sfWorker.ErrorQueue;
　 wfThread.OutputName = sfWorker.OutputName;
　 // 定义辅助类型，并将其插入辅助线程结构
　 CWorkerThread wtBase;
　 switch (sfWorker.ProcessType)
　 {
　　　case WorkerFormatter.SFProcessType.ProcessRoundRobin:
　　　　 wtBase = new CWorkerThreadRoundRobin(this, wfThread);
　　　　 break;
　　　case WorkerFormatter.SFProcessType.ProcessAppSpecific:
　　　　 wtBase = new CWorkerThreadAppSpecific(this, wfThread);
　　　　 break;
　　　case WorkerFormatter.SFProcessType.ProcessAssembly:
　　　　 wtBase = new CWorkerThreadAssembly(this, wfThread);
　　　　 break;
　　　default:
　　　　 throw new Exception("Unknown Processing Type");
　 }
　 // 添加对数组的调用
　 aThreads.Insert(idx, wtBase);
}

　　一旦所有的对象都已创建，就可以通过调用每个线程对象的 Start方
法来启动它们：
foreach(CWorkerThread cThread in aThreads)
　 cThread.Start();

　　Stop、Pause 和 Continue 方法在 foreach循环里执行的操作类似。
Stop方法具有如下的垃圾收集操作：
GC.SuppressFinalize(this);

　　在类析构函数中将调用 Stop 方法，这样，在没有显式调用 Stop 方
法的情况下也可以正确地终止对象。如果调用了 Stop 方法，将不需要析
构函数。SuppressFinalize方法能够防止调用对象的 Finalize 方法（析
构函数的实际实现）。

CWorkerThread 抽象类

　　CWorkerThread 是一个由 CWorkerThreadAppSpecifc、CWorkerThread
RoundRobin 和 CWorkerThreadAssembly继承的抽象类。无论如何处理消
息，队列的大部分处理是相同的，所以 CWorkerThread类提供了这一功能。
这个类提供了抽象方法（必须被实际方法替代）以管理资源和处理消息。