C#線程學習筆記七:Task詳細用法

来源:https://www.cnblogs.com/atomy/archive/2019/12/13/12033461.html
-Advertisement-
Play Games

一、Task類簡介: Task類是在.NET Framework 4.0中提供的新功能,主要用於非同步操作的控制。它比Thread和ThreadPool提供了更為強大的功能,並且更方便使用。 Task和Task<TResult>類:前者接收的是Action委托類型;後者接收的是Func<TResult ...


    一、Task類簡介:

    Task類是在.NET Framework 4.0中提供的新功能,主要用於非同步操作的控制。它比Thread和ThreadPool提供了更為強大的功能,並且更方便使用。

    Task和Task<TResult>類:前者接收的是Action委托類型;後者接收的是Func<TResult>委托類型。

    任務Task和線程Thread的區別:

    1、任務是架構線上程之上。也就是說任務最終還是要拋給線程去執行,它們都是在同一命名空間System.Threading下。

    2、任務跟線程並不是一對一的關係。比如說開啟10個任務並不一定會開啟10個線程,因為使用Task開啟新任務時,是從線程池中調用線程,這點與

ThreadPool.QueueUserWorkItem類似。

    二、Task的創建

    2.1創建方式1:調用構造函數

    class Program
    {
        static void Main(string[] args)
        {
            #region 工作者線程:使用任務實現非同步
            ThreadPool.SetMaxThreads(1000, 1000);
            PrintMessage("Main thread start.");
            //調用構造函數創建Task對象
            Task<int> task = new Task<int>(n => AsyncMethod((int)n), 10);

            //啟動任務 
            task.Start();
            //等待任務完成
            task.Wait();
            Console.WriteLine("The method result is: " + task.Result);
            Console.ReadLine();
            #endregion
        }

        /// <summary>
        /// 列印線程池信息
        /// </summary>
        /// <param name="data"></param>
        private static void PrintMessage(string data)
        {
            //獲得線程池中可用的工作者線程數量及I/O線程數量
            ThreadPool.GetAvailableThreads(out int workThreadNumber, out int ioThreadNumber);

            Console.WriteLine("{0}\n CurrentThreadId is:{1}\n CurrentThread is background:{2}\n WorkerThreadNumber is:{3}\n IOThreadNumbers is:{4}\n",
                data,
                Thread.CurrentThread.ManagedThreadId,
                Thread.CurrentThread.IsBackground.ToString(),
                workThreadNumber.ToString(),
                ioThreadNumber.ToString());
        }

        /// <summary>
        /// 非同步方法
        /// </summary>
        /// <param name="n"></param>
        /// <returns></returns>
        private static int AsyncMethod(int n)
        {
            Thread.Sleep(1000);
            PrintMessage("Asynchoronous method.");

            int sum = 0;
            for (int i = 1; i < n; i++)
            {
                //運算溢出檢查
                checked
                {
                    sum += i;
                }
            }

            return sum;
        }
    }
View Code

    2.2創建方式2:任務工廠

    class Program
    {
        static void Main(string[] args)
        {
            #region 工作者線程:使用任務工廠實現非同步
            ////無參無返回值
            //ThreadPool.SetMaxThreads(1000, 1000);
            //Task.Factory.StartNew(() => PrintMessage("Main thread."));
            //Console.Read();

            //有參有返回值
            ThreadPool.SetMaxThreads(1000, 1000);
            PrintMessage("Main thread start.");
            var task = Task.Factory.StartNew(n => AsyncMethod((int)n), 10);
            //等待任務完成
            task.Wait();
            Console.WriteLine("The method result is: " + task.Result);
            Console.ReadLine();
            #endregion
        }

        /// <summary>
        /// 列印線程池信息
        /// </summary>
        /// <param name="data"></param>
        private static void PrintMessage(string data)
        {
            //獲得線程池中可用的工作者線程數量及I/O線程數量
            ThreadPool.GetAvailableThreads(out int workThreadNumber, out int ioThreadNumber);

            Console.WriteLine("{0}\n CurrentThreadId is:{1}\n CurrentThread is background:{2}\n WorkerThreadNumber is:{3}\n IOThreadNumbers is:{4}\n",
                data,
                Thread.CurrentThread.ManagedThreadId,
                Thread.CurrentThread.IsBackground.ToString(),
                workThreadNumber.ToString(),
                ioThreadNumber.ToString());
        }

        /// <summary>
        /// 非同步方法
        /// </summary>
        /// <param name="n"></param>
        /// <returns></returns>
        private static int AsyncMethod(int n)
        {
            Thread.Sleep(1000);
            PrintMessage("Asynchoronous method.");

            int sum = 0;
            for (int i = 1; i < n; i++)
            {
                //運算溢出檢查
                checked
                {
                    sum += i;
                }
            }

            return sum;
        }
    }
