ostringstream 到 vector<String> 用于多线程队列

Question

所以我有一个应用程序，它是一个打开多个线程的服务器，这些线程将用于数据库查询。在我的接收函数中，我测试了我构建的查询的输出，当我计算出 ostringstream 时它看起来很好，所以我将它添加到向量中。然后我 cout 向量，它看起来也很好。这一切都是在互斥锁内完成的，所以我解锁了互斥锁。我的数据库线程处于一个 while 循环中，它检查我的 vector.size() 是否 > 0。

我遇到的问题是我的循环永远不会运行，因为它永远不会看到向量 > 0（应该是因为我能够计算 vector.begin() 并且它工作正常。有人可以看看在我拥有的代码中并告诉我是否有任何问题可能导致此问题。

#Header
class CNetworkService : public Service
{
   public:
CNetworkService(void);
~CNetworkService(void);
std::ostringstream query;
string  record;
std::vector<string> queue;
string IP;
unsigned int Port;
void DBWork();
bool SaveLog(string insert);
   protected:
virtual void handle(LogicalConnection* pClient, IncomingPacket* pRequest);
};

#Source File
//In my receive handler
    mtx.lock();
query << var1 << var2;

queue.push_back(query.str());
mtx.unlock();
query.clear();



//This is the function that the database threads are looping in
void CNetworkService::DBWork()
{


while(true)
{
mtx.lock();
while(queue.size() > 0)
{
    printf("Adding new record \n");
    SaveLog(queue.front());
    queue.erase(queue.begin());

}
mtx.unlock();
    }
    }

  //The code in the main thread which launches each thread. StartDBThread does some reporting stuff and then lauches the DBWork function, and I can see that DBWork is getting called. In the original attempt I was trying to launch 4 threads, but for now I have scaled it back to 1 thread in order to test and get a working solution.
  std::thread threads[1];
  // spawn 1 threads:
  for (int i=0; i<1; ++i)
  threads[i] = std::thread(StartDBThread, i+1);

  for (auto& th : threads) th.join();

Answer 1

我能想到的一个可能的问题是，在您的代码中的其他地方获取了互斥锁，而CNetworkService::DBWork() 从未获得过锁。

这可能不是问题的原因。但是您可以通过将 mtx 变量设置为 CNetworkService 的私​​有字段来防止它，因为它用于同步队列并且您不希望它在其他地方使用。

我建议您通过在 mtx.lock() 和 while(queue.size() > 0) 之间打印一些内容来进行测试，以查看是否曾经获得过锁。

附： vector::erase 很贵。