很多時候寫
windows
程序都需要結合多線程,在
.net
中用如下得代碼來創建并啟動一個新的線程。
public
void ThreadProc();
Thread thread = new Thread( new ThreadStart( ThreadProc ) );
thread.IsBackground = true;
thread.Start();
但是很多時候,在新的線程中,我們需要與
UI
進行交互,在
.net
中不允許我們直接這樣做。可以參考
MSDN
中的描述:
“Windows
窗體”使用單線程單元 (STA) 模型,因為“Windows 窗體”基于本機 Win32 窗口,而 Win32 窗口從本質上而言是單元線程。STA 模型意味著可以在任何線程上創建窗口,但窗口一旦創建后就不能切換線程,并且對它的所有函數調用都必須在其創建線程上發生。除了 Windows 窗體之外,.NET Framework 中的類使用自由線程模型。
STA
模型要求需從控件的非創建線程調用的控件上的任何方法必須被封送到(在其上執行)該控件的創建線程。基類 Control 為此目的提供了若干方法(Invoke、BeginInvoke 和 EndInvoke)。Invoke生成同步方法調用;BeginInvoke生成異步方法調用。
Windows
窗體中的控件被綁定到特定的線程,不具備線程安全性。因此,如果從另一個線程調用控件的方法,那么必須使用控件的一個 Invoke 方法來將調用封送到適當的線程。
正如所看到的,我們必須調用
Invoke
方法,而
BeginInvoke
可以認為是
Invoke
的異步版本。調用方法如下:
public
delegate
void OutDelegate(string text);
public
void OutText(string text)
{
???? txt.AppendText(text);
???? txt.AppendText( "\t\n" );
}
OutDelegate outdelegate = new OutDelegate( OutText );
this
.BeginInvoke(outdelegate, newobject[]{text});
如果我們需要在另外一個線程里面對
UI
進行操作,我們需要一個類似
OutText
的函數,還需要一個該函數的委托
delegate
,當然,這里展示的是自定義的,
.net
中還有很多其他類型的委托,可以直接使用,不需要而外聲明。例如:
MethodInvoker
和
EventHandler
,這兩種類型委托的函數外觀是固定的,
MethodInvoker
是
void Function()
類型的委托,而
EventHandler
是
void Function(object, EventArgs)
類型的委托,第一個不支持參數,第二中的參數類型和數量都是固定的,這兩種委托可以很方便的調用,但是缺乏靈活性。請注意
BeginInvoke
前面的對象是
this
,也就是主線程。現在再介紹
Control.InvokeRequired
,
Control
是所有控件的基類,對于這個屬性
MSDN
的描述是:
獲取一個值,該值指示調用方在對控件進行方法調用時是否必須調用
Invoke
方法,因為調用方位于創建控件所在的線程以外的線程中。
該屬性可用于確定是否必須調用
Invoke
方法,當不知道什么線程擁有控件時這很有用。
也就是說通過判斷
InvokeRequired
可以知道是否需要用委托來調用當前控件的一些方法,如此可以把
OutText
函數修改一下:
public
delegate
void OutDelegate(string text);
public
void OutText(string text)
{
????
if( txt.InvokeRequired )
???? {
???????? OutDelegate outdelegate = new OutDelegate( OutText );
????????
this.BeginInvoke(outdelegate, newobject[]{text});
????????
return;
???? }
???? txt.AppendText(text);
???? txt.AppendText( "\t\n" );
}
注意,這里的函數沒有返回,如果有返回,需要調用
Invoke
或者
EndInvoke
來獲得返回的結果,不要因為包裝而丟失了返回值。如果調用沒有完成,
Invoke
和
EndInvoke
都將會引起阻塞。
現在如果我有一個線程函數如下:
public
void ThreadProc()
{
????
for(int i = 0; i < 5; i++)
???? {
???????? OutText( i.ToString() );
???????? Thread.Sleep(1000);
???? }
}
如果循環的次數很大,或者漏了
Thread.Sleep(1000);
,那么你的
UI
肯定會停止響應,想知道原因嗎?看看
BeginInvoke
前面的對象,沒錯,就是
this
,也就是主線程,當你的主線程不停的調用
OutText
的時候,
UI
當然會停止響應。
?
與以前
VC
中創建一個新的線程需要調用
AfxBeginThread
函數,該函數中第一個參數就是線程函數的地址,而第二個參數是一個類型為
LPVOID
的指針類型,這個參數將傳遞給線程函數。現在我們沒有辦法再使用這種方法來傳遞參數了。我們需要將傳遞給線程的參數和線程函數包裝成一個單獨的類,然后在這個類的構造函數中初始化該線程所需的參數,然后再將該實例的線程函數傳遞給
Thread
類的構造函數。代碼大致如下:
public
class ProcClass
{
????
private
string procParameter = "";
????
public ProcClass(string parameter)
???? {
???????? procParameter = parameter;
???? }
????
public
void ThreadProc()
???? {
???? }
}
ProcClass threadProc = new ProcClass("use thread class");
Thread thread = new Thread( new ThreadStart( threadProc.ThreadProc ) );
thread.IsBackground = true;
thread.Start();
就是這樣,需要建立一個中間類來傳遞線程所需的參數。
那么如果我的線程又需要參數,又需要和
UI
進行交互的時候該怎么辦呢?可以修改一下代碼:
public
class ProcClass
{
????
private
string procParameter = "";
????
private Form1.OutDelegate delg = null;
????
public ProcClass(string parameter, Form1.OutDelegate delg)
???? {
???????? procParameter = parameter;
????????
this.delg = delg;
???? }
????
public
void ThreadProc()
???? {
???????? delg.BeginInvoke("use ProcClass.ThreadProc()", null, null);
???? }
}
ProcClass threadProc = new ProcClass("use thread class", new OutDelegate(OutText));
Thread thread = new Thread( new ThreadStart( threadProc.ThreadProc ) );
thread.IsBackground = true;
thread.Start();
這里只是我的一些理解,如果有什么錯誤或者不當的地方,歡迎指出。