C#异步编程Task怎么创建

2023-06-30 07:06:22 488人浏览安东尼

摘要

这篇文章主要介绍“C#异步编程Task怎么创建”，在日常操作中，相信很多人在C#异步编程Task怎么创建问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”C#异步编程Task怎么创建”的疑惑有所帮助！接下来，请跟

这篇文章主要介绍“C#异步编程Task怎么创建”，在日常操作中，相信很多人在C#异步编程Task怎么创建问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”C#异步编程Task怎么创建”的疑惑有所帮助！接下来，请跟着小编一起来学习吧！

一、简介

ThreadPool相比Thread来说具备了很多优势，但是ThreadPool却又存在一些使用上的不方便。比如：
Task支持线程的取消、完成、失败通知等交互性操作，但是ThreadPool不支持；
Task支持线程执行的先后次序，但是ThreadPool不支持；；
以往，如果开发者要实现上述功能，需要完成很多额外的工作，现在，FCL中提供了一个功能更强大的概念：Task。Task在线程池的基础上进行了优化，并提供了更多的api。在FCL4.0中，如果我们要编写多线程程序，Task显然已经优于传统的方式。

            Task t = new Task(() =>            {                Console.WriteLine("Start……");                //模拟工作过程                Thread.Sleep(5000);            });            t.Start();            t.ContinueWith((task) =>            {                Console.WriteLine("Already Finished，States：");                Console.WriteLine("IsCanceled={0}\tIsCompleted={1}\tIsFaulted={2}", task.IsCanceled, task.IsCompleted, task.IsFaulted);            });            Console.ReadKey();

二、Task创建

无返回值创建方式

线程引用方法：

        static void TaskMethod(string name)        {            Console.WriteLine("Task: {0} is running on a thread id {1}. Is thread pool thread: {2}",                name, Thread.CurrentThread.ManagedThreadId, Thread.CurrentThread.IsThreadPoolThread);        }

方式一：

            //方式一            var t1 = new Task(() => TaskMethod("Task_1"));            t1.Start();            //等待所有任务结束             //任务的状态:            //Start之前为:Created            //Start之后为:WaitingToRun            Task.WaitAll(t1);////等待所有任务结束

方式二：

            //方式二            Task.Run(() => TaskMethod("Task_2"));

方式三：

            //方式三            Task.Factory.StartNew(() => TaskMethod("Task_3")); //直接异步的方法             //或者            var t3 = Task.Factory.StartNew(() => TaskMethod("Task_3"));            Task.WaitAll(t3);//等待所有任务结束             //任务的状态            //Start之前为:Running                   //Start之后为:Running

实例：

    class Program    {        static void Main(string[] args)        {            var t1 = new Task(() => TaskMethod("Task_1"));            var t2 = new Task(() => TaskMethod("Task_2"));            t2.Start();            t1.Start();            Task.WaitAll(t1, t2);            Task.Run(() => TaskMethod("Task_3"));            Task.Factory.StartNew(() => TaskMethod("Task_4"));            //标记为长时间运行任务,则任务不会使用线程池,而在单独的线程中运行。            Task.Factory.StartNew(() => TaskMethod("Task_5"), TaskCreationOptions.LongRunning);            #region 常规的使用方式            Console.WriteLine("主線程執行業務處理.");            //创建任务            Task task = new Task(() =>            {                Console.WriteLine("使用System.Threading.Tasks.Task執行異步操作.");                for (int i = 0; i < 10; i++)                {                    Console.WriteLine(i);                }            });            //启动任务,并安排到当前任务队列线程中执行任务(System.Threading.Tasks.TaskScheduler)            task.Start();            Console.WriteLine("主線程執行其他處理");            task.Wait();            #endregion            Thread.Sleep(TimeSpan.FromSeconds(1));            Console.ReadLine();        }        static void TaskMethod(string name)        {            Console.WriteLine("Task {0} is running on a thread id {1}. Is thread pool thread: {2}",                name, Thread.CurrentThread.ManagedThreadId, Thread.CurrentThread.IsThreadPoolThread);        }    }

结果：

C#异步编程Task怎么创建

async/await的实现方式:

    class Program    {        async static void AsyncFunction()        {            await Task.Delay(1);            Console.WriteLine("使用System.Threading.Tasks.Task執行異步操作.");            for (int i = 0; i < 10; i++)            {                Console.WriteLine(string.FORMat("AsyncFunction:i={0}", i));            }        }        public static void Main()        {            Console.WriteLine("主線程執行業務處理.");            AsyncFunction();            Console.WriteLine("主線程執行其他處理");            for (int i = 0; i < 10; i++)            {                Console.WriteLine(string.Format("Main:i={0}", i));            }            Console.ReadLine();        }    }

结果：

C#异步编程Task怎么创建

带返回值方式

线程引用方法

        static Task<int> CreateTask(string name)        {            return new Task<int>(() => TaskMethod1(name));        }

        static int TaskMethod1(string name)        {            Console.WriteLine("Task {0} is running on a thread id {1}. Is thread pool thread: {2}",                name, Thread.CurrentThread.ManagedThreadId, Thread.CurrentThread.IsThreadPoolThread);            Thread.Sleep(TimeSpan.FromSeconds(2));            return 42;        }

方式四：

            //方式四            Task<int> task = CreateTask("Task_1");            task.Start();            int result = task.Result;

实例：

    class Program    {        static Task<int> CreateTask(string name)        {            return new Task<int>(() => TaskMethod(name));        }        static void Main(string[] args)        {            TaskMethod("Main Thread Task");            Task<int> task = CreateTask("Task_1");            task.Start();            int result = task.Result;            Console.WriteLine("Task_1 Result is: {0}", result);            task = CreateTask("Task_2");            //该任务会运行在主线程中            task.RunSynchronously();            result = task.Result;            Console.WriteLine("Task_2 Result is: {0}", result);            task = CreateTask("Task_3");            Console.WriteLine(task.Status);            task.Start();            while (!task.IsCompleted)            {                Console.WriteLine(task.Status);                Thread.Sleep(TimeSpan.FromSeconds(0.5));            }            Console.WriteLine(task.Status);            result = task.Result;            Console.WriteLine("Task_3 Result is: {0}", result);            #region 常规使用方式            //创建任务            Task<int> getsumtask = new Task<int>(() => Getsum());            //启动任务,并安排到当前任务队列线程中执行任务(System.Threading.Tasks.TaskScheduler)            getsumtask.Start();            Console.WriteLine("主線程執行其他處理");            //等待任务的完成执行过程。            getsumtask.Wait();            //获得任务的执行结果            Console.WriteLine("任務執行結果：{0}", getsumtask.Result.ToString());            Console.ReadLine();            #endregion        }        static int TaskMethod(string name)        {            Console.WriteLine("Task: {0} is running on a thread id {1}. Is thread pool thread: {2}",                name, Thread.CurrentThread.ManagedThreadId, Thread.CurrentThread.IsThreadPoolThread);            Thread.Sleep(TimeSpan.FromSeconds(2));            return 42;        }        static int Getsum()        {            int sum = 0;            Console.WriteLine("使用Task執行異步操作.");            for (int i = 0; i < 100; i++)            {                sum += i;            }            return sum;        }    }

结果：

C#异步编程Task怎么创建

async/await的实现:

    class Program    {        public static void Main()        {            var ret1 = AsyncGetsum();            Console.WriteLine("主線程執行其他處理");            for (int i = 1; i <= 3; i++)                Console.WriteLine("Call Main()");            int result = ret1.Result;                  //阻塞主线程            Console.WriteLine("任務執行結果：{0}", result);            Console.ReadLine();        }        async static Task<int> AsyncGetsum()        {            await Task.Delay(1);            int sum = 0;            Console.WriteLine("使用Task執行異步操作.");            for (int i = 0; i < 100; i++)            {                sum += i;            }            return sum;        }    }

结果：

C#异步编程Task怎么创建