惯性聚合 高效追踪和阅读你感兴趣的博客、新闻、科技资讯
阅读原文 在惯性聚合中打开

推荐订阅源

V
Visual Studio Blog
OSCHINA 社区最新新闻
OSCHINA 社区最新新闻
N
Netflix TechBlog - Medium
博客园 - 叶小钗
大猫的无限游戏
大猫的无限游戏
S
SegmentFault 最新的问题
V
V2EX
IT之家
IT之家
J
Java Code Geeks
Hacker News - Newest:
Hacker News - Newest: "LLM"
cs.AI updates on arXiv.org
cs.AI updates on arXiv.org
GbyAI
GbyAI
D
Docker
S
Secure Thoughts
Recent Announcements
Recent Announcements
Webroot Blog
Webroot Blog
Application and Cybersecurity Blog
Application and Cybersecurity Blog
云风的 BLOG
云风的 BLOG
博客园_首页
cs.CV updates on arXiv.org
cs.CV updates on arXiv.org
Cyber Security Advisories - MS-ISAC
Cyber Security Advisories - MS-ISAC
Security Archives - TechRepublic
Security Archives - TechRepublic
酷 壳 – CoolShell
酷 壳 – CoolShell
让小产品的独立变现更简单 - ezindie.com
让小产品的独立变现更简单 - ezindie.com
N
News | PayPal Newsroom
S
Security @ Cisco Blogs
I
InfoQ
Last Week in AI
Last Week in AI
SecWiki News
SecWiki News
钛媒体:引领未来商业与生活新知
钛媒体:引领未来商业与生活新知
W
WeLiveSecurity
T
Troy Hunt's Blog
Recent Commits to openclaw:main
Recent Commits to openclaw:main
H
Hackread – Cybersecurity News, Data Breaches, AI and More
Attack and Defense Labs
Attack and Defense Labs
美团技术团队
T
The Blog of Author Tim Ferriss
Google DeepMind News
Google DeepMind News
Martin Fowler
Martin Fowler
B
Blog
CTFtime.org: upcoming CTF events
CTFtime.org: upcoming CTF events
Scott Helme
Scott Helme
T
Tor Project blog
Know Your Adversary
Know Your Adversary
有赞技术团队
有赞技术团队
Hugging Face - Blog
Hugging Face - Blog
Recorded Future
Recorded Future
C
Cyber Attacks, Cyber Crime and Cyber Security
AI
AI
G
Google Developers Blog

博客园 - Kain

Microsoft.Practices.Unity 的一个线程安全Bug浅析 NET Reflector 7发布,其 不再免费 (抽象)工厂的另一种实现方式 自定义EF4 Model 代码生成 .net 4.0 中对多线程新特性(三) .net 4.0 中对多线程新特性(二) .net 4.0 中对多线程新特性(一) Flex&.Net开篇 SqlSever N层表数据查询效率 [读书笔记]Start-up fatigue(启动杂役) 马上又要过中秋和国庆了! 一个小问题 C#2.0 新的关键字 yield 我们的游戏! 不知道有没有同在学习aspnetforums的 郁闷! 关于面试 关于DataGride的Key事件 开心就好!
.net 4.0 中对多线程新特性(四)--任务和任务工厂
Kain · 2010-08-12 · via 博客园 - Kain

在4.0前如果需要进行并行任务往往都是自己实现Task和Task Factory来管理任务,其中难免会牵涉到大量的线程和线程池的管理工作。到了4.0 这部分内容都已经集成到基础类库中了。在System.Threading.Task中新增了几个类:

Task

TaskFactory

TaskScheduler

这几个类一看名字就知道干啥的了,先看看Task的一个简单例子

代码

 1 [STAThread]
 2         static void Main()
 3         {
 4             var tasks = new Task[10];
 5             for (int i = 0; i < 10; i++)
 6             {
 7                 tasks[i] =   new Task(Action,TaskCreationOptions.LongRunning);
 8                 tasks[i].Start();
 9             }
10             
11             //Task.WaitAll(tasks);
12 
13             Console.WriteLine("Finished");
14             Console.ReadLine();
15         }
16 
17         static Random rd = new Random();
18         static void Action()
19         {
20             var threadId = Thread.CurrentThread.ManagedThreadId;
21             Console.WriteLine("Current Thread Id:{0}" ,threadId);
22             Thread.Sleep(rd.Next(1001000));//随机休眠一段时间,模拟线程实际调用时间消耗
23         }

程序输出如下:

Current Thread Id:11

Finished

Current Thread Id:12

Current Thread Id:14

Current Thread Id:13

...

(实际的输出可能和这里有所不同)

细心的你可能会发现代码中的第11行已经被注释了,WaitAll的名字是不是非常熟悉?是的,这在我们做线程同步时经常会用到WaitHandle类的WaitAll效果是一样的

取消注释运运行一下我们会得到如下输出:

Current Thread Id:11

Current Thread Id:12

Current Thread Id:14

Current Thread Id:13

...

Finished

在输出中的Finished一定会等所有的Task完成之后才会输出。是不是非常容易了。Task启动的时候会自动使用到线程池,系统会给Task自动分配线程。

如果任务很多的时时候我们需要细粒度的控制每个Taks的调度Schedule可以用TaskFactory就是来完成做这个工作的,看个简单的例子:

代码

 1 [STAThread]
 2         static void Main()
 3         {
 4             var factory = new TaskFactory();
 5             var tasks = new Task[10];
 6             for (int i = 0; i < 10; i++)
 7             {
 8                 tasks[i] = factory.StartNew(Action );
 9             }
10             
11             Task.WaitAll(tasks);
12 
13             Console.WriteLine("Finished");
14             Console.ReadLine();
15         }
16 
17         static Random rd = new Random();
18         static void Action()
19         {
20             var threadId = Thread.CurrentThread.ManagedThreadId;
21             Console.WriteLine("Current Thread Id:{0}" ,threadId);
22             Thread.Sleep(rd.Next(1001000));//随机休眠一段时间,模拟线程实际调用时间消耗
23         }

程序输出如下:

Current Thread Id:11
Current Thread Id:11
Current Thread Id:12
Current Thread Id:11
Current Thread Id:11
Current Thread Id:12
Current Thread Id:11
Current Thread Id:12
Current Thread Id:11
Current Thread Id:12
Finished

从结果中看到10个任务只分配到了2个线程来处理,线程被最大的限度的复用了。如果需要更好的控制任务的调度,你需显示的配置TaskScheduler,对于你来说应该非常easy的