View Code

    2.3創建方式3:Run方法

    class Program
    {
        static void Main(string[] args)
        {
            #region 工作者線程:使用Task.Run實現非同步
            ThreadPool.SetMaxThreads(1000, 1000);
            PrintMessage("Main thread start.");
            var task = Task.Run(() => AsyncMethod(10));
            //等待任務完成
            task.Wait();
            Console.WriteLine("The method result is: " + task.Result);
            Console.ReadLine();
            #endregion
        }

        /// <summary>
        /// 列印線程池信息
        /// </summary>
        /// <param name="data"></param>
        private static void PrintMessage(string data)
        {
            //獲得線程池中可用的工作者線程數量及I/O線程數量
            ThreadPool.GetAvailableThreads(out int workThreadNumber, out int ioThreadNumber);

            Console.WriteLine("{0}\n CurrentThreadId is:{1}\n CurrentThread is background:{2}\n WorkerThreadNumber is:{3}\n IOThreadNumbers is:{4}\n",
                data,
                Thread.CurrentThread.ManagedThreadId,
                Thread.CurrentThread.IsBackground.ToString(),
                workThreadNumber.ToString(),
                ioThreadNumber.ToString());
        }

        /// <summary>
        /// 非同步方法
        /// </summary>
        /// <param name="n"></param>
        /// <returns></returns>
        private static int AsyncMethod(int n)
        {
            Thread.Sleep(1000);
            PrintMessage("Asynchoronous method.");

            int sum = 0;
            for (int i = 1; i < n; i++)
            {
                //運算溢出檢查
                checked
                {
                    sum += i;
                }
            }

            return sum;
        }
    }
View Code

    三、Task的簡略生命周期

    可通過Status屬性獲取。

狀態 說明
Created 表示預設初始化任務,但是工廠及Run創建方式會直接跳過。
WaitingToRun 表示等待任務調度器分配線程給任務執行。
RanToCompletion 表示任務執行完畢。

 

 

 

 

 

    四、Task的控制

方法名 說明
Task.Wait 如task1.Wait();就是等待task1任務的執行,執行完成後狀態變為Completed。
Task.WaitAll 等待所有的任務執行完畢。
Task.WaitAny 等待任意一個任務完成後就繼續向下執行。
Task.ContinueWith 上一個任務執行完成後自動啟動下一個任務,實現任務的按序進行。
CancellationTokenSource 通過其token來取消一個Task。

 

 

 

 

 

 

 

 

    4.1、組合任務

    class Program
    {
        public static void Main()
        {
            #region 工作者線程:Task組合任務
            //創建一個任務
            Task<int> task = new Task<int>(() =>
            {
                int sum = 0;
                Console.WriteLine("使用任務實現非同步。");
                for (int i = 0; i < 10; i++)
                {
                    sum += i;
                }
                return sum;
            });
            //任務啟動並安排到任務隊列等待執行(System.Threading.Tasks.TaskScheduler)
            task.Start();
            //任務完成時執行處理
            Task cwt = task.ContinueWith(t =>
            {
                Console.WriteLine("任務的執行結果:{0}", t.Result.ToString());
            });
            task.Wait();
            cwt.Wait();
            Console.ReadLine();
            #endregion
        }
    }
