C#多线程

1、基本概念express

一、进程编程

首先打开任务管理器,查看当前运行的进程:c#

从任务管理器里面能够看到当前全部正在运行的进程。那么究竟什么是进程呢?安全

进程(Process)是Windows系统中的一个基本概念,它包含着一个运行程序所须要的资源。一个正在运行的应用程序在操做系统中被视为一个进程,进程能够包括一个或多个线程。线程是操做系统分配处理器时间的基本单元,在进程中能够有多个线程同时执行代码。进程之间是相对独立的,一个进程没法访问另外一个进程的数据(除非利用分布式计算方式),一个进程运行的失败也不会影响其余进程的运行,Windows系统就是利用进程把工做划分为多个独立的区域的。进程能够理解为一个程序的基本边界。是应用程序的一个运行例程,是应用程序的一次动态执行过程。网络

2、线程多线程

在任务管理器里面查询当前总共运行的线程数:并发

线程(Thread)是进程中的基本执行单元,是操做系统分配CPU时间的基本单位,一个进程能够包含若干个线程,在进程入口执行的第一个线程被视为这个进程的主线程。在.NET应用程序中,都是以Main()方法做为入口的,当调用此方法时系统就会自动建立一个主线程。线程主要是由CPU寄存器、调用栈和线程本地存储器(Thread Local Storage,TLS)组成的。CPU寄存器主要记录当前所执行线程的状态,调用栈主要用于维护线程所调用到的内存与数据,TLS主要用于存放线程的状态信息。框架

2、多线程异步

多线程的优势:能够同时完成多个任务;可使程序的响应速度更快;可让占用大量处理时间的任务或当前没有进行处理的任务按期将处理时间让给别的任务;能够随时中止任务;能够设置每一个任务的优先级以优化程序性能。async

那么可能有人会问:为何能够多线程执行呢?总结起来有下面两方面的缘由:

一、CPU运行速度太快,硬件处理速度跟不上,因此操做系统进行分时间片管理。这样,从宏观角度来讲是多线程并发的,由于CPU速度太快,察觉不到,看起来是同一时刻执行了不一样的操做。可是从微观角度来说,同一时刻只能有一个线程在处理。

二、目前电脑都是多核多CPU的,一个CPU在同一时刻只能运行一个线程,可是多个CPU在同一时刻就能够运行多个线程。

然而,多线程虽然有不少优势,可是也必须认识到多线程可能存在影响系统性能的不利方面,才能正确使用线程。不利方面主要有以下几点:

(1)线程也是程序,因此线程须要占用内存,线程越多,占用内存也越多。

(2)多线程须要协调和管理,因此须要占用CPU时间以便跟踪线程。

(3)线程之间对共享资源的访问会相互影响,必须解决争用共享资源的问题。

(4)线程太多会致使控制太复杂,最终可能形成不少程序缺陷。

当启动一个可执行程序时,将建立一个主线程。在默认的状况下,C#程序具备一个线程,此线程执行程序中以Main方法开始和结束的代码,Main()方法直接或间接执行的每个命令都有默认线程(主线程)执行,当Main()方法返回时此线程也将终止。

一个进程能够建立一个或多个线程以执行与该进程关联的部分程序代码。在C#中,线程是使用Thread类处理的,该类在System.Threading命名空间中。使用Thread类建立线程时,只须要提供线程入口,线程入口告诉程序让这个线程作什么。经过实例化一个Thread类的对象就能够建立一个线程。建立新的Thread对象时,将建立新的托管线程。Thread类接收一个ThreadStart委托或ParameterizedThreadStart委托的构造函数,该委托包装了调用Start方法时由新线程调用的方法,示例代码以下:

Thread thread=new Thread(new ThreadStart(method));//建立线程

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

上面代码实例化了一个Thread对象,并指明将要调用的方法method(),而后启动线程。ThreadStart委托中做为参数的方法不须要参数,而且没有返回值。ParameterizedThreadStart委托一个对象做为参数,利用这个参数能够很方便地向线程传递参数,示例代码以下:

Thread thread=new Thread(new ParameterizedThreadStart(method));//建立线程

thread.Start(3);                                                                             //启动线程

