在使用英創(chuàng)ARM9系列嵌入式主板的COM口，CAN口，網(wǎng)口時(shí)，一般會(huì)使用到timer或線(xiàn)程來(lái)實(shí)現(xiàn)數(shù)據(jù)的接收。使用timer控件較為方便，通過(guò)InterVal值來(lái)設(shè)定調(diào)用間隔，但是靈活性不如線(xiàn)程。并且timer的Tick函數(shù)是并在主線(xiàn)程中，如果Tick函數(shù)中運(yùn)算數(shù)據(jù)過(guò)于復(fù)雜，會(huì)導(dǎo)致主線(xiàn)程運(yùn)行變慢，可能導(dǎo)致窗口卡死。使用C#中的線(xiàn)程類(lèi)，可以非常方便的解決這個(gè)問(wèn)題，線(xiàn)程卡死，不會(huì)影響到主線(xiàn)程的運(yùn)算，就不會(huì)導(dǎo)致窗口卡死的狀況發(fā)生。

本文將介紹如何使用C#來(lái)創(chuàng)建和關(guān)閉線(xiàn)程，并在此基礎(chǔ)上，利用WinCE系統(tǒng)的消息機(jī)制實(shí)現(xiàn)通訊數(shù)據(jù)的實(shí)時(shí)收發(fā)，代替常規(guī)的定時(shí)查詢(xún)方法，從而降低了CPU負(fù)載，使嵌入式設(shè)備的整體性能得以提高。

1、線(xiàn)程的應(yīng)用實(shí)例

以下是一個(gè)簡(jiǎn)單的多線(xiàn)程代碼：

using System;
using System.Threading;
namespace thread
{
class Program
{
static void Main(string[] args)
{
Thread t = new Thread(excute);
t.Start();
while (true) Console.Write('1'); // 主線(xiàn)程循環(huán)輸出1
}
static void excute()
{
while (true) Console.Write('2'); // 線(xiàn)程t循環(huán)輸出2
}
}
}

輸出例子（并不唯一）：12121212121212121212121212121212121212121212121212...

2、線(xiàn)程的使用方法

首先需要添加thread類(lèi)的引用

using System.Threading;

初始一個(gè)線(xiàn)程類(lèi)，并設(shè)定它的執(zhí)行函數(shù)，該函數(shù)可以是靜態(tài)函數(shù)，也可以是別的類(lèi)的成員函數(shù)

Thread t = new Thread(excute);

執(zhí)行start，線(xiàn)程即啟動(dòng)并運(yùn)行它的執(zhí)行函數(shù)，函數(shù)運(yùn)行完畢后，線(xiàn)程自動(dòng)退出

t.Start();

3、線(xiàn)程的數(shù)據(jù)同步

觀察以下代碼：

using System;
using System.Threading;
namespace thread
{
class Program
{
static int i;
static void Main(string[] args)
{
Thread t = new Thread(excute);
t.Start();
excute();
}
static void excute()
{
for (i = 0; i < 5; i++)
{
Console.Write('{0}', i);
}
}
}
}

這個(gè)程序的輸出無(wú)法確定，可能是：001234。

這是因?yàn)樵谝粋€(gè)線(xiàn)程在使用一個(gè)變量時(shí)，另外一個(gè)線(xiàn)程也可能同時(shí)在使用。如果希望一個(gè)線(xiàn)程在使用某個(gè)變量時(shí)，禁止其他線(xiàn)程的使用，就需要用到線(xiàn)程鎖lock。

修改代碼為：

using System;
using System.Threading;
namespace thread
{
class Program
{
static readonly object locker = new object();
static int i;
static void Main(string[] args)
{
Thread t = new Thread(excute);
t.Start();
excute();
}
static void excute()
{
lock (locker)
{
for (i = 0; i < 5; i++)
{
Console.Write('{0}', i);
}
}
}
}
}

程序輸出：0123401234。

