一起谈.NET技术,.Net4.0 Parallel编程(一)Data Parallelism 上

  Parallel.For

  首先先写一个普通的循环:


private void NormalFor()
{
for (var i = 0; i < 10000; i++)
{
for (var j = 0; j < 1000; j++)
{
for (var k = 0; k < 100; k++)
{
DoSomething();
}
}
}
}

  再看一个并行的For语句:


private void ParallelFor()
{
Parallel.For(0, 10000, i =>
{
for (int j = 0; j < 1000; j++)
{
for (var k = 0; k < 100; k++)
{
DoSomething();
}
}

});
}

  看下测试方法:


[TestMethod()]
public void TestForLoop()
{

_StopWatch.Start();
this.NormalFor();
_StopWatch.Stop();
Console.WriteLine("NormalForLoop Runned Time:{0}", _StopWatch.ElapsedMilliseconds);

_StopWatch.Reset();
_StopWatch.Start();
this.ParallelFor();
_StopWatch.Stop();
Console.WriteLine("Parallel Loop:{0}", _StopWatch.ElapsedMilliseconds);
}

  测试结果:

  上面的例子中,只是将最外层的For语句替换成了Parallel.For,我们可以看到Parallel执行速度提高了近一倍。下面我把里面的循环也改成并行的:


private void ParallelNestedFor()
{
Parallel.For(0, 10000, i =>
{
Parallel.For(0, 1000, j =>
{
for (var k = 0; k < 100; k++)
{
DoSomething();
}
});

});
}

  结果:

  也许会令我们感到惊讶的是:嵌套Paralled For之后速度并没有更快,反而稍微慢了。其实是这样的,因为我们的示例中大部分操作是在最外层循环,而在并行操作中会需要缓存数据等会浪费一定的性能。当我们把最外层的循环调整成100,中间层为10000时,我们来看下结果:

  所以,是否需要嵌套的时候,需要我们根据一些实际情况来决定,不过对于大部分操作,最外层的并行处理已经足够了。

  Parallel.ForEach

  我们来看两段很简单的代码:


private void NormalForeach()
{
foreach (var file in GetFiles())
{
DoSomething();
}

}

private void ParallelForeach()
{
Parallel.ForEach(GetFiles(), file => {
DoSomething();
});
}

  测试的结果:

  Foreach的使用跟For使用几乎是差不多了,只是在对非泛型的Collection进行操作的时候,需要通过Cast方法进行转换。

  总结

  在本文中,我们简单的介绍了Parallel.For跟Parallel.Foreach方法的使用,感受了下并行编程给我们带来的速度上的优势,在下篇文章中会介绍如何跳出循环以及一些异常的处理。

时间: 2024-10-26 10:16:50

一起谈.NET技术,.Net4.0 Parallel编程(一)Data Parallelism 上的相关文章

一起谈.NET技术,.Net4.0 Parallel编程(二)Data Parallelism 中

在上篇文章中看过了使用Parrallel.For.Parael.Foreach在效率上给我们带来的提高.本文就来如何终止循环.线程局部变量 进行说明. Thread-Local Variables 首先我们来看下线程局部变量,是的我们也许一直在想我们如何去定义一个线程局部变量呢.先看段顺序执行的代码: [TestMethod()]public void NormalSequenceTest(){int[] nums = Enumerable.Range(0, 1000000).ToArray()

.Net4.0 Parallel编程(二)Data Parallelism 中

在上篇文章中看过了使用Parrallel.For.Parael.Foreach在效率上给我们带来的提高.本文就来如何终止循环.线程局部变量 进行说明. Thread-Local Variables 首先我们来看下线程局部变量,是的我们也许一直在想我们如何去定义一个线程局部变量呢.先看段顺序执行的代码: [TestMethod()] public void NormalSequenceTest() { int[] nums = Enumerable.Range(0, 1000000).ToArra

一起谈.NET技术,.Net4.0 Parallel编程(三)Data Parallelism 下

在上篇文章中介绍了如何Break.Stop循环,以及如何定义线程局部变量.在本文中介绍如何在外部去取消循环.以及异常的处理. Cancel 在并行的循环中支持通过传递ParallelOptions参数中的CancellationToken进行取消循环的控制,我们可以CancellationTokenSource实例化之后传递给ParallelOptions对象Cancellation值.下面来看个示例: [TestMethod]public void CancelLoop(){ var sour

一起谈.NET技术,.Net4.0 Parallel编程(四)Task 上

在之前的文章中,已经介绍过了Parallel Loop(上.中.下)的相关内容.本篇文章中会就Task基础部分进行些介绍. 初识Task 首先我们来构建一个简单的Task的Demo: static void Main(string[] args){ Task.Factory.StartNew(() => { Console.WriteLine("Hello word!"); }); Console.Read();} 在上面这段代码中我们构建出了一段非常简单的使用Task类的代码,

.Net4.0 Parallel编程(一)Data Parallelism 上

Parallel.For 首先先写一个普通的循环: private void NormalFor() { for (var i = 0; i < 10000; i++) { for (var j = 0; j < 1000; j++) { for (var k = 0; k < 100; k++) { DoSomething(); } } } } 再看一个并行的For语句: private void ParallelFor() { Parallel.For(0, 10000, i =&g

.Net4.0 Parallel编程(三)Data Parallelism 下

在上篇文章中介绍了如何Break.Stop循环,以及如何定义线程局部变量.在本文中介绍如何在外部去取消循环.以及异常的处理. Cancel 在并行的循环中支持通过传递ParallelOptions参数中的CancellationToken进行取消循环的控制,我们可以CancellationTokenSource实例化之后传递给ParallelOptions对象Cancellation值.下面来看个示例: [TestMethod] public void CancelLoop() { var so

.Net4.0 Parallel编程(四)Task 上

在之前的文章中,已经介绍过了Parallel Loop(上.中.下)的相关内容.本篇文章中会就Task基础部分进行些介绍. 初识Task 首先我们来构建一个简单的Task的Demo: static void Main(string[] args) { Task. Factory.StartNew(() => { Console.WriteLine("Hello word!"); }); Console.Read(); } 在上面这段代码中我们构建出了一段非常简单的使用Task类的

一起谈.NET技术,.Net 4.0 Parallel 编程(五)Task (中)

在上篇文章中我们看过了如何创建Task,本篇文章就各种类型Task的使用进行说明. Task Continuations 首先我们来看看延续的Task,所谓的延续的Task就是在第一个Task完成后自动启动下一个Task.我们通过ContinueWith方法来创建延续的Task.我们假设有一个接受xml解析的服务,首先从某个地方接受文件,然后解析入库,最后返回回执是否解析正确: [TestMethod]public void TaskParallelPrint() { var ReceiveTa

一起谈.NET技术,对抽象编程:接口和抽象类

1. 引言 在我之前的一篇post <抽象类和接口的谁是谁非 >中,和同事管伟的讨论,得到很多朋友的关注,因为是不成体系的论道,所以给大家了解造成不便,同时关于这个主题的系统性理论,我认为也有必要做以总结,因此才有了本篇的新鲜出炉.同时,我将把上贴中的问题顺便也在此做以交代. 2. 概念引入       什么是接口? 接口是包含一组虚方法的抽象类型,其中每一种方法都有其名称.参数和返回值.接口方法不能包含任何实现,CLR 允许接口可以包含事件.属性.索引器.静态方法.静态字段.静态构造函数以及