在处理很多数据的时候,加入C#新特性的并行和任务来实现多线程,超级有趣。
先说2个小代码。
一个是Task任务,相当于旧版的Thread多线程。但是在.net 4.0以后都统称为Task任务了。其实就是多线程。
一、Task多线程,线程结束后执行特定的代码。
Task task = new Task(() =>
{
//这里执行工作的主体,但是不能操作界面,会造成线程崩溃。
//合理的方法是在前面就把界面元素交给特定的值,比如
//string content=txtContent.Text;然后线程内部就可以使用这个content了。
});
task.Start();//开始这个任务
task.ContinueWith((t) =>
{
//任务完成后执行这里的代码,比如一个提示,或者数据显示到界面之类的。
});
Task里面可以去循环执行持 久任务,不会卡死界面。
这里只有一个线程,真正多个分开的线程可以用List<Task>去执行。线程取消使用CancellationTokenSource 也非常简单。
有研究的朋友自己先行尝试一下吧。
二、Parallel并行编程
个人感觉 这块超级爽。原来fore和Foreach执行代码要花 一天的时间,这个一般只需要1个小时不到吧。
尽可能的利用了电脑的硬件资源进行并行开发。具体什么是并行编程,建议自己百度一下。也很好理解,就是每个程序分开在不同的地方去执行。个人感觉和多线程一样。
举个例子,我的数组 List<string>里面有10000万行数据。我要提取指定的包函特定关键词的数据出来。用for和foreach会折腾死人的。
我们用并行来试试吧。
ConcurrentQueue<string> data = new ConcurrentQueue<string>();
List<string> data = new List<string>();
Parallel.ForEach(Data, (oneline) =>
{
if (oneline.indexof(" 关键词")>-1)
data.Add(oneline);
});
Console.WriteLine("执行完成ForEach.");
ConcurrentQueue是线程安全的队列,防止同时多个线程添加数据的时候出现死锁或者其它异常。
parallel.foreah就是遍历每一行,每一行得到的结果是online ,我们再判断每个oneline是不是包括我们要判断的
关键词。包括就存到结果里面去,最后显示出来就O了。
并行会造成界面假死,如果外面还要包装一个Task。在Task的工作代码段放下这段并行代码。
享受下超级无敌极速的体验吧。