快捷導(dǎo)航

詳解C#多線程編程之進(jìn)程與線程

更新時(shí)間：2020年06月22日 08:59:18 作者：白煙染黑墨

這篇文章主要介紹了詳解C#多線程編程之進(jìn)程與線程的的相關(guān)資料，文中講解非常細(xì)致，代碼幫助大家更好的理解和學(xué)習(xí)，感興趣的朋友可以了解下

一、進(jìn)程

簡單來說，進(jìn)程是對資源的抽象，是資源的容器，在傳統(tǒng)操作系統(tǒng)中，進(jìn)程是資源分配的基本單位，而且是執(zhí)行的基本單位，進(jìn)程支持并發(fā)執(zhí)行，因?yàn)槊總€(gè)進(jìn)程有獨(dú)立的數(shù)據(jù)，獨(dú)立的堆棧空間。一個(gè)程序想要并發(fā)執(zhí)行，開多個(gè)進(jìn)程即可。

Q1：在單核下，進(jìn)程之間如何同時(shí)執(zhí)行？

首先要區(qū)分兩個(gè)概念——并發(fā)和并行

并發(fā)：并發(fā)是指在一段微小的時(shí)間段中，有多個(gè)程序代碼段被CPU執(zhí)行，宏觀上表現(xiàn)出來就是多個(gè)程序能”同時(shí)“執(zhí)行。
并行：并行是指在一個(gè)時(shí)間點(diǎn)，有多個(gè)程序段代碼被CPU執(zhí)行，它才是真正的同時(shí)執(zhí)行。

所以應(yīng)該說進(jìn)程之間是并發(fā)執(zhí)行。對于CPU來講，它不知道進(jìn)程的存在，CPU主要與寄存器打交道。有一些常用的寄存器，如程序計(jì)數(shù)器寄存器，這個(gè)寄存器存儲(chǔ)了將要執(zhí)行的指令的地址，這個(gè)寄存器的地址指向哪，CPU就去哪。還有一些堆棧寄存器和通用寄存器等等等，總之，這些數(shù)據(jù)構(gòu)成了一個(gè)程序的執(zhí)行環(huán)境，這個(gè)執(zhí)行環(huán)境就叫做”上下文（Context）“，進(jìn)程之間切換本質(zhì)就是保存這些數(shù)據(jù)到內(nèi)存，術(shù)語叫做”保存現(xiàn)場“，然后恢復(fù)某個(gè)進(jìn)程的執(zhí)行環(huán)境，也即是”恢復(fù)現(xiàn)場“，整個(gè)過程術(shù)語叫做“上下文切換”，具體點(diǎn)就是進(jìn)程上下文切換，這就是進(jìn)程之間能并發(fā)執(zhí)行的本質(zhì)——頻繁的切換進(jìn)程上下文。這個(gè)功能是由操作系統(tǒng)提供的，是內(nèi)核態(tài)的，對應(yīng)用軟件開發(fā)人員透明。

二、線程

進(jìn)程雖然支持并發(fā)，但是對并發(fā)不是很友好，不友好是指每開啟一個(gè)進(jìn)程，都要重新分配一部分資源，而線程相對進(jìn)程來說，創(chuàng)建線程的代價(jià)比創(chuàng)建進(jìn)程要小，所以引入線程能更好的提高并發(fā)性。在現(xiàn)代操作系統(tǒng)中，進(jìn)程變成了資源分配的基本單位，而線程變成了執(zhí)行的基本單位，每個(gè)線程都有獨(dú)立的堆?？臻g，同一個(gè)進(jìn)程的所有線程共享代碼段和地址空間等共享資源。相應(yīng)的上下文切換從進(jìn)程上下文切換變成了線程上下文切換。

三、為什么要引入進(jìn)程和線程#

提高CPU利用率，在早期的單道批處理系統(tǒng)中，如果執(zhí)行中的代碼需要依賴與外部條件，將會(huì)導(dǎo)致CPU空閑，例如文件讀取，等待鍵盤信號輸入，這將浪費(fèi)大量的CPU時(shí)間。引入多進(jìn)程和線程可以解決CPU利用率低這個(gè)問題。
隔離程序之間的數(shù)據(jù)（每個(gè)進(jìn)程都有單獨(dú)的地址空間），保證系統(tǒng)運(yùn)行的穩(wěn)定性。
提高系統(tǒng)的響應(yīng)性和交互能力。

四、在C#中創(chuàng)建托管線程

1. Thread類

在.NET中，托管線程分為：

前臺(tái)線程
后臺(tái)線程

一個(gè).Net程序中，至少要有一個(gè)前臺(tái)線程，所有前臺(tái)線程結(jié)束了，所有的后臺(tái)線程將會(huì)被公共語言運(yùn)行時(shí)（CLR）強(qiáng)制銷毀，程序執(zhí)行結(jié)束。