建立多线程的步骤:
一、编写线程所要执行的方法
二、实例化Thread类,并传入一个指向线程所要执行方法的委托。(这时线程已经产生,但尚未运行)
三、调用Thread实例的Start方法,标记该线程能够被CPU执行了,但具体执行时间由CPU决定

2.1 System.Threading.Thread类

Thread类是是控制线程的基础类,位于System.Threading命名空间下,具备4个重载的构造函数:

名称 说明
Thread(ParameterizedThreadStart)

初始化 Thread 类的新实例,指定容许对象在线程启动时传递给线程的委托。要执行的方法是有参的。

Thread(ParameterizedThreadStart, Int32) 初始化 Thread 类的新实例,指定容许对象在线程启动时传递给线程的委托,并指定线程的最大堆栈大小
Thread(ThreadStart)

初始化 Thread 类的新实例。要执行的方法是无参的。

Thread(ThreadStart, Int32)

初始化 Thread 类的新实例,指定线程的最大堆栈大小。

ThreadStart是一个无参的、返回值为void的委托。委托定义以下:

public delegate void ThreadStart()

经过ThreadStart委托建立并运行一个线程:

 1  class Program
 2     {
 3         static void Main(string[] args)
 4         {
 5             //建立无参的线程
 6             Thread thread1 = new Thread(new ThreadStart(Thread1));
 7             //调用Start方法执行线程
 8             thread1.Start();
 9 
10             Console.ReadKey();
11         }
12 
13         /// <summary>
14         /// 建立无参的方法
15         /// </summary>
16         static void Thread1()
17         {
18             Console.WriteLine("这是无参的方法");
19         }
20     }

运行结果

除了能够运行静态的方法,还能够运行实例方法

 1  class Program
 2     {
 3         static void Main(string[] args)
 4         {
 5             //建立ThreadTest类的一个实例
 6             ThreadTest test=new ThreadTest();
 7             //调用test实例的MyThread方法
 8             Thread thread = new Thread(new ThreadStart(test.MyThread));
 9             //启动线程
10             thread.Start();
11             Console.ReadKey();
12         }
13     }
14 
15     class ThreadTest
16     {
17         public void MyThread()
18         {
19             Console.WriteLine("这是一个实例方法");
20         }
21     }

运行结果:

若是为了简单,也能够经过匿名委托或Lambda表达式来为Thread的构造方法赋值

 1  static void Main(string[] args)
 2  {
 3        //经过匿名委托建立
 4        Thread thread1 = new Thread(delegate() { Console.WriteLine("我是经过匿名委托建立的线程"); });
 5        thread1.Start();
 6        //经过Lambda表达式建立
 7        Thread thread2 = new Thread(() => Console.WriteLine("我是经过Lambda表达式建立的委托"));
 8        thread2.Start();
 9        Console.ReadKey();
10  }

 

 运行结果:

ParameterizedThreadStart是一个有参的、返回值为void的委托,定义以下:

public delegate void ParameterizedThreadStart(Object obj)

 1  class Program
 2     {
 3         static void Main(string[] args)
 4         {
 5             //经过ParameterizedThreadStart建立线程
 6             Thread thread = new Thread(new ParameterizedThreadStart(Thread1));
 7             //给方法传值
 8             thread.Start("这是一个有参数的委托");
 9             Console.ReadKey();
10         }
11 
12         /// <summary>
13         /// 建立有参的方法
14         /// 注意:方法里面的参数类型必须是Object类型
15         /// </summary>
16         /// <param name="obj"></param>
17         static void Thread1(object obj)
18         {
19             Console.WriteLine(obj);
20         }
21     }

注意:ParameterizedThreadStart委托的参数类型必须是Object的。若是使用的是不带参数的委托,不能使用带参数的Start方法运行线程,不然系统会抛出异常。但使用带参数的委托,可使用thread.Start()来运行线程,这时所传递的参数值为null。

2.2 线程的经常使用属性

