|
version 1.9, 2001/12/17 14:17:08
|
version 1.10, 2001/12/17 14:33:01
|
|
|
|
| continue; | continue; |
| | |
| // wait for work | // wait for work |
| // queue->_workSemaphore.wait(); |
queue->_workSemaphore.wait(); |
| | |
| // stop the thread when the message queue has been destroyed. | // stop the thread when the message queue has been destroyed. |
| // ATTN: should check the thread cancel flag that is not yet exposed! | // ATTN: should check the thread cancel flag that is not yet exposed! |
|
|
|
| { | { |
| queue->handleEnqueue(); | queue->handleEnqueue(); |
| } | } |
| else |
|
| { |
|
| thread->sleep(0); |
|
| } |
|
| | |
| } | } |
| | |
Return to
MessageQueue.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common