使用 boost 库编写多线程程序时出错

Question

我创建了两个线程，它们将并行执行一段代码。我想在两个线程完成执行后运行另一个方法。我尝试过 join() 和 timed_join()，但它不起作用。我我正在使用 boost 线程类。请在下面找到我的代码：

代码：

A class:
A a;
boost::thread t(boost::bind(&A::method1,&a,s1,e1));//Call method1 using two parameters     s1 and e1.boost bind is used to call class methods
boost::thread t1(boost::bind(&A::method1,&a,s2,e2));//Call method1 using two parameters   s2 and e2.boost bind is used to call class methods.
t.join();
t1.join();
methodToBeExecutedAfterThreadExec();

让我知道如何使用线程并行执行方法 1，然后我必须调用 methodToBeExecutedAfterThreadExec() 方法。

提前致谢。

编辑 1：

void method1(int start,int end)
{
    vector< vector<string> >::iterator row;
vector<string>::iterator col;
db.onAutoVacuumMode();//Vacuum mode is set to true which eliminates fragmentation
db.startTransaction();//Starts the transaction which does the stuff in a batch wise
for (row = dupViewResults.begin()+start; row != dupViewResults.begin()+end; ++row) {

    std::string filedata=readFileDataInStr(row->at(0));
    int x = boost::lexical_cast<int>( row->at(1) );
    long long int fileCRC32=MurmurHash(filedata.c_str(),x,0);
    std::string strCRC32=std::to_string(fileCRC32);
    std::string query="update duplicatesview set CRC32='"+strCRC32+"' where Filepath='"+row->at(0)+"'";
    char* charQuery = &query[0];
    db.fireSQLQuery(charQuery,results); 
 }
 db.endTransaction();
}

上面的代码将读取向量 dupViewResults（我的代码已经填充了它）然后更新视图，然后在事务中触发 sql 查询。谢谢

Answer 1

根据您的 cmets，听起来您的 db 成员不是线程安全的。比如你在它上面调用endTransaction，它无法知道结束哪个事务。

您有三个选择，根据您未提供的详细信息，其中一些可能不起作用：

1. 每个线程都可以有自己的数据库对象。

2. 数据库对象可以返回后续函数采用的“事务”对象。每个线程都可以分配自己的事务对象。

3. 数据库对象可以将操作与调用它的线程相关联，因为知道endTransaction 会结束由同一线程启动的事务。

如果要同时从多个线程调用数据库，则数据库必须是线程安全的。