属性名称 说明
CurrentContext 获取线程正在其中执行的当前上下文。
CurrentThread 获取当前正在运行的线程。
ExecutionContext 获取一个 ExecutionContext 对象,该对象包含有关当前线程的各类上下文的信息。
IsAlive 获取一个值,该值指示当前线程的执行状态。
IsBackground 获取或设置一个值,该值指示某个线程是否为后台线程。
IsThreadPoolThread 获取一个值,该值指示线程是否属于托管线程池。
ManagedThreadId 获取当前托管线程的惟一标识符。
Name 获取或设置线程的名称。
Priority 获取或设置一个值,该值指示线程的调度优先级。
ThreadState 获取一个值,该值包含当前线程的状态。

2.2.1 线程的标识符

ManagedThreadId是确认线程的惟一标识符,程序在大部分状况下都是经过Thread.ManagedThreadId来辨别线程的。而Name是一个可变值,在默认时候,Name为一个空值 Null,开发人员能够经过程序设置线程的名称,但这只是一个辅助功能。

 

2.2.2 线程的优先级别

当线程之间争夺CPU时间时,CPU按照线程的优先级给予服务。高优先级的线程能够彻底阻止低优先级的线程执行。.NET为线程设置了Priority属性来定义线程执行的优先级别,里面包含5个选项,其中Normal是默认值。除非系统有特殊要求,不然不该该随便设置线程的优先级别。

成员名称 说明
Lowest 能够将 Thread 安排在具备任何其余优先级的线程以后。
BelowNormal 能够将 Thread 安排在具备 Normal 优先级的线程以后,在具备 Lowest 优先级的线程以前。
Normal 默认选择。能够将 Thread 安排在具备 AboveNormal 优先级的线程以后,在具备 BelowNormal 优先级的线程以前
AboveNormal 能够将 Thread 安排在具备 Highest 优先级的线程以后,在具备 Normal 优先级的线程以前。
Highest 能够将 Thread 安排在具备任何其余优先级的线程以前。

 

2.2.3 线程的状态

经过ThreadState能够检测线程是处于Unstarted、Sleeping、Running 等等状态,它比 IsAlive 属性能提供更多的特定信息。

前面说过,一个应用程序域中可能包括多个上下文,而经过CurrentContext能够获取线程当前的上下文。

CurrentThread是最经常使用的一个属性,它是用于获取当前运行的线程。

 

2.2.4 System.Threading.Thread的方法

Thread 中包括了多个方法来控制线程的建立、挂起、中止、销毁,之后来的例子中会常用。

方法名称 说明
Abort()     终止本线程。
GetDomain() 返回当前线程正在其中运行的当前域。
GetDomainId() 返回当前线程正在其中运行的当前域Id。
Interrupt() 中断处于 WaitSleepJoin 线程状态的线程。
Join() 已重载。 阻塞调用线程,直到某个线程终止时为止。
Resume() 继续运行已挂起的线程。
Start()   执行本线程。
Suspend() 挂起当前线程,若是当前线程已属于挂起状态则此不起做用
Sleep()   把正在运行的线程挂起一段时间。

线程示例

 1     static void Main(string[] args)
 2         {
 3             //获取正在运行的线程
 4             Thread thread = Thread.CurrentThread;
 5             //设置线程的名字
 6             thread.Name = "主线程";
 7             //获取当前线程的惟一标识符
 8             int id = thread.ManagedThreadId;
 9             //获取当前线程的状态
10             ThreadState state= thread.ThreadState;
11             //获取当前线程的优先级
12             ThreadPriority priority= thread.Priority;
13             string strMsg = string.Format("Thread ID:{0}\n" + "Thread Name:{1}\n" +
14                 "Thread State:{2}\n" + "Thread Priority:{3}\n", id, thread.Name,
15                 state, priority);
16 
17             Console.WriteLine(strMsg);
18                       
19             Console.ReadKey();
20         }

运行结果:

2.3 前台线程和后台线程

前台线程:只有全部的前台线程都结束,应用程序才能结束。默认状况下建立的线程
              都是前台线程
后台线程:只要全部的前台线程结束,后台线程自动结束。经过Thread.IsBackground设置后台线程。必须在调用Start方法以前设置线程的类型,不然一旦线程运行,将没法改变其类型。

