Re: thread safe
"sagenaut@yahoo.com" <sagenaut@gmail.com> schrieb im Newsbeitrag
news:1151088769.030803.190970@b68g2000cwa.googlegroups.com...
I have a monitor like class and a thread-safe queue:
class Monitor {
public:
void lock();
void unlock();
wait();
signal();
...
};
class MTQueue {
public:
void put();
void get();
...
private:
std::queue<item> queue_
Monitor getLock_;
Monitor putLock_;
Monitor emptyLock_;
Monitor serializeLock_;
...
};
Here is the get() and put() implementation:
void put()
{
putLock_.lock();
queue_.push(item);
emptyLock_.signal();
putLock_.unlock();
}
void get()
{
getLock_.lock();
while (queue_.empty()) emptyLock_.wait();
item = queue_.front();
queue_.pop();
getLock_.unlock();
}
Are the put() and get() thread safe? I used two locks for
serialization and one lock for signaling. This allows two threads
access to the queue: one for put and the other for get.
Since there are no threads or locks in standard C++ (at least not yet) you
should better ask in a group for your system. So without knowing what
exactly your Monitor class really does, the following comments may be of
little value.
No. I don't think your code is thread safe. You should better use a single
lock for reading and writing. Inserting a new item to a container might use
iterators or pointers and while these are used, they must not become
invalid. OTH, removing an item from a container may invalidate all
iterators/pointers to elements in that container might comflict with
simultanous insertion. It is the container you must protect, not a single
operation.
Also, you should unlock the container as early as possible. Therefor it
would be better if put would unlock the container before signaling. But even
more important, get must not keep the container locked while it is waiting
for something to be written to it. How can another thread write something
into the queue while it is locked?
Normal
aka "working"
implementation would use only one lock and allows only one thread to
access queue:
void put()
{
serializeLock_.lock();
queue_.push(item);
serializeLock_.signal();
serializeLock_.unlock();
}
void get()
{
serializeLock_.lock();
while (queue_.empty()) serializeLock_.wait();
item = queue_.front();
queue_.pop();
serializeLock_.unlock();
}
Which is the right way to implemt the put() and get()? Thanks in
advance.
IMHO none of above. Protecting data against concurrent manipulation and
sending messages from one thread to another are different tasks, so there
should be different types objects or at least different instances of them.
Some systems use mutexes to protect critical sections of code and events to
signal an important change of an object's state. And there may be even more
types of syncronisation objects. If your Monitor can do both it might be OK,
but in general it seems better to use different classes for different tasks.
HTH
Heinz
[ See http://www.gotw.ca/resources/clcm.htm for info about ]
[ comp.lang.c++.moderated. First time posters: Do this! ]