2012-05-27 137 views
2

我正在尝试使用地图系统来存储和更新聊天服务器的数据。该应用程序是多线程的并使用锁定系统来防止多线程访问数据。C++映射迭代和堆栈损坏

问题是这样的:当一个客户端被单独从地图中删除时,就没关系。但是,当我尝试调用多个关闭时,它会在内存中留下一些内容。如果我在地图上的任何一个地方调用:: clear(),它会导致一个调试断言错误,或者“迭代器不兼容”或类似。代码将第一次运行(使用80+控制台作为测试连接进行测试),但由于它将块放在后面,将不再工作。我已经尝试过研究方法,并且我已经编写了系统来停止代码执行,直到每个进程完成。我非常感谢迄今为止所提供的帮助,并附上了相关的代码片段。

//portion of server code that handles shutting down 
DWORD WINAPI runserver(void *params) { 
    runserverPARAMS *p = (runserverPARAMS*)params; 
    /*Server stuff*/        

    serverquit = 0; 
    //client based cleanup 
    vector<int> tokill; 
    map<int,int>::iterator it = clientsockets.begin(); 

    while(it != clientsockets.end()) {  
     tokill.push_back(it->first); 
     ++it; 
    } 
    for(;;) { 
     for each (int x in tokill) { 
      clientquit[x] = 1; 
      while(clientoffline[x] != 1) { 
       //haulting execution until thread has terminated 
      } 
      destoryclient(x); 
     } 
    } 
    //client thread based cleanup complete. 
    return 0; 
} 


//clientioprelim 
DWORD WINAPI clientioprelim(void* params) { 
    CLIENTthreadparams *inparams = (CLIENTthreadparams *)params; 
    /*Socket stuff*/ 
    for(;;) {  
     /**/ 
     } 
     else { 
      if(clientquit[inparams->clientid] == 1) 
       break; 
     } 
    } 
    clientoffline[inparams->clientid] = 1; 
    return 0; 
} 

int LOCKED; //exported as extern via libraries.h so it's visible to other source files 

void destoryclient(int clientid) { 
    for(;;) { 
     if(LOCKED == 0) { 
      LOCKED = 1;   
      shutdown(clientsockets[clientid], 2); 
      closesocket(clientsockets[clientid]); 
      if((clientsockets.count(clientid) != 0) && (clientsockets.find(clientid) != clientsockets.end())) 
       clientsockets.erase(clientsockets.find(clientid));     
      if((clientname.count(clientid) != 0) && (clientname.find(clientid) != clientname.end())) 
       clientname.erase(clientname.find(clientid)); 
      if((clientusername.count(clientid) != 0) && (clientusername.find(clientid) != clientusername.end())) 
       clientusername.erase(clientusername.find(clientid)); 
      if((clientaddr.count(clientid) != 0) && (clientaddr.find(clientid) != clientaddr.end())) 
       clientaddr.erase(clientusername.find(clientid)); 
      if((clientcontacts.count(clientid) != 0) && (clientcontacts.find(clientid) != clientcontacts.end())) 
       clientcontacts.erase(clientcontacts.find(clientid)); 
      if((clientquit.count(clientid) != 0) && (clientquit.find(clientid) != clientquit.end())) 
       clientquit.erase(clientquit.find(clientid));  
      if((clientthreads.count(clientid) != 0) && (clientthreads.find(clientid) != clientthreads.end())) 
       clientthreads.erase(clientthreads.find(clientid)); 
      LOCKED = 0; 
      break;   
     } 
    } 
    return; 
} 
+0

这是什么语言有'每个'? –

+0

我的'Visual C++'用''为每个'做了'... – IAbstract

+1

Visual C++对每个'扩展名都有一个非标准的':http://msdn.microsoft.com/en-us/library/xey702bw%28VS。 80%29.aspx –

回答

0

您确实在使用int进行锁定,还是仅仅是简化了代码?如果您确实使用了int:如果两个线程在分配变量(简化)之前检查该变量,则这将不起作用,并且临界区可以同时输入两次(或更多)。请参阅mutexes in Wikipedia以供参考。你可以使用Windows提供的某种互斥锁,或者使用boost thread而不是int

+0

我实际上使用了一个int。我将更多地研究mutux对象(我发现了一些有关它的MSDN技巧)。 –

+0

是的,“每个”通过我。我总是习惯于“foreach”。 –

+0

工作!谢谢!我正在使用MUTEX函数和WaitForSingleObject,而不是用于客户端线程终止的另一个映射。奇迹般有效!非常感谢你! –