经过BeginXXX方法运行的线程都是后台线程。

 1 class Program
 2     {
 3         static void Main(string[] args)
 4         {                   
 5             //演示前台、后台线程
 6             BackGroundTest background = new BackGroundTest(10);
 7             //建立前台线程
 8             Thread fThread = new Thread(new ThreadStart(background.RunLoop));
 9             //给线程命名
10             fThread.Name = "前台线程";
11             
12 
13             BackGroundTest background1 = new BackGroundTest(20);
14             //建立后台线程
15             Thread bThread = new Thread(new ThreadStart(background1.RunLoop));
16             bThread.Name = "后台线程";
17             //设置为后台线程
18             bThread.IsBackground = true;
19 
20             //启动线程
21             fThread.Start();
22             bThread.Start();
23         }
24     }
25 
26     class BackGroundTest
27     {
28         private int Count;
29         public BackGroundTest(int count)
30         {
31             this.Count = count;
32         }
33         public void RunLoop()
34         {
35             //获取当前线程的名称
36             string threadName = Thread.CurrentThread.Name;
37             for (int i = 0; i < Count; i++)
38             {
39                 Console.WriteLine("{0}计数:{1}",threadName,i.ToString());
40                 //线程休眠500毫秒
41                 Thread.Sleep(1000);
42             }
43             Console.WriteLine("{0}完成计数",threadName);
44             
45         }
46     }

运行结果:前台线程执行完,后台线程未执行完,程序自动结束。

把bThread.IsBackground = true注释掉,运行结果:主线程执行完毕后(Main函数),程序并未结束,而是要等全部的前台线程结束之后才会结束。

后台线程通常用于处理不重要的事情,应用程序结束时,后台线程是否执行完成对整个应用程序没有影响。若是要执行的事情很重要,须要将线程设置为前台线程。

2.4 线程同步

所谓同步:是指在某一时刻只有一个线程能够访问变量。
若是不能确保对变量的访问是同步的,就会产生错误。
c#为同步访问变量提供了一个很是简单的方式,即便用c#语言的关键字Lock,它能够把一段代码定义为互斥段,互斥段在一个时刻内只容许一个线程进入执行,而其余线程必须等待。在c#中,关键字Lock定义以下:
Lock(expression)
{
   statement_block
}

expression表明你但愿跟踪的对象:
           若是你想保护一个类的实例,通常地,你可使用this;
           若是你想保护一个静态变量(如互斥代码段在一个静态方法内部),通常使用类名就能够了
而statement_block就算互斥段的代码,这段代码在一个时刻内只可能被一个线程执行。

以书店卖书为例

 1 class Program
 2     {
 3         static void Main(string[] args)
 4         {                   
 5             BookShop book = new BookShop();
 6             //建立两个线程同时访问Sale方法
 7             Thread t1 = new Thread(new ThreadStart(book.Sale));
 8             Thread t2 = new Thread(new ThreadStart(book.Sale));
 9             //启动线程
10             t1.Start();
11             t2.Start();
12             Console.ReadKey();
13         }
14     }
15 
16    
17 
18     class BookShop
19     {
20         //剩余图书数量
21         public int num = 1;
22         public void Sale()
23         {
24             int tmp = num;
25             if (tmp > 0)//判断是否有书,若是有就能够卖
26             {
27                 Thread.Sleep(1000);
28                 num -= 1;
29                 Console.WriteLine("售出一本图书,还剩余{0}本", num);
30             }
31             else
32             {
33                 Console.WriteLine("没有了");
34             }
35         }
36     }

运行结果:

从运行结果能够看出,两个线程同步访问共享资源,没有考虑同步的问题,结果不正确。

考虑线程同步,改进后的代码:

 1 class Program
 2     {
 3         static void Main(string[] args)
 4         {                   
 5             BookShop book = new BookShop();
 6             //建立两个线程同时访问Sale方法
 7             Thread t1 = new Thread(new ThreadStart(book.Sale));
 8             Thread t2 = new Thread(new ThreadStart(book.Sale));
 9             //启动线程
10             t1.Start();
11             t2.Start();
12             Console.ReadKey();
13         }
14     }
15 
16    
17 
18     class BookShop
19     {
20         //剩余图书数量
21         public int num = 1;
22         public void Sale()
23         {
24             //使用lock关键字解决线程同步问题
25             lock (this)
26             {
27                 int tmp = num;
28                 if (tmp > 0)//判断是否有书,若是有就能够卖
29                 {
30                     Thread.Sleep(1000);
31                     num -= 1;
32                     Console.WriteLine("售出一本图书,还剩余{0}本", num);
33                 }
34                 else
35                 {
36                     Console.WriteLine("没有了");
37                 }
38             }
39         }
40     }