如下將在控制臺(tái)程序中創(chuàng)建一個(gè)后臺(tái)線程

static void Main(string[] args)
{
   var t = new Thread(() =>
   {
     Thread.Sleep(1000);
     Console.WriteLine("執(zhí)行完畢");
   });
  t.IsBackground = true;
   t.Start();
}

主線程（默認(rèn)是前臺(tái)線程）執(zhí)行完畢，程序直接退出。

2. 有什么問題

直接使用Thread類來進(jìn)行多線程編程浪費(fèi)資源（服務(wù)器端更加明顯）且不方便，舉個(gè)栗子。

假如我寫一個(gè)Web服務(wù)器程序，每個(gè)請求創(chuàng)建一個(gè)線程，那么每一次我都要new一個(gè)Thread對象，然后傳入處理HttpRequest的委托，處理完之后，線程將會(huì)被銷毀，這將會(huì)導(dǎo)致浪費(fèi)大量CPU時(shí)間和內(nèi)存，在早期CPU性能不行和內(nèi)存資源珍貴的情況下這個(gè)缺點(diǎn)會(huì)被放大，在現(xiàn)在這個(gè)缺點(diǎn)不是很明顯，原因是硬件上來了。

不方便體現(xiàn)在哪呢？

無法直接獲取另一個(gè)線程內(nèi)未被捕捉的異常
無法直接獲取線程函數(shù)的返回值

public static void ThrowException()
{
   throw new Exception("發(fā)生異常");
}
static void Main(string[] args)
{
   var t = new Thread(() =>
   {
     Thread.Sleep(1000);
     ThrowException();
   });
  t.IsBackground = false;
   try
   {
     t.Start();
   }
   catch(Exception e)
   {
     Console.WriteLine(e.Message);
   }
}

上述代碼將會(huì)導(dǎo)致程序奔潰，如下圖。

要想直接獲取返回值和可以直接從主線程捕捉線程函數(shù)內(nèi)未捕捉的異常，我們可以這么做。

新建一個(gè)MyTask.cs文件，內(nèi)容如下

using System;
using System.Threading;
namespace ConsoleApp1
{
   public class MyTask
   {
     private Thread _thread;
     private Action _action;
     private Exception _innerException;
    public MyTask()
     {
    }
     public MyTask(Action action)
     {
       _action = action;
     }
     protected virtual void Excute()
     {
       try
       {
         _action();
       }
       catch(Exception e)
       {
         _innerException = e;
       }

     }
     public void Start()
     {
       if (_thread != null) throw new InvalidOperationException("任務(wù)已經(jīng)開始");
       _thread = new Thread(() => Excute());
       _thread.Start();
     }
     public void Start(Action action)
     {
       _action = action;
       if (_thread != null) throw new InvalidOperationException("任務(wù)已經(jīng)開始");
       _thread = new Thread(() => Excute());
       _thread.Start();
     }
    public void Wait()
     {
       _thread.Join();
       if (_innerException != null) throw _innerException;
     }
   }
  public class MyTask<T> : MyTask
   {
     private Func<T> _func { get; }
     private T _result;
     public T Result {

       private set => _result = value;
       get
       {
         base.Wait();
         return _result;
       }
     }
     public MyTask(Func<T> func)
     {
       _func = func;
     }
    public new void Start()
     {
       base.Start(() =>
       {
         Result = _func();
       });
     }
  }
}

簡單的包裝了一下（不要在意細(xì)節(jié)），我們便可以實(shí)現(xiàn)我們想要的效果。

測試代碼如下

public static void ThrowException()
{
   throw new Exception("發(fā)生異常");
}
public static void Test3()
{
   MyTask<string> myTask = new MyTask<string>(() =>
   {
     Thread.Sleep(1000);
     return "執(zhí)行完畢";
   });
  myTask.Start();
  try
   {
     Console.WriteLine(myTask.Result);
   }
   catch (Exception e)
   {
     Console.WriteLine(e.Message);
   }
}
public static void Test2()
{
   MyTask<string> myTask = new MyTask<string>(() =>
   {
     Thread.Sleep(1000);
     ThrowException();
     return "執(zhí)行完畢";
   });
  myTask.Start();
  try
   {
     Console.WriteLine(myTask.Result);
   }
   catch(Exception e)
   {
     Console.WriteLine(e.Message);
   }
}
public static void Test1()
{
   MyTask myTask = new MyTask(() =>
   {
     Thread.Sleep(1000);
     ThrowException();
   });
   myTask.Start();
  try
   {
     myTask.Wait();
   }
   catch (Exception e)
   {
     Console.WriteLine(e.Message);
   }
}
static void Main(string[] args)
{
   Test1();
   Test2();
   Test3();
}