Потоконезависимые очереди, реализация Опции

[AD]

На соседнем форуме обсуждали. Одна из тем: http://www.prog.org.ru/index.php?topic=144...g95463#msg95463

Спасибо еще раз. Есть еще один небольшой вопрос - дополнение к тому, что я увидел на prog.org по указанной ссылке. Надо ли взводить семафор (semaphore.acquire()), если я хочу проверить очередь на пустоту (вед в основе список QList) или узнать размер очереди?

[BRE]

Не нужны там семафоры (для другого они заточены), ну да ладно.
И в первом и во втором случае нужно блокировать доступ к QList.

Сообщение отредактировал BRE - 9.11.2011, 17:46

[AD]

Не нужны там семафоры (для другого они заточены), ну да ладно.

Не ладно. Буду благодарен, если раскроешь суть. И еще вопросик. Как на русский переводится термин "wait condition" (дословно-то я знаю, состояние ожидания)?

[BRE]

Чаще всего встречал перевод "условные переменные".

[AD]

Ага. Ну тут еще вопросы.
Смысл программы следующий: в главном потоке мы заполняем очередь запросов, в дополнительном - происходят вычисления и результаты попадают в очередь результатов. Исходя из приведенного на прог.орг примера сделал функции проверки на пустоту и размер следующими:

/// Пpoвepka на пустую очередь
bool ReqQueue::isEmpty()
{
    QMutexLocker locker(&_mtx);
    while(_req_list.isEmpty())
        _cond.wait(&_mtx, 300);

    return _req_list.isEmpty();
}

/// Pазмер очередu
int ReqQueue::size()
{
    QMutexLocker locker(&_mtx);
    while(_req_list.isEmpty())
        _cond.wait(&_mtx, 300);

    return _req_list.size();
}

Но это как-то не так. При проверке на пустоту цикл while не заканчивается. Как это поправить корректно? На сколько я понял из обсуждения на то форуме, цикл нужен, но тогда какой?

[BRE]

Не нужно ждать условную переменную. Она нужна в рабочих потоках, что бы усыпить поток на время когда нет работы.

bool ReqQueue::isEmpty()
{
    QMutexLocker locker(&_mtx);
    return _req_list.isEmpty();
}

/// Pазмер очередu
int ReqQueue::size()
{
    QMutexLocker locker(&_mtx);
    return _req_list.size();
}

[AD]

Из главного потока запустил дополнительный. В дополнительном у меня вечный цикл (forever) - памяти жрет 50%. Есть возможность, не отменяя цикла forever сделать так, чтобы память не жралась безмерно?

С потоками уже не раз работал, но еще ни разу не использовал forever в доп. потоке, потому такие вопросы и встают.

Пока что делаю так (память жрет):

/// Запуск потока вычисления
void CalcThread::run()
{
    forever
    {
        wait(_sec * TO_MILLISEC);
        if(QueueRequests.isEmpty())
            continue;

        Request request(QueueRequests.takeRequest());
        int error_code;
        double result = doOperation(request.type_work, request.first_operand, request.second_operand, error_code);
    }
}

[BRE]

"Память жрет" это ты про "процессор жрет"?
Что такое функция wait, как она определена?
А лучше ты все покажи.

[AD]

"Память жрет" это ты про "процессор жрет"?
Что такое функция wait, как она определена?
А лучше ты все покажи.

Да, проц жрет. wait - функция QThread. Так у меня это одна функция в Qthread.

[Iron Bug]

дык, в безусловном цикле крутится - потому и жрёт. любой поллинг жрёт проц.
тебе же про условные переменные говорили - вот и примени их, чтобы было условие, что в очереди что-то появилось, а в рабочем потоке - ожидание этого условия.