运行结果:

2.5 跨线程访问

点击“测试”,建立一个线程,从0循环到10000给文本框赋值,代码以下:

 1  private void btn_Test_Click(object sender, EventArgs e)
 2         {
 3             //建立一个线程去执行这个方法:建立的线程默认是前台线程
 4             Thread thread = new Thread(new ThreadStart(Test));
 5             //Start方法标记这个线程就绪了,能够随时被执行,具体何时执行这个线程,由CPU决定
 6             //将线程设置为后台线程
 7             thread.IsBackground = true;
 8             thread.Start();
 9         }
10 
11         private void Test()
12         {
13             for (int i = 0; i < 10000; i++)
14             {               
15                 this.textBox1.Text = i.ToString();
16             }
17         }

运行结果:

产生错误的缘由:textBox1是由主线程建立的,thread线程是另外建立的一个线程,在.NET上执行的是托管代码,C#强制要求这些代码必须是线程安全的,即不容许跨线程访问Windows窗体的控件。

解决方案:

一、在窗体的加载事件中,将C#内置控件(Control)类的CheckForIllegalCrossThreadCalls属性设置为false,屏蔽掉C#编译器对跨线程调用的检查。

 private void Form1_Load(object sender, EventArgs e)
 {
        //取消跨线程的访问
        Control.CheckForIllegalCrossThreadCalls = false;
 }

使用上述的方法虽然能够保证程序正常运行并实现应用的功能,可是在实际的软件开发中,作如此设置是不安全的(不符合.NET的安全规范),在产品软件的开发中,此类状况是不容许的。若是要在遵照.NET安全标准的前提下,实现从一个线程成功地访问另外一个线程建立的空间,要使用C#的方法回调机制。

二、使用回调函数

回调实现的通常过程:

 C#的方法回调机制,也是创建在委托基础上的,下面给出它的典型实现过程。

(1)、定义、声明回调。

1 //定义回调
2 private delegate void DoSomeCallBack(Type para);
3 //声明回调
4 DoSomeCallBack doSomaCallBack;

能够看出,这里定义声明的“回调”(doSomaCallBack)其实就是一个委托。

(2)、初始化回调方法。

doSomeCallBack=new DoSomeCallBack(DoSomeMethod);

所谓“初始化回调方法”实际上就是实例化刚刚定义了的委托,这里做为参数的DoSomeMethod称为“回调方法”,它封装了对另外一个线程中目标对象(窗体控件或其余类)的操做代码。

(3)、触发对象动做

Opt  obj.Invoke(doSomeCallBack,arg);

其中Opt obj为目标操做对象,在此假设它是某控件,故调用其Invoke方法。Invoke方法签名为:

object  Control.Invoke(Delegate  method,params  object[] args);

它的第一个参数为委托类型,可见“触发对象动做”的本质,就是把委托doSomeCallBack做为参数传递给控件的Invoke方法,这与委托的使用方式是如出一辙的。

最终做用于对象Opt obj的代码是置于回调方法体DoSomeMethod()中的,以下所示:

private void DoSomeMethod(type para)

{

     //方法体

    Opt obj.someMethod(para);

}

若是不用回调,而是直接在程序中使用“Opt obj.someMethod(para);”,则当对象Opt obj不在本线程(跨线程访问)时就会发生上面所示的错误。

从以上回调实现的通常过程可知:C#的回调机制,实质上是委托的一种应用。在C#网络编程中,回调的应用是很是广泛的,有了方法回调,就能够在.NET上写出线程安全的代码了。

