标签：c style class blog http a
Partitioner.Create(1,10,4).GetDynamicPartitions()
为长度为10的序列创建分区，每个分区至多4个元素，分区方法及结果：Partitioner.Create(0,
10, 4).GetDynamicPartitions()
得到3个前闭后开区间: [0,
4)即{0, 1, 2, 3}, [4, 8)即{4,
5, 6, 7}, [8,
10)即{8, 9}, 注意被枚举的数字均为数组下标；
为长度为10的序列创建分区，至多4个分区，分区方法及结果：
Partitioner.Create(0, 10, 3).GetDynamicPartitions()
得到4个前闭后开区间: [0,3)即{0,
1, 2}, [3,
6)即{3, 4, 5}, [6, 9)即{6,
7, 8}, [9,
10)即{9}, 注意被枚举的数字均为数组下标；
定义分区个数
= 定义并发线程(笔者这样讲并不严格), 故定义方法如下:
private static void
NewMethod<T>(IList<T> array, Int32 rangeCount) {
var
rangeSize = (Int32)Math.Ceiling(array.Count / (Double)rangeCount);
var
part = Partitioner.Create(0, array.Count, rangeSize);
Parallel.ForEach(part, (range, state, rangeIndex) => {
for (Int32 index = range.Item1; index < range.Item2; index++)
{
Console.WriteLine("[{0,2}] {1} {2}",
Thread.CurrentThread.ManagedThreadId, rangeIndex, index);
}
});
}
对于分区个数定义为3,
可以看到线程ID 在1,3,4中切换, 线程[1]遍历了4个元素, 线程[3]遍历了4个元素, 线程[4]遍历了2个元素
对于分区个数定义为4,
可以看到线程ID 在1, 3, 4, 5中切换, 线程[1]遍历了3个元素, 线程[3]遍历了3个元素, 线程[4]遍历了3个元素,
线程5遍历了1个元素.
Parallel中分区器Partitioner的简单使用,布布扣,bubuko.com
Parallel中分区器Partitioner的简单使用
标签：c style class blog http a
原文地址：http://www.cnblogs.com/Jusfr/p/3758055.html
