while(true){
apr_thread_mutex_lock(mySharedObject->getMutex());
while (mySharedObject->getMessagesReady() == 0 && !mySharedObject->getEndThread()) {
apr_thread_cond_wait(mySharedObject->getCond(), mySharedObject->getMutex());
}
if (mySharedObject->getEndThread()){
apr_thread_mutex_unlock(mySharedObject->getMutex());
break;
}
apr_thread_mutex_unlock(mySharedObject->getMutex());
if (mySharedObject->getMessagesReady()>0){
myActiveProducer->send();
}
}
Это способ, которым я это реализовал. Что-то не так ??