View Code

   運行結果如下:

    4.2、串列任務

    class Program
    {
        public static void Main()
        {
            #region 工作者線程:Task串列任務
            //堆棧
            ConcurrentStack<int> stack = new ConcurrentStack<int>();

            //t1最早串列
            var t1 = Task.Factory.StartNew(() =>
            {
                stack.Push(1);
                stack.Push(2);
            });

            //t2、t3並行執行
            var t2 = t1.ContinueWith(t =>
            {
                stack.TryPop(out int result);
                Console.WriteLine("Task t2 result={0},thread id is {1}.", result, Thread.CurrentThread.ManagedThreadId);
            });
            var t3 = t1.ContinueWith(t =>
            {
                stack.TryPop(out int result);
                Console.WriteLine("Task t3 result={0},thread id is {1}.", result, Thread.CurrentThread.ManagedThreadId);
            });

            //等待t2、t3執行完畢
            Task.WaitAll(t2, t3);

            //t4串列執行
            var t4 = Task.Factory.StartNew(() =>
            {
                Console.WriteLine("The stack count={0},thread id is {1}.", stack.Count, Thread.CurrentThread.ManagedThreadId);
            });
            t4.Wait();

            Console.ReadLine();
            #endregion
        }
    }
View Code

    運行結果如下:

    4.3、子任務

    class Program
    {
        public static void Main()
        {
            #region 工作者線程:Task子任務
            Task<string[]> parent = new Task<string[]>(state =>
            {
                Console.WriteLine(state);
                string[] result = new string[2];
                //創建並啟動子任務
                new Task(() => { result[0] = "子任務1。"; }, TaskCreationOptions.AttachedToParent).Start();
                new Task(() => { result[1] = "子任務2。"; }, TaskCreationOptions.AttachedToParent).Start();
                return result;
            }, "我是父任務,我創建了2個子任務,它們執行完後我才會結束執行。");
            //任務完成時執行處理
            parent.ContinueWith(t =>
            {
                Array.ForEach(t.Result, r => Console.WriteLine(r));
            });
            //啟動父任務
            parent.Start();
            parent.Wait();
            Console.ReadLine();
            #endregion
        }
    }
View Code

    運行結果如下:

    4.4、動態並行任務

    /// <summary>
    /// 結點類
    /// </summary>
    class Node
    {
        public Node Left { get; set; }
        public Node Right { get; set; }
        public string Text { get; set; }
    }

    class Program
    {
        public static void Main()
        {
            #region 工作者線程:Task動態並行任務
            Node root = GetNode();
            DisplayTree(root);
            Console.ReadLine();
            #endregion
        }

        /// <summary>
        /// GetNode方法
        /// </summary>
        /// <returns></returns>
        static Node GetNode()
        {
            Node root = new Node
            {
                Left = new Node
                {
                    Left = new Node
                    {
                        Text = "L-L"
                    },
                    Right = new Node
                    {
                        Text = "L-R"
                    },
                    Text = "L"
                },
                Right = new Node
                {
                    Left = new Node
                    {
                        Text = "R-L"
                    },
                    Right = new Node
                    {
                        Text = "R-R"
                    },
                    Text = "R"
                },
                Text = "Root"
            };
            return root;
        }

        /// <summary>
        /// DisplayTree方法
        /// </summary>
        /// <param name="root"></param>
        static void DisplayTree(Node root)
        {
            var task = Task.Factory.StartNew
                (
                    () =>
                    DisplayNode(root),
                    CancellationToken.None,
                    TaskCreationOptions.None,
                    TaskScheduler.Default
                );
            task.Wait();
        }

        /// <summary>
        /// DisplayNode方法
        /// </summary>
        /// <param name="current"></param>
        static void DisplayNode(Node current)
        {

            if (current.Left != null)
            {
                Task.Factory.StartNew
                    (
                        () =>
                        DisplayNode(current.Left),
                        CancellationToken.None,
                        TaskCreationOptions.AttachedToParent,
                        TaskScheduler.Default
                    );
            }
            if (current.Right != null)
            {
                Task.Factory.StartNew
                    (
                        () =>
                        DisplayNode(current.Right),
                        CancellationToken.None,
                        TaskCreationOptions.AttachedToParent,
                        TaskScheduler.Default
                    );
                Console.WriteLine("The current node text={0},thread id is {1}.", current.Text, Thread.CurrentThread.ManagedThreadId);
            }
        }
    }
