2. 程式人生 > 實用技巧 >.NET非同步和多執行緒系列（三）- Task和Parallel

.NET非同步和多執行緒系列（三）- Task和Parallel

阿新 • • 發佈：2020-08-25

一、Task類

Task是.NET Framework 3.0出現的，執行緒是基於執行緒池的，然後提供了豐富的API。Task被稱之為多執行緒的最佳實踐。

同樣的首先我們來看下如何使用Task來啟動執行緒：

/// <summary>
/// 一個比較耗時耗資源的私有方法
/// </summary>
private void DoSomethingLong(string name)
{
    Console.WriteLine($"****************DoSomethingLong Start  {name}  {Thread.CurrentThread.ManagedThreadId.ToString(
 
"00")} " +
        $"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}***************");
    long lResult = 0;
    for (int i = 0; i < 1_000_000_000; i++)
    {
        lResult += i;
    }
    Thread.Sleep(2000);
    Console.WriteLine($"****************DoSomethingLong   End  {name}  {Thread.CurrentThread.ManagedThreadId.ToString(
 
"00")} " +
        $"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")} {lResult}***************");
}
/// <summary>
/// Task是.NET Framework 3.0出現的，執行緒是基於執行緒池的，然後提供了豐富的API。
/// </summary>
private void btnTask_Click(object sender, EventArgs e)
{
    Console.WriteLine($"****************btnTask_Click Start {Thread.CurrentThread.ManagedThreadId.ToString(
 
"00")} " +
        $"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}***************");

    {
        Task task = new Task(() => this.DoSomethingLong("btnTask_Click_1"));
        task.Start();
    }

    {
        Task task = Task.Run(() => this.DoSomethingLong("btnTask_Click_2"));
    }

    {
        TaskFactory taskFactory = Task.Factory;
        Task task = taskFactory.StartNew(() => this.DoSomethingLong("btnTask_Click_3"));
    }

    Console.WriteLine($"****************btnTask_Click End   {Thread.CurrentThread.ManagedThreadId.ToString("00")} " +
        $"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}***************");
}

Task的執行緒是源於執行緒池，執行緒池是單例的，全域性唯一的。

//Task的執行緒是源於執行緒池
//執行緒池是單例的，全域性唯一的
{
    //設定的最大值，必須大於CPU核數，否則設定無效
    //全域性的，請不要這樣設定！！！此處設定只是為了演示
    ThreadPool.SetMaxThreads(12, 12);

    //設定後，同時併發的Task只有12個；而且執行緒是複用的；
    for (int i = 0; i < 100; i++)
    {
        int k = i;
        Task.Run(() =>
        {
            Console.WriteLine($"This is {k} running ThreadId={Thread.CurrentThread.ManagedThreadId.ToString("00")}");
            Thread.Sleep(2000);
        });
    }
    //假如說我想控制下Task的併發數量，該怎麼做？
}

注意：執行緒池的執行緒數量，設定的最大值，必須大於CPU核數，否則設定無效。

執行結果如下：

從結果中可以看出同時併發的Task只有12個（執行緒ID從03到14）；而且執行緒是複用的；

同步等待：

{
    Stopwatch stopwatch = new Stopwatch(); //計時
    stopwatch.Start();
    Console.WriteLine("在Sleep之前");
    Thread.Sleep(2000);//同步等待--當前執行緒等待2s 然後繼續
    Console.WriteLine("在Sleep之後");
    stopwatch.Stop();
    Console.WriteLine($"Sleep耗時{stopwatch.ElapsedMilliseconds}");
}

非同步等待（Task.Delay方法，一般結合ContinueWith一起用），如下所示：

