C# 基礎知識系列- 12 任務和多線程

0. 前言

照例一份前言,在介紹任務和多線程之前,先介紹一下異步和同步的概念。我們之間介紹的知識點都是在同步執行,所謂的同步就是一行代碼一行代碼的執行,就像是我們日常乘坐地鐵通過安檢通道一樣,想像我們每個人都是一行代碼,我們依次通過安檢儀器的時候就是同步。

那麼,什麼是異步呢?有一個時間利用率的故事,講的是在燒水的同時,順便準備茶葉,清洗茶杯等工序可以節省時間。這個故事就是異步的一個典型範例。異步通俗的將就是不暫停也不等待當前耗時的流程執行完成,繼續執行後續的流程。

那麼這和任務與多線程有什麼關係呢?在C#中,基於任務可以很簡單的創建一個異步程序或者異步方法;同時任務也是一個簡單的多線程模式。不過值得注意的是,C#的異步可以由多線程實現,但多線程更多的是用來實現並行。所謂並行,顧名思義,就是多任務同時執行,這裡的任務指的是程序需要完成的事,而不是C#中的任務機制。

這一篇是《C#基礎知識系列》的一篇,簡單介紹一下如何創建、使用任務和多線程,這部分的內容很多,包括有很多注意事項,將會另開一個系列專門講解C#的異步和並行編程,名字暫定為《C#異步編程系列》。

1. 線程

了解過計算機的人可能知道程序最小執行單元是線程,最小資源分配單位是進程。進程里必然至少有一個線程,而一個程序也必然至少有一個進程。這裡不過多的介紹進程和線程的區別於關係,只需要記着線程是程序最小執行單元,我們在開發中最常用的也是線程。

在很多不太嚴謹的編程教程中,都會把多線程和並行化作等號。但是這裡有一個很微妙的區別,對於單核CPU來說,多進程和多線程一樣,都不會產生並行的效果;對於多核CPU而言,多進程必然是並行的,但是多線程則不一定並行。所以C#中,線程更多的用作異步處理上,而不是並行計算上。

在C#程序中,需要引用System.Threading。C#的入門級線程操作只需要知道Thread類、一個帶參數的無返回值方法和一個不帶參數的無返回值方法,這三個要點就可以了。

1.1 創建一個線程

var thread = new Thread(() =>
{
});

以上示例代碼演示了如果創建一個線程。但創建了線程,並不代表線程就會運行。

說到這裡就必須說一下線程的狀態,一般情況線程分為五個階段,也就是五種狀態:分別是準備、就緒、運行、阻塞、死亡。當然在不同的地方,狀態可能會細分為更多的級別,這裡只做初步的介紹。狀態之間的切換如下:

image-20200423102030652

線程的狀態之間切換順序有着嚴格的限制,而且只能從就緒態由CPU切換到運行態,運行態無法從其他狀態切換過去,而且這一步的切換開發者不能控制。

現在,我們回到線程的創建方法,先來看看Thread構造方法的聲明:

public Thread (System.Threading.ParameterizedThreadStart start);
public Thread (System.Threading.ThreadStart start);

碰到了兩個沒見過的類型,我們繼續看看?

public delegate void ParameterizedThreadStart(object obj);
public delegate void ThreadStart();

到這裡,線程的創建為我們揭開了它的謎底。根據之前《C# 基礎知識系列- 11 委託和事件》那篇的介紹,我們可以很明確的得到 ThreadStart是一個 無返回值也沒有參數的委託,而ParameterizedThreadStart表示有一個object的參數。所以,創建線程的時候,可以直接傳一個方法進去。

有的同學可能要問了,為什麼創建線程的委託參數那麼少?這裡涉及到一個並發概念,因為線程訪問過多的主線程可能會導致鎖,所以最佳的線程實踐就是讓線程的運行保持一個相對封閉的環境。

當然,C#的線程其實放寬了這部分的限制,這部分將在《C#異步編程系列》中繼續探討。

現在我們回過頭來,再看看如何創建一個標準的線程:

class Program
{
    static void Main(string[] args)
    {
        var thread1 = new Thread(ThreadTest1);
        var thread2 = new Thread(ThreadTest2);
    }

    /// <summary>
    /// 不帶參數的線程
    /// </summary>
    public static void ThreadTest1()
    {
        // 業務代碼
    }
    /// <summary>
    /// 帶參數的線程
    /// </summary>
    /// <param name="obj"></param>
    public static void ThreadTest2(object obj)
    {
        //業務代碼
    }
}

其中thread1就是一個沒有參數的線程,thread2是一個帶參數的線程。

註:Main方法是C#程序入口的固定寫法,之前所有的示例代碼都是在這個方法里執行的,後續這部分會在《C#基礎篇之開發工具和項目的基本結構》這一篇中詳細介紹,這裡先記住這是一個固定寫法。

1.2 啟動並使用線程

在啟動線程之前,我們先介紹一個概念:主線程。主線程指伴隨着當前程序啟動而啟動的線程,以代碼來看就是Main方法所在線程。

線程通過調用Thread.Start方法,來將線程標記為就緒態。

注意:線程不能直接進入運行態,該狀態只能由CPU決定。