使用方法回调,实现给文本框赋值:

 1 namespace MultiThreadDemo
 2 {
 3     public partial class Form1 : Form
 4     {
 5         public Form1()
 6         {
 7             InitializeComponent();
 8         }
 9 
10         //定义回调
11         private delegate void setTextValueCallBack(int value);
12         //声明回调
13         private setTextValueCallBack setCallBack;
14 
15         private void btn_Test_Click(object sender, EventArgs e)
16         {
17             //实例化回调
18             setCallBack = new setTextValueCallBack(SetValue);
19             //建立一个线程去执行这个方法:建立的线程默认是前台线程
20             Thread thread = new Thread(new ThreadStart(Test));
21             //Start方法标记这个线程就绪了,能够随时被执行,具体何时执行这个线程,由CPU决定
22             //将线程设置为后台线程
23             thread.IsBackground = true;
24             thread.Start();
25         }
26 
27         private void Test()
28         {
29             for (int i = 0; i < 10000; i++)
30             {               
31                 //使用回调
32                 textBox1.Invoke(setCallBack, i);
33             }
34         }
35 
36         /// <summary>
37         /// 定义回调使用的方法
38         /// </summary>
39         /// <param name="value"></param>
40         private void SetValue(int value)
41         {
42             this.textBox1.Text = value.ToString();
43         }
44     }
45 }

 2.6 终止线程

若想终止正在运行的线程,可使用Abort()方法。

3、同步和异步

同步和异步是对方法执行顺序的描述。

同步:等待上一行完成计算以后,才会进入下一行。

例如:请同事吃饭,同事说很忙,而后就等着同事忙完,而后一块儿去吃饭。

异步:不会等待方法的完成,会直接进入下一行,是非阻塞的。

例如:请同事吃饭,同事说很忙,那同事先忙,本身去吃饭,同事忙完了他本身去吃饭。

下面经过一个例子讲解同步和异步的区别

一、新建一个winform程序,上面有两个按钮,一个同步方法、一个异步方法,在属性里面把输出类型改为控制台应用程序,这样能够看到输出结果,代码以下:

 1 using System;
 2 using System.Collections.Generic;
 3 using System.ComponentModel;
 4 using System.Data;
 5 using System.Drawing;
 6 using System.Linq;
 7 using System.Text;
 8 using System.Threading;
 9 using System.Threading.Tasks;
10 using System.Windows.Forms;
11 
12 namespace MyAsyncThreadDemo
13 {
14     public partial class Form1 : Form
15     {
16         public Form1()
17         {
18             InitializeComponent();
19         }
20 
21         /// <summary>
22         /// 异步方法
23         /// </summary>
24         /// <param name="sender"></param>
25         /// <param name="e"></param>
26         private void btnAsync_Click(object sender, EventArgs e)
27         {
28             Console.WriteLine($"***************btnAsync_Click Start {Thread.CurrentThread.ManagedThreadId}");
29             Action<string> action = this.DoSomethingLong;
30             // 调用委托(同步调用)
31             action.Invoke("btnAsync_Click_1");
32             // 异步调用委托
33             action.BeginInvoke("btnAsync_Click_2",null,null);
34             Console.WriteLine($"***************btnAsync_Click End    {Thread.CurrentThread.ManagedThreadId}");
35         }
36 
37         /// <summary>
38         /// 同步方法
39         /// </summary>
40         /// <param name="sender"></param>
41         /// <param name="e"></param>
42         private void btnSync_Click(object sender, EventArgs e)
43         {
44             Console.WriteLine($"****************btnSync_Click Start {Thread.CurrentThread.ManagedThreadId.ToString("00")} {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}***************");
45             int j = 3;
46             int k = 5;
47             int m = j + k;
48             for (int i = 0; i < 5; i++)
49             {
50                 string name = string.Format($"btnSync_Click_{i}");
51                 this.DoSomethingLong(name);
52             }
53         }
54 
55 
56         private void DoSomethingLong(string name)
57         {
58             Console.WriteLine($"****************DoSomethingLong {name} Start {Thread.CurrentThread.ManagedThreadId.ToString("00")} {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}***************");
59             long lResult = 0;
60             for (int i = 0; i < 1000000000; i++)
61             {
62                 lResult += i;
63             }
64             Console.WriteLine($"****************DoSomethingLong {name}   End {Thread.CurrentThread.ManagedThreadId.ToString("00")} {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")} {lResult}***************");
65         }
66     }
67 }

 二、启动程序,点击同步,结果以下:

从上面的截图中可以很清晰的看出:同步方法是等待上一行代码执行完毕以后才会执行下一行代码。