View Code

    運行結果如下:

    4.5、取消任務

    class Program
    {
        static void Main(string[] args)
        {
            #region 取消任務
            ThreadPool.SetMaxThreads(1000, 1000);
            PrintMessage("Main thread start.");
            CancellationTokenSource cts = new CancellationTokenSource();

            //調用構造函數創建Task對象,將一個CancellationToken傳給Task構造器從而使Task和CancellationToken關聯起來。
            Task<int> task = new Task<int>(n => AsyncMethod(cts.Token, (int)n), 10);

            //啟動任務 
            task.Start();
            //延遲取消任務
            Thread.Sleep(3000);

            //取消任務
            cts.Cancel();
            Console.WriteLine("The method result is: " + task.Result);
            Console.ReadLine();
            #endregion
        }

        /// <summary>
        /// 列印線程池信息
        /// </summary>
        /// <param name="data"></param>
        private static void PrintMessage(string data)
        {
            //獲得線程池中可用的工作者線程數量及I/O線程數量
            ThreadPool.GetAvailableThreads(out int workThreadNumber, out int ioThreadNumber);

            Console.WriteLine("{0}\n CurrentThreadId is:{1}\n CurrentThread is background:{2}\n WorkerThreadNumber is:{3}\n IOThreadNumbers is:{4}\n",
                data,
                Thread.CurrentThread.ManagedThreadId,
                Thread.CurrentThread.IsBackground.ToString(),
                workThreadNumber.ToString(),
                ioThreadNumber.ToString());
        }

        /// <summary>
        /// 非同步方法
        /// </summary>
        /// <param name="ct"></param>
        /// <param name="n"></param>
        /// <returns></returns>
        private static int AsyncMethod(CancellationToken ct, int n)
        {
            Thread.Sleep(1000);
            PrintMessage("Asynchoronous method.");

            int sum = 0;
            try
            {
                for (int i = 1; i < n; i++)
                {
                    //當CancellationTokenSource對象調用Cancel方法時,就會引起OperationCanceledException異常,
                    //通過調用CancellationToken的ThrowIfCancellationRequested方法來定時檢查操作是否已經取消,
                    //這個方法和CancellationToken的IsCancellationRequested屬性類似。
                    ct.ThrowIfCancellationRequested();
                    Thread.Sleep(500);
                    //運算溢出檢查
                    checked
                    {
                        sum += i;
                    }
                }
            }
            catch (Exception e)
            {
                Console.WriteLine("Exception is:" + e.GetType().Name);
                Console.WriteLine("Operation is canceled.");
            }

            return sum;
        }
    }
View Code

    運行結果如下:

    4.6、處理單個任務中的異常

    class Program
    {
        public static void Main()
        {
            #region 工作者線程:處理單個任務中的異常
            try
            {
                Task<int> task = Task.Run(() => SingleTaskExceptionMethod("Single task.", 2));
                int result = task.GetAwaiter().GetResult();
                Console.WriteLine("Result:{0}", result);
            }
            catch (Exception ex)
            {
                Console.WriteLine("Single task exception caught:{0}", ex.Message);
            }
            Console.ReadLine();
            #endregion
        }

        /// <summary>
        /// SingleTaskException方法
        /// </summary>
        /// <param name="name"></param>
        /// <param name="seconds"></param>
        /// <returns></returns>
        static int SingleTaskExceptionMethod(string name, int seconds)
        {
            Console.WriteLine("Task {0} is running on thread {1}.Is it threadpool thread?:{2}",
                name, Thread.CurrentThread.ManagedThreadId, Thread.CurrentThread.IsThreadPoolThread);
            Thread.Sleep(TimeSpan.FromSeconds(seconds));
            throw new Exception("Boom.");
        }
    }