所以上一小節的創建的兩個線程可以通過以下方式通知已經準備就續:

thread1.Start();

咦?是不是少了一個?注意力集中的小夥伴會發現,我沒有演示thread2的調用方法。thread2與threa1有個不同的地方,thread2的委託參數有一個參數。那麼必然Start也有一個對應的帶參版本的重載,所以thread2就會有以下兩種調用方式:

thread2.Start();

object obj;// 省略來源
thread2.Start(obj);

兩種方法有什麼區別嗎?

有,但是區別不大。第一種調用方式對於方法ThreadTest2而言就是參數為null,第二種就是參數為obj的值。所以第一種調用約等於thread2.Start(null)

1.3 暫停或銷毀線程

這一小節的標題是,暫停或銷毀線程。當線程運行起來後,如果沒有突發情況或者外力干涉會直接運行到結束。這時候,後續程序覺得這個線程執行時間過長,需要暫停或者取消線程的執行,那麼就需要了解一下如何暫停或者銷毀線程了。

thread1.Suspend();//掛起
thread1.Resume();//繼續

中斷線程,也就是終止線程:

thread1.Abort();// 已掛起的線程無法中斷

強制終止銷毀:

thread1.Interrupt();//在執行中的線程無法終止

以上是線程操作的基本概念,這部分並不是為了能讓大家精通多線程,這是為了讓大家有個初步概念。在C# 中,創建一個線程需要傳遞一個委託進去,因為委託的性質,並沒有限制是否是靜態方法,所以這裡也可以傳一個對象的方法。當然了,我們十分不提倡這樣做,因為會導致一些多線程領域裏的一些問題。

2. 任務

C#中的任務與線程的區別不是很大,因為C#的任務就是基於線程實現的,而任務比線程更友好,使用也更方便,當然使用也更加複雜。不過對於開發者而言,任務取消了線程的狀態切換,只保留了有限的一部分。而且,在C# 更推薦使用任務,任務也是對線程的進一步抽象和改進。

2.1 創建一個任務

如線程相同的一點是,任務的創建也是通過傳遞一個方法(嚴格上講是一個委託)。不同的是,線程的委託沒有返回值而且也不接受從線程返回的值,而任務則不同,調用方可以期待任務是有返回值的而且也可以正常使用。

我們先來看看任務是什麼,任務的命名空間System.Threading.Tasks,任務的類有以下兩種聲明:

public class Task : IAsyncResult, IDisposable;
public class Task<TResult> : System.Threading.Tasks.Task;

第一個,沒有泛型的Task類表示一個沒有返回值的任務;

第二個,泛型Task類表示該任務有一個返回值,返回值的類型為傳遞進來的泛型參數。

兩個任務類的初始化類似於Thread類,不過與之不同的是 泛型Task的參數是Func,都有一個帶Object參數的委託。

與線程不同,任務的創建就有很多種方法:

1 通過構造函數創建

var task1 = new Task(() => { });
var task2 = new Task<int>(()=> 
{
    int i = 0;
    return i;
});

2 使用任務工廠:

var task1 = Task.Factory.StartNew(() => { });
var task2 = Task.Factory.StartNew(() =>
{
    int i = 0;
    return i;
});

3 通過Task.Run創建:

var task1 = Task.Run(() => { });
var task2 = Task.Run(() =>
{
    int i = 0;
    return i;
});

以上三種方式創建的任務是等效的。當然實際上任務的創建並非只有這麼幾種,但這幾種是任務創建的基礎,使用頻率相當高。

2.2 執行任務

與線程不同的是,任務創建完成之後就會自動執行,不需要調用方法。

關於任務的運行有以下需要注意的地方:

  1. 任務的運行不會阻塞主線程;

  2. 主線程結束後,任務一定也會結束;

任務可以IsCompleted屬性確定任務是否執行完成,所以可以通過訪問任務對象的IsCompleted確認該任務是否執行完成,但有一個問題,這個屬性只會表示當前任務是否完成。所以如果需要等待任務完成,則可以通過訪問Wait()方法,強制主線程等待任務結束。

如果使用的任務是泛型Task也就是待返回值的任務,可以通過訪問Result屬性獲取任務執行結果。有意思的地方就是,這個屬性能獲取到結果的時候,也是任務執行完成的時候,所以不需要調用Wait()IsCompleted來判斷任務是否完成。

註:通過構造方法創建的任務需要調用 Start方法才能啟動,而通過Task.Run和Task.Factory.StartNew創建的則不需要。

3. 總結

C#中任務基於線程,對其做了更多的抽象和封裝,將線程的粒度進一步細分。所以線程在C#中就沒有那麼重要了,任務逐漸替代了線程在C#程序中的地位。

任務與線程,有共通的地方,也有完全不一樣的地方。線程的運行環境相對封閉,所以線程出現錯誤導致線程中斷,不會影響主線程的運行。但任務則不一樣了,任務與主線程的關聯性更大,一旦任務出現異常導致任務中斷,如果沒有正確處理,則會影響主線程的運行。

以上是本篇的全部內容,也請大家期待一下《C#異步編程系列》吧。

更多內容煩請關注我的博客

file