{
    Stopwatch stopwatch = new Stopwatch();
    stopwatch.Start();
    Console.WriteLine("在Delay之前");
    Task task = Task.Delay(2000) //非同步等待--等待2s後啟動新任務
        .ContinueWith(t =>
        {
            stopwatch.Stop();
            Console.WriteLine($"Delay耗時{stopwatch.ElapsedMilliseconds}");

            Console.WriteLine($"This is ThreadId={Thread.CurrentThread.ManagedThreadId.ToString("00")}");
        });
    Console.WriteLine("在Delay之後");
    //stopwatch.Stop();
    //Console.WriteLine($"Delay耗時{stopwatch.ElapsedMilliseconds}");
}

什麼時候能用多執行緒？ 任務能併發的時候。多執行緒能幹嘛？提升速度/優化使用者體驗。

ContinueWhenAny：同時併發多個任務，當其中任意的，第一個任務完成的時候，執行後續的任務。非阻塞式的回撥。

ContinueWhenAll：同時併發多個任務，當所有的任務都完成的時候，執行後續的任務。非阻塞式的回撥。

WaitAny：阻塞當前執行緒，等著任意一個任務完成。

WaitAll：阻塞當前執行緒，等著全部任務完成。

/// <summary>
/// 模擬講課
/// </summary>
private void Teach(string lesson)
{
    Console.WriteLine($"{lesson}開始講。。。");
    long lResult = 0;
    for (int i = 0; i < 1_000_000_000; i++)
    {
        lResult += i;
    }
    Console.WriteLine($"{lesson}講完了。。。");
}

/// <summary>
/// 模擬程式設計過程
/// </summary>
private void Coding(string name, string projectName)
{
    Console.WriteLine($"****************Coding Start  {name} {projectName}  {Thread.CurrentThread.ManagedThreadId.ToString("00")} " +
        $"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}***************");
    long lResult = 0;
    for (int i = 0; i < 1_000_000_000; i++)
    {
        lResult += i;
    }

    Console.WriteLine($"****************Coding   End  {name} {projectName} {Thread.CurrentThread.ManagedThreadId.ToString("00")} " +
        $"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")} {lResult}***************");
}
{
    //什麼時候能用多執行緒？ 任務能併發的時候
    //多執行緒能幹嘛？提升速度/優化使用者體驗
    Console.WriteLine("Eleven開啟了一學期的課程");
    this.Teach("Lesson1");
    this.Teach("Lesson2");
    this.Teach("Lesson3");
    //不能併發，因為有嚴格順序(只有Eleven講課)
    Console.WriteLine("部署一下專案實戰作業，需要多人合作完成");

    //開發可以多人合作---多執行緒--提升效能
    TaskFactory taskFactory = new TaskFactory();
    List<Task> taskList = new List<Task>();
    taskList.Add(taskFactory.StartNew(() => this.Coding("張三", "Portal")));
    taskList.Add(taskFactory.StartNew(() => this.Coding("李四", "DBA ")));
    taskList.Add(taskFactory.StartNew(() => this.Coding("王五", "Client")));
    taskList.Add(taskFactory.StartNew(() => this.Coding("趙六", "BackService")));
    taskList.Add(taskFactory.StartNew(() => this.Coding("錢七", "Wechat")));

    //誰第一個完成，獲取一個紅包獎勵
    taskFactory.ContinueWhenAny(taskList.ToArray(), t => Console.WriteLine($"XXX開發完成，獲取個紅包獎勵" +
        $"{Thread.CurrentThread.ManagedThreadId.ToString("00")}"));
    //實戰作業完成後，一起慶祝一下
    taskList.Add(taskFactory.ContinueWhenAll(taskList.ToArray(), rArray => Console.WriteLine($"開發都完成，一起慶祝一下" +
        $"{Thread.CurrentThread.ManagedThreadId.ToString("00")}")));
    //ContinueWhenAny  ContinueWhenAll 非阻塞式的回撥；而且使用的執行緒可能是新執行緒，也可能是剛完成任務的執行緒，唯一不可能是主執行緒。

    //阻塞當前執行緒，等著任意一個任務完成
    Task.WaitAny(taskList.ToArray());//也可以限時等待
    Console.WriteLine("Eleven準備環境開始部署");
    //需要能夠等待全部執行緒完成任務再繼續  阻塞當前執行緒，等著全部任務完成
    Task.WaitAll(taskList.ToArray());
    Console.WriteLine("5個模組全部完成後，Eleven集中點評");
    //Task.WaitAny  WaitAll都是阻塞當前執行緒，等任務完成後執行操作

    //阻塞卡介面，是為了併發以及順序控制
    //網站首頁：A資料庫 B介面 C分散式服務 D搜尋引擎，適合多執行緒併發，都完成後才能返回給使用者，需要等待WaitAll
    //列表頁：核心資料可能來自資料庫/介面服務/分散式搜尋引擎/快取，多執行緒併發請求，哪個先完成就用哪個結果，其他的就不管了
}

