经验大分享: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)

相关文章
|
2月前
|
存储
向量化代码实践问题之Task<T>类中的on_completed函数是如何工作的
向量化代码实践问题之Task<T>类中的on_completed函数是如何工作的
|
4月前
|
Java C#
C#学习相关系列之多线程(七)---Task的相关属性用法
C#学习相关系列之多线程(七)---Task的相关属性用法
|
4月前
|
Java C#
C#学习相关系列之多线程(六)----Task的初级使用
C#学习相关系列之多线程(六)----Task的初级使用
|
安全 Go
大白话讲讲 Go 语言的 sync.Map(二)
上一篇文章《大白话讲讲 Go 语言的 sync.Map(一)》讲到 entry 数据结构,原因是 Go 语言标准库的 map 不是线程安全的,通过加一层抽象回避这个问题……
105 1
|
存储 程序员 Go
大白话讲讲 Go 语言的 sync.Map(一)
在讲 sync.Map 之前,我们先说说什么是 map(映射)。我们每个人都有身份证号码,如果我需要从身份证号码查到对应的姓名,用 map 存储是非常合适的……
118 1
高并发编程-深入分析wait和sleep的区别并结合源码示例佐证
高并发编程-深入分析wait和sleep的区别并结合源码示例佐证
111 0
|
前端开发
前端学习案例1-call,apply的重用
前端学习案例1-call,apply的重用
70 0
前端学习案例1-call,apply的重用
|
运维 Prometheus Kubernetes
工作用Go: 异步任务怎么写6 | Asynq: 专业异步任务框架
工作用Go: 异步任务怎么写6 | Asynq: 专业异步任务框架
1862 0
工作用Go: 异步任务怎么写6 | Asynq: 专业异步任务框架
|
Java Linux 程序员
Java的wait()、notify()学习三部曲之二:修改JVM源码看参数
线程同步相关的JVM源码分析系列之二,修改源码查看运行时的虚拟机参数
224 0
Java的wait()、notify()学习三部曲之二:修改JVM源码看参数
|
Rust 运维 Cloud Native
HAVE FUN | 源码解析活动进展
在第一篇源码解析活动文中,我们介绍了 SOFARegistry 源码解析的详细介绍与具体参与方法,错过的小伙伴可以点击回顾哦,活动还在进行中...
HAVE FUN | 源码解析活动进展