点击异步,结果以下:

从上面的截图中看出:当执行到action.BeginInvoke("btnAsync_Click_2",null,null);这句代码的时候,程序并无等待这段代码执行完就执行了下面的End,没有阻塞程序的执行。

在刚才的测试中,若是点击同步,这时winform界面不能拖到,界面卡住了,是由于主线程(即UI线程)在忙于计算。

点击异步的时候,界面不会卡住,这是由于主线程已经结束,计算任务交给子线程去作。

在仔细检查上面两个截图,能够看出异步的执行速度比同步执行速度要快。同步方法执行完将近16秒,异步方法执行完将近6秒。

在看下面的一个例子,修改异步的方法,也和同步方法同样执行循环,修改后的代码以下:

 1 private void btnAsync_Click(object sender, EventArgs e)
 2 {
 3       Console.WriteLine($"***************btnAsync_Click Start {Thread.CurrentThread.ManagedThreadId}");
 4       //Action<string> action = this.DoSomethingLong;
 5       //// 调用委托(同步调用)
 6       //action.Invoke("btnAsync_Click_1");
 7       //// 异步调用委托
 8       //action.BeginInvoke("btnAsync_Click_2",null,null);
 9       Action<string> action = this.DoSomethingLong;
10       for (int i = 0; i < 5; i++)
11       {
12            //Thread.Sleep(5);
13            string name = string.Format($"btnAsync_Click_{i}");
14            action.BeginInvoke(name, null, null);
15       }
16       Console.WriteLine($"***************btnAsync_Click End    {Thread.CurrentThread.ManagedThreadId}");
17 }

 结果以下:

从截图中可以看出:同步方法执行是有序的,异步方法执行是无序的。异步方法无序包括启动无序和结束无序。启动无序是由于同一时刻向操做系统申请线程,操做系统收到申请之后,返回执行的顺序是无序的,因此启动是无序的。结束无序是由于虽然线程执行的是一样的操做,可是每一个线程的耗时是不一样的,因此结束的时候不必定是先启动的线程就先结束。从上面同步方法中能够清晰的看出:btnSync_Click_0执行时间耗时不到3秒,而btnSync_Click_1执行时间耗时超过了3秒。能够想象体育比赛中的跑步,每位运动员听到发令枪起跑的顺序不一样,每位运动员花费的时间不一样,最终到达终点的顺序也不一样。

总结一下同步方法和异步方法的区别:

一、同步方法因为主线程忙于计算,因此会卡住界面。

      异步方法因为主线程执行完了,其余计算任务交给子线程去执行,因此不会卡住界面,用户体验性好。

二、同步方法因为只有一个线程在计算,因此执行速度慢。

      异步方法由多个线程并发运算,因此执行速度快,但并非线性增加的(资源可能不够)。多线程也不是越多越好,只有多个独立的任务同时运行,才能加快速度。

三、同步方法是有序的。

      异步多线程是无序的:启动无序,执行时间不肯定,因此结束也是无序的。必定不要经过等待几毫秒的形式来控制线程启动/执行时间/结束。

4、回调

先来看看异步多线程无序的例子:

在界面上新增一个按钮,实现代码以下:

1 private void btnAsyncAdvanced_Click(object sender, EventArgs e)
2 {
3       Console.WriteLine($"****************btnAsyncAdvanced_Click Start {Thread.CurrentThread.ManagedThreadId.ToString("00")} {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}***************");
4       Action<string> action = this.DoSomethingLong;
5       action.BeginInvoke("btnAsyncAdvanced_Click", null, null);
6       // 需求:异步多线程执行完以后再打印出下面这句
7       Console.WriteLine($"到这里计算已经完成了。{Thread.CurrentThread.ManagedThreadId.ToString("00")}。");
8       Console.WriteLine($"****************btnAsyncAdvanced_Click End {Thread.CurrentThread.ManagedThreadId.ToString("00")} {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}***************");
9 }

 

运行结果:

从上面的截图中看出,最终的效果并非咱们想要的效果,并且打印输出的仍是主线程。

既然异步多线程是无序的,那咱们有没有什么办法能够解决无序的问题呢?办法固然是有的,那就是使用回调,.NET框架已经帮咱们实现了回调:

