首页 > 编程语言 > 详细

更简洁的线程安全的并行 accumulate

时间:2015-10-24 20:08:15      阅读:250      评论:0      收藏:0      [点我收藏+]
template<typename Iterator, typename T>
T parallelAccumulate(Iterator first, Iterator last, T init)
{
    size_t const length = std::distance(first, last);
    if (length == 0){
        return init;
    }
    
    static constexpr size_t maxChunkSize = 25;
    if (length <= maxChunkSize){
        return std::accumulate(first, last, init);
    }
    
    auto midIterator = first;
    std::advance(midIterator, (length / 2));
    auto formerHalfResult = std::async(parallelAccumulate<Iterator, T>,
                                       first, midIterator, init);
    auto latterHalfResult = parallelAccumulate(midIterator, last, T());
    return (formerHalfResult.get() + latterHalfResult);
}

递归地划分数据,短就短在: 1.递归 2. 把线程数量扔给标准库和系统调度。

更简洁的线程安全的并行 accumulate

原文:http://www.cnblogs.com/wuOverflow/p/4907356.html

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