Использование условной переменной в ситуации производитель-потребитель - PullRequest
Новая
       21

Использование условной переменной в ситуации производитель-потребитель

26 голосов
/ 04 марта 2010

Я пытаюсь узнать об условных переменных и о том, как их использовать в ситуации производитель-потребитель. У меня есть очередь, где один поток помещает числа в очередь, в то время как другой поток извлекает номера из очереди. Я хочу использовать переменную условия, чтобы сигнализировать потребляющему потоку, когда производящий поток помещает некоторые данные. Проблема в том, что бывают моменты (или большинство случаев), когда он помещает в очередь до двух элементов, а затем зависает. Я указал в функции product (), где он останавливается при работе в режиме отладки. Может кто-нибудь помочь мне указать, почему это происходит?

У меня есть следующие глобальные переменные: 


boost::mutex mutexQ;               // mutex protecting the queue
boost::mutex mutexCond;            // mutex for the condition variable
boost::condition_variable condQ;

Ниже моя потребительская тема: 


void consume()
{
    while( !bStop )   // globally declared, stops when ESC key is pressed
    {
        boost::unique_lock lock( mutexCond );
        while( !bDataReady )
        {
            condQ.wait( lock );
        }

        // Process data
        if( !messageQ.empty() )
        {
            boost::mutex::scoped_lock lock( mutexQ );

            string s = messageQ.front();   
            messageQ.pop();
        }
    }
}

Ниже моя ветка продюсера: 


void produce()
{
    int i = 0;

    while(( !bStop ) && ( i &lt MESSAGE ))    // MESSAGE currently set to 10
    {
        stringstream out;
        out &lt&lt i;
        string s = out.str();

        boost::mutex::scoped_lock lock( mutexQ );
        messageQ.push( s );

        i++;
        {
            boost::lock_guard lock( mutexCond );  // HANGS here
            bDataReady = true;
        }
        condQ.notify_one();
    }
}

1 Ответ

36 голосов
/ 04 марта 2010

Вы должны использовать тот же мьютекс для защиты очереди, который вы используете в условной переменной.

Это должно быть все, что вам нужно: 

void consume()
{
    while( !bStop )
    {
        boost::scoped_lock lock( mutexQ);
        // Process data
        while( messageQ.empty() ) // while - to guard agains spurious wakeups
        {
            condQ.wait( lock );

        }
        string s = messageQ.front();            
        messageQ.pop();
    }
}

void produce()
{
    int i = 0;

    while(( !bStop ) && ( i < MESSAGE ))
    {
        stringstream out;
        out << i;
        string s = out.str();

        boost::mutex::scoped_lock lock( mutexQ );
        messageQ.push( s );
        i++;
        condQ.notify_one();
    }
}
...