注意lock的使用，見(jiàn)MSDN的說(shuō)明：

1、不要鎖定this，即禁止lock(this)
2、不要鎖定類(lèi)型，如lock (typeof (MyType))
3、不要鎖定字符串，如lock('myLock')
4、最佳做法是定義private或 private static對(duì)象來(lái)鎖定

鎖定本身是很快，一個(gè)鎖在堵塞的情況，任務(wù)切換帶來(lái)的開(kāi)銷(xiāo)很低，使用鎖可以有效避免一些數(shù)據(jù)錯(cuò)誤，提高程序穩(wěn)定性。

4、線(xiàn)程的結(jié)束

使用abort可以提前釋放被阻塞的線(xiàn)程，使用join可以等待線(xiàn)程的結(jié)束：

using System;
using System.Threading;
namespace thread
{
class Program
{
static int i;
static void Main(string[] args)
{
Thread t = new Thread(excute);
t.Start();
// t.Abort();
t.Join();
for (i = 6; i < 10; i++)
{
Console.Write('{0}', i);
}
}
static void excute()
{
for (i = 0; i < 5; i++)
{
Console.Write('{0}', i);
}
}
}
}

程序輸出：0123456789。

如果取消Abort的注釋?zhuān)绦虻妮敵隹赡苁牵?789。

在主線(xiàn)程中關(guān)閉副線(xiàn)程一般步驟為，終止副線(xiàn)程，再等待確認(rèn)該線(xiàn)程退出，在主程序退出的時(shí)間同樣需要執(zhí)行檢測(cè)副線(xiàn)程的關(guān)閉：

t.Abort();
t.Join();

5、帶參數(shù)的線(xiàn)程

有時(shí)候希望在添加的線(xiàn)程中傳入指定的參數(shù)。

最簡(jiǎn)單的辦法是把類(lèi)封裝在類(lèi)中，讓線(xiàn)程的執(zhí)行函數(shù)為類(lèi)的成員函數(shù)，然后通過(guò)設(shè)置類(lèi)的成員變量，執(zhí)行函數(shù)訪(fǎng)問(wèn)成員變量這樣的辦法來(lái)實(shí)現(xiàn)指定執(zhí)行函數(shù)參數(shù)的功能，例程如下：

using System;
using System.Threading;
namespace thread
{
class ThreadClass
{
public int x;
public void excute()
{
while (true) { Console.WriteLine('{0}', x); }
}
}
class Program
{
static void Main(string[] args)
{
ThreadClass TClass1 = new ThreadClass();
TClass1.x = 1;
ThreadClass TClass2 = new ThreadClass();
TClass2.x = 2;
Thread t1 = new Thread(TClass1.excute);
Thread t2 = new Thread(TClass2.excute);
t1.Start();
t2.Start();
}
}
}

還有一個(gè)另外的辦法，使用ParameterizedThreadStart。

C#提供2種委托，ThreadStart和ParameterizedThreadStart，ParameterizedThreadStart允許傳入一個(gè)參數(shù)Object，可以將所需參數(shù)打包后調(diào)用。

注意：wince使用的是.net精簡(jiǎn)庫(kù)，不包含ParameterizedThreadStart，如果在wince下編程，請(qǐng)使用第一種方法。

6、線(xiàn)程的掛起和喚醒

當(dāng)線(xiàn)程創(chuàng)建后，就將占用一定的CPU時(shí)間，可以使用Sleep函數(shù)讓線(xiàn)程放棄一定時(shí)間片，進(jìn)入休眠狀態(tài)，在休眠狀態(tài)下，線(xiàn)程將不再占用CPU時(shí)間，如：

Thread.Sleep(0); // 釋放CPU時(shí)間片
Thread.Sleep(1000); // 休眠1000毫秒
Thread.Sleep(Timeout.Infinite); // 休眠直到被喚醒

