У меня есть многопоточное серверное приложение, которому нужны мьютексные блокировки некоторой разделяемой памяти.
Общая память - это в основном sTL-карты и т. Д.
Большую часть времени я просто читаю из карта. Но мне также нужно иногда добавлять к нему.
например typedef std :: map MessageMap; MessageMap msgmap; boost: доступ shared_mutex _;
void ProcessMessage(Message* message)
{
// Access message... read some stuff from it message->...
UUID id = message->GetSessionID();
// Need to obtain a lock here. (shared lock? multiple readers)
// How is that done?
boost::interprocess::scoped_lock(access_);
// Do some readonly stuff with msgmap
MessageMap::iterator it = msgmap.find();
//
// Do some stuff...
// Ok, after all that I decide that I need to add an entry to the map.
// how do I upgrade the shared lock that I currently have?
boost::interprocess::upgradable_lock
// And then later forcibly release the upgrade lock or upgrade and shared lock if I'm not looking
// at the map anymore.
// I like the idea of using scoped lock in case an exception is thrown, I am sure that
// all locks are released.
}
РЕДАКТИРОВАТЬ: Я могу сбить с толку разные типы блокировки.
В чем разница между общим / обновленным и эксклюзивным. т.е. я не понимаю объяснения. Похоже, если вы просто хотите позволить большому количеству читателей, общий доступ - это все, что вы хотите получить. А для записи в общую память вам просто нужен доступ для обновления. Или нужен эксклюзив? Объяснение в ускорении совсем не ясное.
Получен ли доступ к обновлению, потому что вы можете писать. Но общий означает, что вы определенно не будете писать, вот что это значит?
РЕДАКТИРОВАТЬ: Позвольте мне объяснить, что я хочу сделать, с большей ясностью. Я еще не доволен ответами.
Вот пример снова, но с примером кода, который я использую. Просто иллюстрация, а не код.
typedef boost::shared_mutex Mutex;
typedef boost::shared_lock<Mutex> ReadLock;
typedef boost::unique_lock<Mutex> WriteLock;
Mutex mutex;
typedef map<int, int> MapType; // Your map type may vary, just change the typedef
MapType mymap;
void threadoolthread() // There could be 10 of these.
{
// Add elements to map here
int k = 4; // assume we're searching for keys equal to 4
int v = 0; // assume we want the value 0 associated with the key of 4
ReadLock read(mutex); // Is this correct?
MapType::iterator lb = mymap.lower_bound(k);
if(lb != mymap.end() && !(mymap.key_comp()(k, lb->first)))
{
// key already exists
}
else
{
// Acquire an upgrade lock yes? How do I upgrade the shared lock that I already have?
// I think then sounds like I need to upgrade the upgrade lock to exclusive is that correct as well?
// Assuming I've got the exclusive lock, no other thread in the thread pool will be able to insert.
// the key does not exist in the map
// add it to the map
{
WriteLock write(mutex, boost::adopt_lock_t()); // Is this also correct?
mymap.insert(lb, MapType::value_type(k, v)); // Use lb as a hint to insert,
// so it can avoid another lookup
}
// I'm now free to do other things here yes? what kind of lock do I have here, if any? does the readlock still exist?
}