经验大分享:Task的用法

简介: 经验大分享:Task的用法

Task用法记录总结

1.创建Task的3种方法

1.1new方式实例化一个Task,需要通过Start方法启动

Task task = new Task(() =>

{

Thread.Sleep(100);

Console.WriteLine($"hello, task1的线程ID为{Thread.CurrentThread.ManagedThreadId}");

});

task.Start();

task.Start方式,每个task都在不同的线程中

代码:

private static void Main(string【】 args)

{

Console.WriteLine("Hello, World!");

Task task1 = new Task(() =>

{

Console.WriteLine("task1 is running on a thread id {0}. Is thread pool thread: {1}",

Thread.CurrentThread.ManagedThreadId,

Thread.CurrentThread.IsThreadPoolThread);

});

Task task2 = new Task(() =>

{

Console.WriteLine("task2 is running on a thread id {0}. Is thread pool thread: {1}",

Thread.CurrentThread.ManagedThreadId,

Thread.CurrentThread.IsThreadPoolThread);

});

Task task3 = new Task(() =>

{

Console.WriteLine("task3 is running on a thread id {0}. Is thread pool thread: {1}",

Thread.CurrentThread.ManagedThreadId,

Thread.CurrentThread.IsThreadPoolThread);

});

//不在同一个线程

task1.Start();

task2.Start();

task3.Start();

//在同一个线程

//task1.RunSynchronously();

//task2.RunSynchronously();

//task3.RunSynchronously();

Task.WaitAll(task1,task2,task3);

}

View Code

task.RunSynchronously方式,每个任务都在同一个线程。task会阻塞主线程

task.Start方式,不会阻塞主线程

1.2Task.Factory.StartNew(Action action)创建和启动一个Task

Task task2 = Task.Factory.StartNew(() =>

{

Thread.Sleep(100);

Console.WriteLine($"hello, task2的线程ID为{Thread.CurrentThread.ManagedThreadId}");

});

创建后自动运行Task

1.3Task.Run(Action action)将任务放在线程池队列,返回并启动一个Task

Task task3 = Task.Run(() =>

{

Thread.Sleep(100);

Console.WriteLine($"hello, task3的线程ID为{Thread.CurrentThread.ManagedThreadId}");

});

创建后自动运行Task

2.Task的Wait/WaitAny/WaitAll方法

task.Wait() 表示等待task执行完毕

Task.WaitAll(Task【】 tasks) 表示只有所有的task都执行完成了再解除阻塞

private static void Main(string【】 args)

{

Console.WriteLine("start");

Task task1 = new Task(() =>

{

Thread.Sleep(1000);

Console.WriteLine("task1 is running on a thread id {0}//代码效果参考:http://www.ezhiqi.com/zx/art_3426.html . Is thread pool thread: {1}",

Thread.CurrentThread.ManagedThreadId,

Thread.CurrentThread.IsThreadPoolThread);

});

Task task2 = new Task(() =>

{

Thread.Sleep(2000);

Console.WriteLine("task2 is running on a thread id {0}. Is thread pool thread: {1}",

Thread.CurrentThread.ManagedThreadId,

Thread.CurrentThread.IsThreadPoolThread);

});

Task task3 = new Task(() =>

{

Thread.Sleep(3000);

Console.WriteLine("task3 is running on a thread id {0}. Is thread pool thread: {1}",

Thread.CurrentThread.ManagedThreadId,

Thread.CurrentThread.IsThreadPoolThread);

});

// 不在同一个线程

task1.Start();

task2.Start();

task3.Start();

Task.WaitAll(task1,task2,task3);

Console.WriteLine("task 1 2 3 end");

}

task1 等待1秒,task2等待2秒 task3等待3秒,使用WaitAll,则会等所有任务执行完毕之后才结束。

Task.WaitAny(Task【】 tasks) 表示只要有一个task执行完毕就解除阻塞

task1 等待1秒,task2等待2秒 ,task3等待3秒,使用WaitAny,只要有一个task结束,就结束阻塞。这里task最先结束

3.Task的延续操作(WhenAny/WhenAll/ContinueWith)

Task.WhenAll(task1, task2, task3).ContinueWith((t) => {

//dosomething

Console.WriteLine("task 1 2 3 all End");

});

当task完成后执行某些操作。

4.带返回值的Task

private static int Main(string【】 args)

{

//1.new方式实例化一个Task

Task[span style="color: rgba(0, 0, 255, 1)">intint

{

Thread.Sleep(100);

Console.WriteLine($"hello, task1的线程ID为{Thread.CurrentThread.ManagedThreadId}");

return 12;

});

task.Start();

int ret = task.Result;

task.Wait();

Console.WriteLine(ret);

//2.Task.Run

Task[span style="color: rgba(0, 0, 255, 1)">intint

{

Thread.Sleep(1000);

Console.WriteLine($"hello, task2的线程ID为{Thread.CurrentThread.ManagedThreadId}");

return 13;

});

int ret2 = task2.Result;

Console.WriteLine(ret2);

//3.Task.Factory.StartNew

Task[span style="color: rgba(0, 0, 255, 1)">int

{

Thread.Sleep(100);

Console.WriteLine($"hello, task3的线程ID为{Thread.CurrentThread.ManagedThreadId}");

return 14;

});

int ret3 = task3.Result;

Console.WriteLine(ret3);

return 0;

}

5.异步async awit

private static void Main(string【】 args)

{

Console.WriteLine("begin download");

Task task = download();

Console.WriteLine("end download");

}

static async Task[span style="color: rgba(0, 0, 255, 1)">int

{

Console.WriteLine("开始");

await Task.Run(() => { Thread.Sleep(2222); });

Console.WriteLine("结束");

return 666;

}

可以看到主线程退出了,但download异步方法还没结束。

深入理解异步:

一文说通C#中的异步编程 - 老王Plus - 博客园 (cnblogs.com)

相关文章
|
9天前
|
缓存 JavaScript
技术经验解读:关于watch的常见用法
技术经验解读:关于watch的常见用法
|
2月前
|
Java C#
C#学习相关系列之多线程(七)---Task的相关属性用法
C#学习相关系列之多线程(七)---Task的相关属性用法
|
2月前
|
Java C#
C#学习相关系列之多线程(六)----Task的初级使用
C#学习相关系列之多线程(六)----Task的初级使用
|
2月前
|
存储 SQL 关系型数据库
探秘MSSQL存储过程:功能、用法及实战案例
探秘MSSQL存储过程:功能、用法及实战案例
104 1
高并发编程-深入分析wait和sleep的区别并结合源码示例佐证
高并发编程-深入分析wait和sleep的区别并结合源码示例佐证
97 0
|
前端开发
前端学习案例1-call,apply的重用
前端学习案例1-call,apply的重用
59 0
前端学习案例1-call,apply的重用
|
调度
Thread 类的基本用法——一网打尽
Thread 类的基本用法——一网打尽
|
运维 Prometheus Kubernetes
工作用Go: 异步任务怎么写6 | Asynq: 专业异步任务框架
工作用Go: 异步任务怎么写6 | Asynq: 专业异步任务框架
1780 0
工作用Go: 异步任务怎么写6 | Asynq: 专业异步任务框架
ts重点学习126-装饰器的小例子笔记
ts重点学习126-装饰器的小例子笔记
68 0
ts重点学习50-函数得参数得处理方式笔记
ts重点学习50-函数得参数得处理方式笔记
78 0