首页 > 其他 > 详细

Parallel中分区器Partitioner的简单使用

时间:2014-05-29 23:34:55      阅读:569      评论:0      收藏:0      [点我收藏+]
Partitioner.Create(1,10,4).GetDynamicPartitions()
为长度为10的序列创建分区,每个分区至多4个元素,分区方法及结果:Partitioner.Create(0, 10, 4).GetDynamicPartitions()
bubuko.com,布布扣
得到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()
bubuko.com,布布扣
得到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个元素
bubuko.com,布布扣
 
对于分区个数定义为4, 可以看到线程ID 在1, 3, 4, 5中切换, 线程[1]遍历了3个元素, 线程[3]遍历了3个元素, 线程[4]遍历了3个元素, 线程5遍历了1个元素.
bubuko.com,布布扣

Parallel中分区器Partitioner的简单使用,布布扣,bubuko.com

Parallel中分区器Partitioner的简单使用

原文:http://www.cnblogs.com/Jusfr/p/3758055.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!