啟動帶有回撥和帶有返回值的執行緒：

{
    //帶有回撥
    Task.Run(() => this.DoSomethingLong("btnTask_Click")).ContinueWith(t => Console.WriteLine($"btnTask_Click已完成" +
        $"{Thread.CurrentThread.ManagedThreadId.ToString("00")}"));
}

{
    //帶有返回值
    Task<int> result = Task.Run<int>(() =>
        {
            Thread.Sleep(2000);
            return DateTime.Now.Year;
        });
    int i = result.Result;//會阻塞
}

控制Task的併發數量，該怎麼做？

{
    //假如說我想控制下Task的併發數量，該怎麼做？  20個
    List<Task> taskList = new List<Task>();
    for (int i = 0; i < 10000; i++)
    {
        int k = i;
        if (taskList.Count(t => t.Status != TaskStatus.RanToCompletion) >= 20)
        {
            Task.WaitAny(taskList.ToArray());
            taskList = taskList.Where(t => t.Status != TaskStatus.RanToCompletion).ToList();
        }

        taskList.Add(Task.Run(() =>
        {
            Console.WriteLine($"This is {k} running ThreadId={Thread.CurrentThread.ManagedThreadId.ToString("00")}");
            Thread.Sleep(2000);
        }));
    }
}

想使用返回值但又不想阻塞執行緒怎麼辦？

//想使用返回值但又不想阻塞執行緒怎麼辦？
{
    Task.Run<int>(() =>
    {
        Thread.Sleep(2000);
        return DateTime.Now.Year;
    }).ContinueWith(tInt =>
    {
        int i = tInt.Result; //不會阻塞
    });

    //不會阻塞
    Task<int> result = Task.Run<int>(() =>
    {
        Thread.Sleep(2000);
        return DateTime.Now.Year;
    });
    Task.Run(() =>
    {
        int i = result.Result;
    });
}

如果在啟動執行緒的時候想帶一些引數資訊，則可以使用對應的過載方法：

{
    TaskFactory taskFactory = new TaskFactory();
    List<Task> taskList = new List<Task>();
    taskList.Add(taskFactory.StartNew(o => this.Coding("張三", "Portal"), "張三"));
    taskList.Add(taskFactory.StartNew(o => this.Coding("李四", "  DBA "), "李四"));
    taskList.Add(taskFactory.StartNew(o => this.Coding("王五", "Client"), "王五"));
    taskList.Add(taskFactory.StartNew(o => this.Coding(" 趙六", "BackService"), " 趙六"));
    taskList.Add(taskFactory.StartNew(o => this.Coding("錢七", "Wechat"), "錢七"));

    //誰第一個完成，獲取一個紅包獎勵
    taskFactory.ContinueWhenAny(taskList.ToArray(), t => Console.WriteLine($"{t.AsyncState}開發完成，獲取個紅包獎勵" +
        $"{Thread.CurrentThread.ManagedThreadId.ToString("00")}"));
}

幾乎90%以上的多執行緒場景，以及順序控制，以上的Task的方法就可以完成。

如果你的多執行緒場景太複雜搞不定，那麼請梳理一下你的流程，簡化一下。