BeginInvoke的第二个参数就是一个回调,那么AsyncCallback到底是什么呢?F12查看AsyncCallback的定义:

发现AsyncCallback就是一个委托,参数类型是IAsyncResult,明白了AsyncCallback是什么之后,将上面的代码进行以下的改造:

 1 private void btnAsyncAdvanced_Click(object sender, EventArgs e)
 2 {       
 3     Console.WriteLine($"****************btnAsyncAdvanced_Click Start {Thread.CurrentThread.ManagedThreadId.ToString("00")} {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}***************");
 4     Action<string> action = this.DoSomethingLong;
 5     // 定义一个回调
 6     AsyncCallback callback = p => 
 7     {
 8        Console.WriteLine($"到这里计算已经完成了。{Thread.CurrentThread.ManagedThreadId.ToString("00")}。");
 9     };
10     // 回调做为参数
11     action.BeginInvoke("btnAsyncAdvanced_Click", callback, null);          
12     Console.WriteLine($"****************btnAsyncAdvanced_Click End {Thread.CurrentThread.ManagedThreadId.ToString("00")} {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}***************");
13  }

 

运行结果:

 

上面的截图中能够看出,这就是咱们想要的效果,并且打印是子线程输出的,可是程序到底是怎么实现的呢?咱们能够进行以下的猜测:

程序执行到BeginInvoke的时候,会申请一个基于线程池的线程,这个线程会完成委托的执行(在这里就是执行DoSomethingLong()方法),在委托执行完之后,这个线程又会去执行callback回调的委托,执行callback委托须要一个IAsyncResult类型的参数,这个IAsyncResult类型的参数是如何来的呢?鼠标右键放到BeginInvoke上面,查看返回值:

发现BeginInvoke的返回值就是IAsyncResult类型的。那么这个返回值是否是就是callback委托的参数呢?将代码进行以下的修改:

 1 private void btnAsyncAdvanced_Click(object sender, EventArgs e)
 2 {
 3             // 需求:异步多线程执行完以后再打印出下面这句
 4             Console.WriteLine($"****************btnAsyncAdvanced_Click Start {Thread.CurrentThread.ManagedThreadId.ToString("00")} {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}***************");
 5             Action<string> action = this.DoSomethingLong;
 6             // 无序的
 7             //action.BeginInvoke("btnAsyncAdvanced_Click", null, null);
 8 
 9             IAsyncResult asyncResult = null;
10             // 定义一个回调
11             AsyncCallback callback = p =>
12             {
13                 // 比较两个变量是不是同一个
14                 Console.WriteLine(object.ReferenceEquals(p,asyncResult));
15                 Console.WriteLine($"到这里计算已经完成了。{Thread.CurrentThread.ManagedThreadId.ToString("00")}。");
16             };
17             // 回调做为参数
18             asyncResult= action.BeginInvoke("btnAsyncAdvanced_Click", callback, null);           
19             Console.WriteLine($"****************btnAsyncAdvanced_Click End {Thread.CurrentThread.ManagedThreadId.ToString("00")} {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}***************");
20 }

 结果:

这里能够看出BeginInvoke的返回值就是callback委托的参数。

如今咱们可使用回调解决异步多线程无序的问题了。

二、获取委托异步调用的返回值

使用EndInvoke能够获取委托异步调用的返回值,请看下面的例子:

 1 private void btnAsyncReturnVlaue_Click(object sender, EventArgs e)
 2 {
 3        // 定义一个无参数、int类型返回值的委托
 4        Func<int> func = () =>
 5        {
 6              Thread.Sleep(2000);
 7              return DateTime.Now.Day;
 8        };
 9        // 输出委托同步调用的返回值
10        Console.WriteLine($"func.Invoke()={func.Invoke()}");
11        // 委托的异步调用
12        IAsyncResult asyncResult = func.BeginInvoke(p => 
13        {
14             Console.WriteLine(p.AsyncState);
15        },"异步调用返回值");
16        // 输出委托异步调用的返回值
17        Console.WriteLine($"func.EndInvoke(asyncResult)={func.EndInvoke(asyncResult)}");
18 }

 结果:

相关文章
相关标签/搜索