.Net并行编程之二:并行循环

本篇内容主要包括:

1.能够转化为并行循环的条件

2.并行For循环的用法:Parallel.For

3.并行ForEach的用法Parallel.ForEach

4.并行LINQ(PLINQ)的用法AsParallel()

5.并行中断与并行停止的用法与区别

6.外部控制循环取消的方法(Break,Stop)

7.处理循环体中抛出的异常

8.小循环体的分区并行方法:Parallel.ForEach

9.最大并行度的控制,Parallel.For,Parallel.ForEach

10.在循环体中使用局部任务状态(个人理解就是循环体中包含几个阶段,但是这个阶段又要求能线程安全的调用这些方法)

11.尝试给并行循环定义自己的任务调度程序。

12.注意事项。

-------------------华丽的分割线-----------------------------------------

1.能够转化为并行循环的条件

.Net Framework 4.0,VisualStudio2010,XP sp3,Vista SP1,Win7,Win8,Win2008...

对集合中的元素的操作是相同的并且互不影响,不互相影响是指执行的先后顺序不影响最后结果。

生活中的场景举例:

a:把银行的多个服务窗口看成是多个处理器核心,不同的客户取款操作是相互不影响的。当客户总量一定时,多个窗口同时开放要比只开放一个窗口效率要高很多。

b:考试之后,老师判卷子,参加判卷子的老师越多,处理完所有卷子时间越短

c:程序中处理/初始化一个高数量级的对象数组,对象之间相互独立

2.并行For循环的用法:Parallel.For

public int NumberOfSteps = 10000000;
double[] result = new double[NumberOfSteps];
for (int i = 0; i < NumberOfSteps; i++)
{
result[i] = DoWork(i);
}

一般的顺序执行的For

  public int NumberOfSteps = 10000000;
double[] result = new double[NumberOfSteps];

Parallel.For(0, NumberOfSteps, (i) =>
{
result[i] = DoWork(i);

});

并行的For

例子中的方法原型为:public static ParallelLoopResult For(int fromInclusive, int
toExclusive, Action<int> body);

返回值为ParallelLoopResult,指示结果的状态,定义如下

 public struct ParallelLoopResult
{
public bool IsCompleted { get; }
public long? LowestBreakIteration { get; }
}

ParallelLoopResult

Parallel.For 共有12种重载类型,上面是最简单的一种,其它类型的重载可以用来指定一些并行运行的配置,比如并行度,取消标记等。

3.并行ForEach的用法Parallel.ForEach

未完待续...

.Net并行编程之二:并行循环

时间: 2024-10-24 19:47:39

.Net并行编程之二:并行循环的相关文章

socket编程之二:两种链接类型upd和upd

前面一篇文章说到了一些计算机网络的基础知识,引入了socket,从这节开始,就进入正题了. 一 概率 TCP:Transimission Control Protocol传输控制协议. UPD:User Datagram Protocol用户数据包协议. 两者都属于上一篇文章说的OSI模型中的第四层--传输层的协议. 两者相比: TCP协议面向连接,UDP协议面向非连接:(链接) TCP协议传输速度慢,UDP协议传输速度快:(速度) TCP有丢包重传机制,UDP没有:(重传) TCP协议保证数据

C++ 并行编程之memory_order

一.如果只是简单地解决在多线程中对共享资源的读写并发问题,只需要用C++以下内容: 线程类 thread, 原子数据类模板 atomic<T> t, 互斥 mutex, 锁 lock, 条件变量 condition_variables. 二.在此基础上,如果想在并行编程中获得更好的性能,尤其当使用的是一些弱内存顺序的平台(比如PowerPC)的话,设定原子操作间的内存顺序则很有必要. C++11 加入了支持并行编程的原子操作模块,而所有的原子操作都有一个参数 memory_order. 1.内

Python之路——并行编程之multiprocessing模块

Process 1 import socket 2 import time 3 from multiprocessing import Process 4 5 def talk(conn): 6 if type(conn)==socket.socket(): 7 conn.send(b'connected') 8 msg = conn.recv(1024) 9 print(msg) 10 conn.close() 11 12 13 if __name__ == '__main__': 14 sk

深入理解多线程编程之二

一.NSOperation 1.简介 NSOperation实例封装了需要执行的操作和执行操作所需的数据,并且能够以并发或非并发的方式执行这个操作. NSOperation本身是抽象基类,因此必须使用它的子类,使用NSOperation子类的方式有2种: 1> Foundation框架提供了两个具体子类直接供我们使用:NSInvocationOperation和NSBlockOperation 2> 自定义子类继承NSOperation,实现内部相应的方法 2.执行操作 NSOperation

菜鸟的Linux之路3 bash脚本编程之二

整数测试及特殊变量     在开始之前我们先介绍一个可以提前结束脚本的命令->exit exit的作用是退出当前进程.退出当前脚本,任何一个命令或者说是任何一个进程执行结束的时候都会有一个执行结果返回值和一个执行状态结果返回值,exit是用来让用户自定义执行状态结果返回值的命令. 命令.脚本或者说是进程的执行状态结果有两种情况: ->正确执行 ->错误执行 而这种状态可以使用exit命令自定义. exit命令使用格式:exit #(0-255) 0值,表示执行正确 1-255的值,均表示

python异步socket编程之二

三.异步client与异步server的通信 1. 服务端代码 pythone socket的server段,开放三个端口:10000,10001,10002. 例子中是每个server绑定一个端口,测试的时候需要分别开3个shell,分别运行. 这太麻烦了,就分别用三个Thread来运行这些services #!/usr/bin/env python # # -*- coding:utf-8 -*- # File: multithrd_socket_server.py # import opt

并发编程之二

线程安全 线程安全这个词汇实在是折磨人,它给人一种错觉,让你仿佛很轻松的理解了它,但实则是一个典型的笑面虎,背后冷不丁就给你一刀,让你血溅职场. 我们先来看下这个词语组成的词汇都有哪些,首先后面可以加一“性”字,此为线程安全性.另外,如果后面加“类”或者“程序”,就组成了线程安全类或者是线程安全程序.很显然,线程安全性是类和程序的属性,就像一个类或者程序的其它属性一样,例如扩展性.维护性等等. 到现在重点就出来了,到底什么是线程安全性?从字面上看,线程安全性就是一个类或者程序在多线程的环境中运行

UDP编程之二

广播模型 broadcast.c 1 #include <apue.h> 2 3 #define PORT 8088 4 5 int main(int argc,char **argv) 6 { 7 if(argc!=2) 8 { 9 printf("%s <msg>\n",argv[0]); 10 exit(0); 11 } 12 13 int sockfd; 14 if((sockfd = socket(AF_INET,SOCK_DGRAM,0))<0

IOS高级编程之二:IOS的数据存储与IO

一.应用程序沙盒 IOS应用程序职能在系统为该应用所分配的文件区域下读写文件,这个文件区域就是应用程序沙盒.所有的非代码文件如:图片.声音.映象等等都存放在此. 在mac中command+shift+G命令,然后输入users/用户名/library命令进入库,然后依次进入application support/iphone simulator/版本/applications文件夹,这里面的各个文件夹对应着各个应用程序. Documents:除了基于NSUserDefaults的首选项设置外,应