使用線(xiàn)程的Interrupt方法可以強(qiáng)行喚醒休眠中的線(xiàn)程，注意，wince的.net精簡(jiǎn)庫(kù)里，Thread類(lèi)沒(méi)有Interrupt方法，所以在嵌入式設(shè)備中開(kāi)發(fā)時(shí)不要無(wú)限休眠線(xiàn)程，即Sleep(-1)。

7、線(xiàn)程的消息事件響應(yīng)

有的時(shí)候需要在線(xiàn)程中輪詢(xún)執(zhí)行一個(gè)函數(shù)，如通信接口的接收函數(shù)。使用輪循的方式將非常浪費(fèi)CPU時(shí)間。

private void BeginReceive() // 客戶(hù)機(jī)狀態(tài)下接收數(shù)據(jù)線(xiàn)程
{
while (!threadStop)
{
// 線(xiàn)程接收函數(shù)
}
}

在接收線(xiàn)程中加入適當(dāng)休眠可以提高CPU效率，這里Sleep的x越大，CPU效率越高，但是可能造成數(shù)據(jù)處理的延時(shí)。

private void BeginReceive() // 客戶(hù)機(jī)狀態(tài)下接收數(shù)據(jù)線(xiàn)程
{
while (!threadStop)
{
// 線(xiàn)程接收函數(shù)
Thread.Sleep(x); // 輪詢(xún)休眠
}
}

為了避免通訊數(shù)據(jù)接收的延時(shí)，線(xiàn)程還可采用等待數(shù)據(jù)接收事件的方式，線(xiàn)程在平時(shí)掛起，直到有數(shù)據(jù)接收的事件產(chǎn)生。
C#提供一套事件類(lèi)，可以讓線(xiàn)程進(jìn)入等待狀態(tài)，直到該事件到來(lái)，線(xiàn)程在等待時(shí)不會(huì)消耗CPU資源。

using System;
using System.Threading;
namespace thread
{
class Program
{
static AutoResetEvent evt;
static void Main(string[] args)
{
evt = new AutoResetEvent(false);
Thread t = new Thread(excute);
t.Start();
Thread.Sleep(10000);
evt.Set();
}
static void excute()
{
for ( ; ; )
{
evt.WaitOne();
Console.Write('event');
}
}
}
}

設(shè)定一個(gè)事件

static AutoResetEvent evt;

在線(xiàn)程等待該事件的時(shí)候掛起

evt.WaitOne();

直到該事件Set產(chǎn)生，線(xiàn)程才繼續(xù)執(zhí)行下面的代碼：

evt.Set();

還可以設(shè)置等待的時(shí)間長(zhǎng)短，當(dāng)有事件產(chǎn)生，WaitOne函數(shù)立刻返回true，如果等待時(shí)間超過(guò)設(shè)置時(shí)間，WaitOne也會(huì)返回，返回值false。

using System;
using System.Threading;
namespace thread
{
class Program
{
static AutoResetEvent evt;
static void Main(string[] args)
{
evt = new AutoResetEvent(false);
Thread t = new Thread(excute);
t.Start();
evt.Set();
Thread.Sleep(1000);
evt.Set();
Thread.Sleep(10000);
evt.Set();
}
static void excute()
{
bool b;
for (; ; )
{
b = evt.WaitOne(1000, false);
Console.Write('{0}', b.ToString);
}
}
}
}

注意：WaitOne第二個(gè)參數(shù)一般設(shè)置為false。

但是使用C#的事件類(lèi)可能有一定局限性，它需要在同一進(jìn)程里，有一些情況無(wú)法滿(mǎn)足需要。這時(shí)候可以使用系統(tǒng)的API函數(shù)來(lái)解決這個(gè)問(wèn)題，參看以下代碼。

