C#:多线程Task使用
一.Task与Thread
- Task是架构在Thread之上的,也就是说任务最终还是要抛给线程去执行。
- Task跟Thread不是一对一的关系,比如开10个任务并不是说会开10个线程,这一点任务有点类似线程池,但是任务相比线程池有很小的开销和精确的控制。
Task
是用于表示一个异步操作的抽象。它是一种轻量级的、可等待的对象,允许你在不阻塞当前线程的情况下执行操作- Task用途:可以用来处理各种耗时的操作,如文件I/O、网络请求、复杂的计算等,从而提高应用程序的响应性和性能。例如,在一个图形用户界面(GUI)应用程序中,使用
Task
来执行长时间的文件读取操作,这样在读取文件时,用户界面仍然可以响应用户的其他操作,如点击按钮、移动窗口等 - Task为后台程序,前台程序执行完毕后,软件即可结束
二.Task是使用方法:
创建Task,无返回值的创建方法,使用Task 创建以及使用Lambda表达式创建:有返回值的创建方法,Task支持泛型编程
//方法一:
Task b = new Task(()=> Console.WriteLine( "Task 2" ));
b.start;
//方法二
Task.Run(() =>
{Console.WriteLine("Task1");
});
//方法三:TaskFactory taskFactory = new TaskFactory();taskFactory.StartNew(() => { Console.WriteLine("工厂模式创建"); });//有返回值
Task<int> taskWithResult = Task.Run(() =>
{return 42; // 返回一个整数结果
});
Console.WriteLine(taskWithResult.Result);
执行结果,Task创建的为后台程序,当主线程为前台程序,当前台程序执行完毕,程序结束,后台程序会出现没有执行的情况:
Task1
工厂模式创建
Task 2
42
使用以下程序进行测试:
static void Main(string[] args)
{Task.Run(() =>{Console.WriteLine("Task1");});TaskFactory taskFactory = new TaskFactory();taskFactory.StartNew(() => { Console.WriteLine("工厂模式创建"); });///Task a =new Task(program.GetTicket);Task b = new Task(()=> Console.WriteLine( "Task 2" ));b.Start();Console.WriteLine( "main主程序" );
}
执行结果如下:
//执行结果1:
main主程序
Task1
工厂模式创建
Task 2//执行结果2:
main主程序
工厂模式创建
Task1
为了解决这个问题,Task提供一系列API进行线程控制:
Task API | 意义 |
---|---|
Task.Result | 获取Task的返回值 |
Task.ContinueWith | 一个任务完成后执行 |
Task.Delay | 异步延迟程序,不会阻碍主线程 |
Task.Wait | 用与阻塞当前线程,直到指定任务完成,相当于Thread.Join() |
Task.WaitAll | 等待列表中的任务全部完成,传递Array |
Task.WaitAny | 等待列表中的任一任务全部完成,传递Array |
Task.WhenAll | 等待列表中的任务都完成(异步),传递Array |
Task.WhenAny | 等待列表中的任一任务完成(异步),传递Array |
通过程序逐步演示该API使用方法:
Task task1 = new Task(()=> Console.WriteLine("Task1"));
Task task2 = task1.ContinueWith(t => //t和task1为同一任务{Console.WriteLine(t ==task1);Console.WriteLine("task2");});task1.Start();// task2.Start();//持续线程不可以使用starttask1.Wait(); //阻塞主线程,Task线程完成后在进行执行task2.Wait(); //阻塞主线程,Task线程完成后在进行执行Console.WriteLine( "main线程" );
打印结果:
Task1
True
task2
main线程
- Continue with使用,参数t指的是上一个Task:
Task<int> task1 = Task.Run(() =>{return 10086;Console.WriteLine("Task1 is Running"); } );Task<int> task2 = task1.ContinueWith(t => { return t.Result + 1;Console.WriteLine("Task2 is Running");});Task<int> task3 = task2.ContinueWith(t => {return t.Result + 1;Console.WriteLine("Task2 is Running");});Console.WriteLine( task3.Result );Console.WriteLine( task1.Result );Console.WriteLine( task2.Result );
打印结果:
10088
10086
10087
三.async和await:
async执行一个异步方法,await执行一个异步任务,当程序遇见await会单独开一个控制流,不影响主线程的执行。
static void Main(string[] args){Console.WriteLine($"main方法Begins:线程ID:{Thread.CurrentThread.ManagedThreadId},是否在线程池{Thread.CurrentThread.IsThreadPoolThread}");RunAsync();Console.WriteLine($"main方法Ends:线程ID:{Thread.CurrentThread.ManagedThreadId},是否在线程池{Thread.CurrentThread.IsThreadPoolThread}");Console.ReadLine();
}public static async void RunAsync() //异步方法必须使用async
{Console.WriteLine( $"RunAsync方法Begin:线程ID:{Thread.CurrentThread.ManagedThreadId},是否在线程池{Thread.CurrentThread.IsThreadPoolThread}" );//await开启异步任务await Task.Run(() =>{Console.WriteLine($"Task方法Begin:线程ID:{Thread.CurrentThread.ManagedThreadId},是否在线程池{Thread.CurrentThread.IsThreadPoolThread}");long sum = 0;for (long i = 0; i < 10000000000; i++) {sum += i;};Console.WriteLine();Console.WriteLine($"Task方法End:线程ID:{Thread.CurrentThread.ManagedThreadId},是否在线程池{Thread.CurrentThread.IsThreadPoolThread}");});Console.WriteLine($"RunAsync方法End:线程ID:{Thread.CurrentThread.ManagedThreadId},是否在线程池{Thread.CurrentThread.IsThreadPoolThread}");}
打印结果:
main方法Begins:线程ID:1,是否在线程池False
RunAsync方法Begin:线程ID:1,是否在线程池False
main方法Ends:线程ID:1,是否在线程池False
Task方法Begin:线程ID:3,是否在线程池TrueTask方法End:线程ID:3,是否在线程池True
RunAsync方法End:线程ID:3,是否在线程池True
使用async和await执行有返回值的方法,异步任务的返回值类型默认为Task,await作用有两个,分流和获取任务返回值的功能,没有await关键字,则相当于同步方法:
static void Main(string[] args){Console.WriteLine($"main方法Begins:线程ID:{Thread.CurrentThread.ManagedThreadId},是否在线程池{Thread.CurrentThread.IsThreadPoolThread}");RunAsync();Console.WriteLine($"main方法Ends:线程ID:{Thread.CurrentThread.ManagedThreadId},是否在线程池{Thread.CurrentThread.IsThreadPoolThread}");Console.ReadLine();
}public static async void RunAsync()
{long result=await GetSumAsync(); //必须使用await,getsum是任务,异步分流Console.WriteLine($"计算结果是:{result}");
}
public static async Task<long> GetSumAsync()
{return await Task.Run(() =>{long sum = 0;for (long i = 0; i < 1000000000; i++){sum += i;}return sum; });
}
打印结果:
main方法Begins:线程ID:1,是否在线程池False
main方法Ends:线程ID:1,是否在线程池False
计算结果是:499999999500000000