View Code

    運行結果如下:

    4.7、處理多個任務中的異常

    class Program
    {
        public static void Main()
        {
            #region 工作者線程:處理多個任務中的異常
            try
            {
                var t1 = new Task<int>(() => MultipleTaskExceptionMethod("Multiple task 1", 3));
                var t2 = new Task<int>(() => MultipleTaskExceptionMethod("Multiple task 2", 2));
                var complexTask = Task.WhenAll(t1, t2);
                var exceptionHandler = complexTask.ContinueWith
                    (
                        t =>
                        Console.WriteLine("Result:{0}", t.Result),
                        TaskContinuationOptions.OnlyOnFaulted
                    );
                t1.Start();
                t2.Start();
                Task.WaitAll(t1, t2);
                Console.ReadLine();
            }
            catch (AggregateException ex)
            {
                ex.Handle
                    (
                        exception =>
                        {
                            Console.WriteLine(exception.Message);
                            return true;
                        }
                    );
            }
            #endregion
        }

        /// <summary>
        /// MultipleTaskException方法
        /// </summary>
        /// <param name="name"></param>
        /// <param name="seconds"></param>
        /// <returns></returns>
        static int MultipleTaskExceptionMethod(string name, int seconds)
        {
            Console.WriteLine("Task {0} is running on thread id {1}. Is it threadpool thread?:{2}",
                name, Thread.CurrentThread.ManagedThreadId, Thread.CurrentThread.IsThreadPoolThread);
            Thread.Sleep(TimeSpan.FromSeconds(seconds));
            throw new Exception(string.Format("Task {0} Boom.", name));
        }
    }
View Code

    運行結果如下:

    4.8、Task.FromResult的應用

    class Program
    {
        //字典
        private static readonly IDictionary<string, string> cache = new Dictionary<string, string>()
        {
            {"0001","A"},
            {"0002","B"},
            {"0003","C"},
            {"0004","D"},
            {"0005","E"},
            {"0006","F"},
        };

        public static void Main()
        {
            #region 工作者線程:Task.FromResult的應用
            Task<string> task = GetValueFromCacheMethod("0006");
            Console.WriteLine("Result={0}", task.Result.ToString());
            Console.ReadLine();
            #endregion
        }

        /// <summary>
        /// GetValueFromCache方法
        /// </summary>
        /// <param name="key"></param>
        /// <returns></returns>
        private static Task<string> GetValueFromCacheMethod(string key)
        {
            Console.WriteLine("GetValueFromCache開始執行……");
            string result = string.Empty;
            Thread.Sleep(3000);
            Console.WriteLine("GetValueFromCache繼續執行……");
            if (cache.TryGetValue(key, out result))
            {
                return Task.FromResult(result);
            }
            return Task.FromResult("");
        }
    }
View Code

    運行結果如下:

    4.9、使用IProgress實現非同步編程的進程通知

    IProgress<in T>只提供了一個方法void Report(T value),通過Report方法把一個T類型的值報告給IProgress,然後IProgress<in T>的實現類Progress<in T>的構造函數

接收類型為Action<T>的形參,通過這個委托讓進度顯示在UI界面中。