using System;
using System.Threading;
using System.Runtime.InteropServices;
namespace thread
{
class Program
{
[DllImport('coredll.dll', EntryPoint = 'WaitForSingleObject')]
private static extern int WaitForSingleObject(int hHandle, int dwMilliseconds);
[DllImport('coredll.dll', EntryPoint = 'CreateEvent')]
private static extern int CreateEvent(int lpEventAttributes, int bManualReset, int bInitialState, int lpName);
[DllImport('coredll.dll', EntryPoint = 'EventModify')]
private static extern bool EventModify(int h, int i);
[DllImport('coredll.dll', EntryPoint = 'WaitForMultipleObjects')]
private static extern int WaitForMultipleObjects(uint nCount, int[] lpHandles, int bWaitAll, int dwMilliseconds);
[DllImport('coredll.dll', EntryPoint = 'CloseHandle')]
private static extern int CloseHandle(int hObject);
static int hEvt;
static void Main(string[] args)
{
hEvt = CreateEvent(0, 1, 0, 0); // CreateEvent(NULL,TRUE,FALSE,NULL)
EventModify(hEvt, 2); // ResetEvent(hEvt);
Thread t = new Thread(excute);
t.Start();
Thread.Sleep(1000);
EventModify(hEvt, 3); // SetEvent(hEvt);
Thread.Sleep(10000);
EventModify(hEvt, 3); // SetEvent(hEvt);
CloseHandle(hEvt);
}
static void excute()
{
int i;
for (; ; )
{
i = WaitForSingleObject(hEvt, -1); // 無(wú)限等待
// i = WaitForSingleObject(hEvt, 1000); // 等待1秒
EventModify(hEvt, 2); // ResetEvent(hEvt);
Console.Write('event');
}
}
}
}

這里使用了API函數(shù)，所以需要添加引用

using System.Runtime.InteropServices;

通過(guò)CreateEvent創(chuàng)建一個(gè)事件，并獲得該事件句柄。這里參數(shù)一般使用（NULL,TRUE,FALSE,NULL），即(0, 1, 0, 0)

通過(guò)EventModify(hEvt, 2)將該事件的信號(hào)設(shè)置為無(wú)信號(hào)，該函數(shù)第一個(gè)參數(shù)為設(shè)置的事件句柄，第二個(gè)參數(shù)為2表示ResetEvent，第二個(gè)參數(shù)為3表示SetEvent。

hEvt = CreateEvent(0, 1, 0, 0); // CreateEvent(NULL,TRUE,FALSE,NULL)

EventModify(hEvt, 2); // ResetEvent(hEvt);

在線(xiàn)程中調(diào)用WaitForSingleObject函數(shù)等待事件，第一個(gè)參數(shù)為等待的事件句柄，第二個(gè)參數(shù)為等待的時(shí)間，如果為INFINITE即-1，表示一直等待，直到收到事件消息。該函數(shù)返回0表示接收到消息，返回0x102表示未接收到消息等待超時(shí)

i = WaitForSingleObject(hEvt, -1); // 無(wú)限等待

當(dāng)主線(xiàn)程執(zhí)行SetEvent即EventModify(hEvt, 3)時(shí)，掛起的副線(xiàn)程將被激活

EventModify(hEvt, 3); // SetEvent(hEvt);

在接收到信號(hào)的處理代碼里，需要重新將事件設(shè)置為未激活狀態(tài)，否則WaitForSingleObject函數(shù)將判定事件為激活狀態(tài)，不再發(fā)生等待

EventModify(hEvt, 2); // ResetEvent(hEvt);

在程序結(jié)束處，記得用CloseHandle關(guān)閉創(chuàng)建的事件

CloseHandle(hEvt);

使用API函數(shù)的事件響應(yīng)與使用C#的事件類(lèi)作用相同，因?yàn)槭褂昧司浔鍪录臉?biāo)志，就可以與C的代碼進(jìn)行交互，以英創(chuàng)ARM9系列嵌入式主板EM9161的CAN口數(shù)據(jù)接收線(xiàn)程為例。

設(shè)定一個(gè)線(xiàn)程用于CAN口的接收，創(chuàng)建一個(gè)事件用于通知線(xiàn)程關(guān)閉