建議最好不要執行緒巢狀執行緒，兩層勉強能懂，三層hold不住的，更多隻能求神。

二、Parallel類

Parallel可以啟動多個執行緒去併發執行多個Action，它是多執行緒的。Parallel最直觀的特點是主執行緒（當前執行緒）也會參與計算---阻塞介面（主執行緒忙於計算）。

Parallel是在Task的基礎上做了一個封裝，它的效果等於TaskWaitAll+主執行緒（當前執行緒）參與計算。

/// <summary>
/// Parallel
/// </summary>
private void btnParallel_Click(object sender, EventArgs e)
{
    Console.WriteLine($"****************btnParallel_Click Start   {Thread.CurrentThread.ManagedThreadId.ToString("00")} " +
        $"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}***************");

    {
        //Parallel併發執行多個Action 多執行緒的
        //主執行緒（當前執行緒）會參與計算---阻塞介面
        //等於TaskWaitAll+主執行緒計算
        Parallel.Invoke(
            () => this.DoSomethingLong("btnParallel_Click_1"),
            () => this.DoSomethingLong("btnParallel_Click_2"),
            () => this.DoSomethingLong("btnParallel_Click_3"),
            () => this.DoSomethingLong("btnParallel_Click_4"),
            () => this.DoSomethingLong("btnParallel_Click_5"));
    }

    Console.WriteLine($"****************btnParallel_Click End   {Thread.CurrentThread.ManagedThreadId.ToString("00")} " +
        $"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}***************");
}

執行結果如下：

可以看出執行緒ID為01的主執行緒（當前執行緒）也參與計算了。

Parallel其他的API如下所示：

//主執行緒（當前執行緒）會參與計算
{
    Parallel.For(0, 5, i => this.DoSomethingLong($"btnParallel_Click_{i}"));
}

//主執行緒（當前執行緒）會參與計算
{
    Parallel.ForEach(new int[] { 0, 1, 2, 3, 4 }, i => this.DoSomethingLong($"btnParallel_Click_{i}"));
}

如何控制併發（執行緒）數量？上面我們在介紹Task的時候已經寫了一種方案，其實還有一種更好的解決方案，就是使用Parallel來實現。

//控制執行緒數量（併發數量）
//會阻塞當前執行緒（主執行緒）-- 卡介面
{
    ParallelOptions options = new ParallelOptions();
    options.MaxDegreeOfParallelism = 3;
    Parallel.For(0, 10, options, i => this.DoSomethingLong($"btnParallel_Click_{i}"));
}

//控制執行緒數量（併發數量）
//不會阻塞當前執行緒（主執行緒）
{
    Task.Run(() =>
    {
        ParallelOptions options = new ParallelOptions();
        options.MaxDegreeOfParallelism = 3;
        Parallel.For(0, 10, options, i => this.DoSomethingLong($"btnParallel_Click_{i}"));
    });
}

此文由博主精心撰寫轉載請保留此原文連結：https://www.cnblogs.com/xyh9039/p/13556424.html

版權宣告：如有雷同純屬巧合，如有侵權請及時聯絡本人修改，謝謝！！！

相關推薦

.NET非同步和多執行緒系列（三）- Task和Parallel

一、Task類 Task是.NET Framework 3.0出現的，執行緒是基於執行緒池的，然後提供了豐富的API。Task被稱之為多執行緒的最佳實踐。

.NET非同步和多執行緒系列（四）- 多執行緒異常處理、執行緒取消、多執行緒的臨時變數問題、執行緒安全和鎖lock

本文是.NET非同步和多執行緒系列第四章，主要介紹的是多執行緒異常處理、執行緒取消、多執行緒的臨時變數問題、執行緒安全和鎖lock等。

.NET非同步和多執行緒系列（六）- async/await

本文是.NET非同步和多執行緒系列的第六章，本章主要對之前介紹過的async/await做一些補充說明。

多執行緒系列（三）之執行緒池