您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 第一次寫博客,本文主要源於圖像處理大作業,不足之處,還望指正。 1. Introduction (5%) The task of the project is to find the dial-code switch in the figure below and calibrate the rec ...
  • 公司兩個系統。 我們的A系統要給B系統上送業務簽約單申請。B系統接收數據後,非同步處理,簽約完成會主動發送通知給我們的A系統。 介面文檔里說明瞭,通過http協議的post請求來發送非同步通知,報文是json格式字元串。But,But,But, ...
  • 之前我們使用VSCode搭建C 項目,今天寫一篇關於django項目的搭建;django官網:https://www.djangoproject.com/ 安裝django django安裝命令: ,參考:https://docs.djangoproject.com/en/3.0/topics/in ...
  • spring 第一章 Spring模塊規劃圖 核心架包 AOP+Aspects(面向切麵編程模塊) 數據訪問/:Spring資料庫訪問模塊 Web:Spring開發web應用的模塊; ecplise插件的安裝 1.ecplise查看版本號: Help About Eclipse 點擊自己eclips ...
  • 二、Celery基本使用 1.創建一個celery application 用來定義你的任務列表,創建一個任務文件就叫tasks.py吧。 from celery import Celery # 配置好celery的backend和broker app = Celery('task1', backe ...
  • 一、下載(原文鏈接:http://www.studyshare.cn/software/details/1183/0 ) 1、官網下載:下載地址 2、百度網盤下載:下載地址 提取碼:0g5a java開發工具下載地址及安裝教程大全,點這裡。 更多深度技術文章,在這裡。 二、安裝及啟動 1、前提條件: ...
  • 本文將介紹在Java程式中如何將Excel工作簿轉為PDF文檔的,包括: 將整個工作簿轉為PDF 將指定工作表轉為PDF 使用工具:Free Spire.XLS for Java (免費版) Jar文件下載及導入: 方法1:通過官網下載。下載後,解壓文件,將lib文件夾下的Spire.Xls.jar ...
  • 場景 JPA入門簡介與搭建HelloWorld(附代碼下載): https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/103473937 JPA中實現單向多對一的關聯關係: https://blog.csdn.net/BADAO_LIUM ...
一周排行
    -Advertisement-
    Play Games
  • Timer是什麼 Timer 是一種用於創建定期粒度行為的機制。 與標準的 .NET System.Threading.Timer 類相似,Orleans 的 Timer 允許在一段時間後執行特定的操作,或者在特定的時間間隔內重覆執行操作。 它在分散式系統中具有重要作用,特別是在處理需要周期性執行的 ...
  • 前言 相信很多做WPF開發的小伙伴都遇到過表格類的需求,雖然現有的Grid控制項也能實現,但是使用起來的體驗感並不好,比如要實現一個Excel中的表格效果,估計你能想到的第一個方法就是套Border控制項,用這種方法你需要控制每個Border的邊框,並且在一堆Bordr中找到Grid.Row,Grid. ...
  • .NET C#程式啟動閃退,目錄導致的問題 這是第2次踩這個坑了,很小的編程細節,容易忽略,所以寫個博客,分享給大家。 1.第一次坑:是windows 系統把程式運行成服務,找不到配置文件,原因是以服務運行它的工作目錄是在C:\Windows\System32 2.本次坑:WPF桌面程式通過註冊表設 ...
  • 在分散式系統中,數據的持久化是至關重要的一環。 Orleans 7 引入了強大的持久化功能,使得在分散式環境下管理數據變得更加輕鬆和可靠。 本文將介紹什麼是 Orleans 7 的持久化,如何設置它以及相應的代碼示例。 什麼是 Orleans 7 的持久化? Orleans 7 的持久化是指將 Or ...
  • 前言 .NET Feature Management 是一個用於管理應用程式功能的庫,它可以幫助開發人員在應用程式中輕鬆地添加、移除和管理功能。使用 Feature Management,開發人員可以根據不同用戶、環境或其他條件來動態地控制應用程式中的功能。這使得開發人員可以更靈活地管理應用程式的功 ...
  • 在 WPF 應用程式中,拖放操作是實現用戶交互的重要組成部分。通過拖放操作,用戶可以輕鬆地將數據從一個位置移動到另一個位置,或者將控制項從一個容器移動到另一個容器。然而,WPF 中預設的拖放操作可能並不是那麼好用。為瞭解決這個問題,我們可以自定義一個 Panel 來實現更簡單的拖拽操作。 自定義 Pa ...
  • 在實際使用中,由於涉及到不同編程語言之間互相調用,導致C++ 中的OpenCV與C#中的OpenCvSharp 圖像數據在不同編程語言之間難以有效傳遞。在本文中我們將結合OpenCvSharp源碼實現原理,探究兩種數據之間的通信方式。 ...
  • 一、前言 這是一篇搭建許可權管理系統的系列文章。 隨著網路的發展,信息安全對應任何企業來說都越發的重要,而本系列文章將和大家一起一步一步搭建一個全新的許可權管理系統。 說明:由於搭建一個全新的項目過於繁瑣,所有作者將挑選核心代碼和核心思路進行分享。 二、技術選擇 三、開始設計 1、自主搭建vue前端和. ...
  • Csharper中的表達式樹 這節課來瞭解一下表示式樹是什麼? 在C#中,表達式樹是一種數據結構,它可以表示一些代碼塊,如Lambda表達式或查詢表達式。表達式樹使你能夠查看和操作數據,就像你可以查看和操作代碼一樣。它們通常用於創建動態查詢和解析表達式。 一、認識表達式樹 為什麼要這樣說?它和委托有 ...
  • 在使用Django等框架來操作MySQL時,實際上底層還是通過Python來操作的,首先需要安裝一個驅動程式,在Python3中,驅動程式有多種選擇,比如有pymysql以及mysqlclient等。使用pip命令安裝mysqlclient失敗應如何解決? 安裝的python版本說明 機器同時安裝了 ...