private Thread revThread;

hCloseEvent = CreateEvent(0, 1, 0, 0); // CreateEvent(NULL,TRUE,FALSE,NULL)

打開(kāi)CAN口后，通過(guò)COM組件接口函數(shù)獲得CAN的消息事件句柄

hEvent = CAN.CAN_GetRxEvent(hCAN);
hErr = CAN.CAN_GetErrorEvent(hCAN);

設(shè)定一個(gè)接收線(xiàn)程專(zhuān)門(mén)處理CAN口接收。
revThread = new Thread(new ThreadStart(BeginReceive));
threadStop = false;
revThread.Start(); // 啟動(dòng)waitforMessage線(xiàn)程

在接收函數(shù)中，執(zhí)行等待，直到有CAN口接收消息到來(lái)，或是接收到線(xiàn)程關(guān)閉的事件。

private void BeginReceive() // 客戶(hù)機(jī)狀態(tài)下接收數(shù)據(jù)線(xiàn)程
{
int[] handles = new int[2];
handles[0] = hCloseEvent;
handles[1] = hEvent;
int i;
bool bResult;
string revstr;
while (!threadStop)
{
// WaitForSingleObject(hEvent, 200);
i = WaitForMultipleObjects(2, handles, 0, -1); // handles里的兩個(gè)事件hEvent和hCloseEvent
// ….其他的處理代碼

}

}

這里使用了WaitForMultipleObjects來(lái)同時(shí)等待2個(gè)事件，第一個(gè)參數(shù)為等待的事件數(shù)。第二個(gè)參數(shù)為各事件的數(shù)組。第三個(gè)參數(shù)為FALSE即0表示當(dāng)任何一個(gè)事件產(chǎn)生，該函數(shù)即返回，第三個(gè)參數(shù)為T(mén)RUE即1表示只有當(dāng)所有事件都產(chǎn)生，該函數(shù)才返回。最后個(gè)參數(shù)為等待的時(shí)間。返回值為0x102表示超時(shí)，返回0-X表示接收的事件在數(shù)組中的位置，同時(shí)接收多個(gè)事件，返回的第一個(gè)事件在數(shù)組中的位置。

更詳細(xì)的完整代碼，請(qǐng)參考英創(chuàng)ARM9系列嵌入式主板EM9161的CAN事件接口例程。

8、等待線(xiàn)程

C#使用Thread類(lèi)的Join函數(shù)來(lái)等待一個(gè)線(xiàn)程

using System;
using System.Threading;
namespace thread
{
class Program
{
static int i;
static void Main(string[] args)
{
Thread t = new Thread(excute);
t.Start();
for (i = 0; i < 10; i++)
{
Console.Write('2');
}
t.Join();
// t.Join(1000);
for (; ; )
{
Console.Write('2');
}
}
static void excute()
{
for (; ;)
{
Console.Write('1');
}
}
}
}

該函數(shù)不帶參數(shù)表示一直等待到線(xiàn)程結(jié)束，帶參數(shù)表示等待的時(shí)間，返回true表示線(xiàn)程已結(jié)束，返回false表示線(xiàn)程還在運(yùn)行，只是超時(shí)返回。

在主函數(shù)關(guān)閉前，應(yīng)使用Join函數(shù)來(lái)確保各支線(xiàn)程已完全關(guān)閉，否則會(huì)導(dǎo)致進(jìn)程無(wú)法完全關(guān)閉。

9、其他

在關(guān)閉程序進(jìn)程時(shí)，請(qǐng)確保關(guān)閉所有創(chuàng)建的線(xiàn)程，否則進(jìn)程將無(wú)法完全關(guān)閉，并一直占用系統(tǒng)資源。在英創(chuàng)ARM9系列嵌入式主板程序開(kāi)發(fā)中，可以結(jié)合VS自帶的遠(yuǎn)程線(xiàn)程查看工具進(jìn)行程序調(diào)試。