什麼是執行緒池？ .NetFramework1.0時代的Thread，API功能繁多，對執行緒的數量是沒有管控的，在.NetFramework2.0時代推出了ThreadPool，如果某個物件建立和銷燬代價比較高，同時這個物件還可以反覆使這些執行緒，就

Java 多執行緒基礎（十）interrupt()和執行緒終止方式

Java 多執行緒基礎（十）interrupt()和執行緒終止方式 一、interrupt() 介紹 interrupt() 定義在 Thread 類中，作用是中斷本執行緒。

多執行緒系列（1），多執行緒基礎

執行緒相關概念 在學習多執行緒之前，先來了解下幾個與多執行緒相關的概念。

Java多執行緒--synchronized（三）

synchronized(object) 非this物件鎖 package ch02.test4; import java.util.ArrayList; import java.util.List;

Java 多執行緒基礎（二）

簡介 在上篇 Java 多執行緒基礎（一） 我們提到了一些執行緒的常用方法，這篇我們具體看看其中一些方法的使用以及方法的區別，讓我們在工作中更好的使用。

Java 多執行緒基礎（一）

簡介 在接觸多執行緒之前，在我們程式中在任意時刻都只能執行一個步驟，稱之為單執行緒。在單執行緒開發的程式中所有的程式路徑都是順序執行的，前面的必須先執行，後面的才會執行。單執行緒的優點也很明顯，相對於多

多執行緒原理（4）-synchronized與鎖

yy 這篇文章我們來聊一聊Java多執行緒裡面的“鎖”。 首先需要明確的一點是：Java多執行緒的鎖都是基於物件的，Java中的每一個物件都可以作為一個鎖。

【java多執行緒】（四）執行緒併發問題

技術標籤：java基礎篇多執行緒java併發程式設計thread public class Station implements Runnable{

【Java】白話說Java多執行緒篇（四），生產者/消費者模式與定時任務

技術標籤：Javajava多執行緒併發程式設計設計模式jvm 【Java】白話說Java多執行緒篇（四），生產者/消費者模式與定時任務

linux多執行緒學習（1）

基本函式和關係 pthread_create建立一個子執行緒； pthread_exit是執行緒函式在終止執行時呼叫，就像程序在執行完畢以後呼叫exit函式一樣；

Liunx系統程式設計篇—多執行緒程式設計（二）執行緒開發常用API（一）（關於執行緒操作）（共3種全）

技術標籤：Liunx系統程式設計篇—多執行緒程式設計linux多執行緒經驗分享 執行緒開發常用API——關於執行緒操作

非同步、多執行緒、Await/Async、Task

非同步多執行緒經常被拿來說事，網上文章也是多如牛毛，我也是停留在很菜的水平，痛下決心好好“惡補”一下這塊知識。

【重學Java】多執行緒基礎（三種建立方式，執行緒安全，生產者消費者）

實現多執行緒 簡單瞭解多執行緒【理解】 是指從軟體或者硬體上實現多個執行緒併發執行的技術。

java多執行緒梳理（1）

要開始瞭解多執行緒的知識我們先得理解執行緒是什麼？執行緒和程序之間關係？

JAVA多執行緒併發（1）

1. JAVA多執行緒實現/建立方式 1.1 繼承Thread類 Thread類本質上是實現了Runnable介面的一個例項，代表一個執行緒的例項。啟動執行緒的唯一方法就是通過條用Thread類的start()方法。start()方法是一個native方法，它

android多執行緒-AsyncTaskyi（一）

今天分析android的非同步執行緒類HandlerThread與IntentService，它們都是android系統獨有的執行緒類，而android中還有另一個比較重要的非同步執行緒類AsyncTask。本文我們就來分析AsyncTask。

C++多執行緒學習（一）

（一）幾個基礎的thread函式 (1) thread 執行緒名(函式入口）//建立了執行緒，執行緒執行起點入口為函式，執行緒開始執行。