线程安全的小问题

singerinsky

如果function1 和 function2 是两个线程的操作函数。小弟想请教下要怎么同步比较的好。给伪代码就可以了。

std::map<int,session*> g_map;//全局 function1(int id, session* pSession) {   g_map[id] = pSession; } function2() {    std::map<int, session*>::iterator itr = g_map.begin(); while(itr != g_map.end()) {   itr->second->process(); itr++; } } }

[ 本帖最后由 singerinsky 于 2009-9-15 10:51 编辑 ]

hellioncu

进入函数加锁，退出前解锁

singerinsky

仁兄你说的可是？
std::map<int,session*> g_map;//全局


function1(int id, session* pSession)
{
lock();
  g_map[id] = pSession;
unlock();

}

function2()
{
lock();
   std::map<int, session*>::iterator itr = g_map.begin();

while(itr != g_map.end())
{
  itr->second->process();
itr++;
}
unlock();
}




}

hellioncu

原帖由 singerinsky 于 2009-9-15 11:00 发表
仁兄你说的可是？
std::map g_map;//全局


function1(int id, session* pSession)
{
lock();
  g_map = pSession;
unlock();

}

function2()
{
lock();
   std::map::iterator itr = g_map.be ...

是呀，按照你的函数只能这样了。不过实际应该还有一个从map中删除的地方吧

pagx

std::map<int,session*> g_map;//全局


function1(int id, session* pSession)
{
lock();
  g_map[id] = pSession;
unlock();

}

function2()
{
lock();
   std::map<int, session*>::iterator itr = g_map.begin();

while(itr != g_map.end())
{
session *s =  itr->second;
unlock();
s->process();
lock();
itr++;
}
unlock();
}
这样应该也可以, 不过要求process不能再操作 g_map。





}

singerinsky

这样的话，会不会在s->process();的时候，有新的节点插入的时候导致map的结构变化，使迭代器变的未知啊。

pagx

map 迭代器应该是居于节点的，所以应该不至于变无效(不确定，我也没有试过)。不过新插入节点有可能被process也有可能不被process。