【问题标题】:C++ divide for loop with threadsC++ 用线程除法循环
【发布时间】:2015-08-17 21:26:20
【问题描述】:
    #include<iostream>
    #include<thread>
    using namespace std ;
    void dowork(size_t s , size_t e, size_t *se )
    {
     for(size_t  i = s ; i < e; i++)
            se += i ;
    }

    int main(void)
    {
        int numthreads = std::thread::hardware_concurrency() ;
        size_t start = 0 ;
        size_t end = 12;
        size_t chunk = (end - start + (numthreads - 1))/numthreads ;
        cout<< chunk ;
        std::thread t[numthreads] ;
        size_t sum = 0 ;
        for(int i = 0 ; i < numthreads ; i++ )
        {
            size_t s = start + i * chunk ;
            size_t e = s + chunk ;
            t[i] = std::thread(dowork, s, e, &sum) ;


        }
        for(int i = 0 ; i < numthreads ; i++)
            t[i].join() ;

        cout<<sum ;



    }

我不断收到浮点异常。我尝试过数据类型 Auto、size_t、double、float。目标是显示线程循环。简单的程序将 0 加到 12 并在内核之间分配工作。

【问题讨论】:

  • 您从哪里得到异常?使用调试符号编译并在调试器中运行。
  • 显示的代码甚至没有浮点运算,无法判断到底发生了什么问题。
  • 表达式se += i 不会像你期望的那样。
  • @VoidStar 这条线呢(end - start + (numthreads - 1))/numthreads
  • @crush 没有浮点运算,都是整数运算。

标签: c++ multithreading


【解决方案1】:

尝试改变:

size_t chunk = (end - start + (numthreads - 1))/numthreads ;

t0:

size_t chunk = (numthreads>0 ? (end - start + (numthreads - 1))/numthreads) : end - start)

【讨论】:

  • 为什么?这完成了什么,它将如何使 OP 受益?通常一个好主意是告诉 OP 出了什么问题以及如何修复它,而不是仅仅将代码作为答案。
  • en.cppreference.com/w/cpp/thread/thread/hardware_concurrency num_threads 可以为0!在这种情况下,我怀疑您想要做的事情是默认为 1 个线程。
  • 评论不是扩展您的答案的地方。请编辑您的帖子并在其中包含其他信息。
猜你喜欢
  • 2014-11-12
  • 2014-12-18
  • 1970-01-01
  • 2011-06-12
  • 2011-06-17
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 2020-08-13
相关资源
最近更新 更多