当前位置 : 主页 > 网络编程 > c#编程 >

C#线程委托实现原理及方法解析

来源:互联网 收集:自由互联 发布时间:2021-04-07
很多时候写windows程序都需要结合多线程,在C#中用如下得代码来创建并启动一个新的线程。 Thread thread = new Thread(new ThreadStart(ThreadProc));//实例化一个线程 thread.IsBackground = true;//将线程改

很多时候写windows程序都需要结合多线程,在C#中用如下得代码来创建并启动一个新的线程。

Thread thread = new Thread(new ThreadStart(ThreadProc));//实例化一个线程

thread.IsBackground = true;//将线程改为后台线程

thread.Start();//开启线程

但是很多时候,在新的线程中,我们需要与UI(Windows窗体设计器用户界面)进行交互,在C#中不允许直接这样做。可以参考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, new object[]{text});

如果需要在另外一个线程里面对UI进行操作,需要一个类似OutText的函数,还需要一个该函数的委托delegate,当然,这里展示的是自定义的。

该属性可用于确定是否必须调用 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, new object[]{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();

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持易盾网络。

网友评论