1

我正在尝试利用 boost::thread 来执行“n”个类似的工作。当然，“n”一般来说可能非常高，所以我想将同时运行的线程数限制为某个小数 m（比如 8）。我写了类似下面的内容，在其中打开 11 个文本文件，一次使用四个线程打开四个。

我有一个小类parallel（它在调用run()方法时会打开一个输出文件并向其写入一行，其中包含一个 int 变量。编译进行顺利，程序运行没有任何警告。但是结果与预期不符。文件被创建了，但它们的数量并不总是 11。有谁知道我犯了什么错误？

这是parallel.hpp：

 #include <fstream>
 #include <iostream>

 #include <boost/thread.hpp>

 class parallel{
 public:
    int m_start;

    parallel()
    {  }

    // member function
    void run(int start=2);
};

parallel.cpp 实现文件是

#include "parallel.hpp"

void parallel::run(int start){

    m_start = start;

    std::cout << "I am " << m_start << "! Thread # " 
          << boost::this_thread::get_id()
          << " work started!" << std::endl;

    std::string fname("test-");
    std::ostringstream buffer;
    buffer << m_start << ".txt";

    fname.append(buffer.str());

    std::fstream output;
    output.open(fname.c_str(), std::ios::out);

    output << "Hi, I am " << m_start << std::endl;

    output.close();

    std::cout << "Thread # " 
          << boost::this_thread::get_id()
          << " work finished!" << std::endl;
}

和 main.cpp：

 #include <iostream>
 #include <fstream>
 #include <string>

 #include <boost/thread.hpp>
 #include <boost/shared_ptr.hpp>

 #include "parallel.hpp"

 int main(int argc, char* argv[]){

     std::cout << "main: startup!" << std::endl;
     std::cout << boost::thread::hardware_concurrency() << std::endl;

     parallel p;

     int populationSize(11), concurrency(3);

     // define concurrent thread group
     std::vector<boost::shared_ptr<boost::thread> > threads;

     // population one-by-one
     while(populationSize >= 0) {
         // concurrent threads
         for(int i = 0; i < concurrency; i++){
             // create a thread
             boost::shared_ptr<boost::thread>
             thread(new boost::thread(&parallel::run, &p, populationSize--));
             threads.push_back(thread);
         }    
         // run the threads
         for(int i =0; i < concurrency; i++)
             threads[i]->join();

         threads.clear();
     }

     return 0;
 }
4

1 回答 1

0

您有一个parallel带有单个m_start成员变量的对象，所有线程都可以在没有任何同步的情况下访问它。

更新

这种竞争条件似乎是设计问题的结果。尚不清楚类型对象parallel要代表什么。

  • 如果它是用来表示一个线程，那么应该为每个创建的线程分配一个对象。发布的程序有一个对象和许多线程。
  • 如果它旨在表示一组线程，那么它不应该保留属于单个线程的数据。
于 2012-04-21T19:30:00.457 回答