VPF::boost::thread, mutex и прочая каша, Поможите!)

iManiac

Дата 9.6.2009, 10:30 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 4
Регистрация: 19.9.2007

Репутация: нет
Всего: нет

Итак, есть класс очереди. В эту очередь добавляются события с разных потоков, в том числе и из того потока, в котором эта очередь потом обрабатывается.

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

Код:

Код


using namespace boost;

class SomeClass
{
 //--------------------
 конструктор, деструктор, инициализатор и прочая  фигня.
//--------------------

recursieve_mutex mutex;
condition sync;
bool QueueProcessing;
//Метод который добавляет ивент в очередь,  посмотрел значение лока - перед зависанием  recurse_count = 2
// Метод может выполняться из любого кол-ва  потоков Оо
void AddEvent(eventPtr ptr)
{
   recursive_mutex::scoped_lock lk(mutex);
   if(QueueProcessing)
     sync.wait(lk); //Вот тут мы и дохнем :( 
   //Ага, дождались - делаем то что надо и  сваливаем...
};

void ProcessQueue()
{
  recursive_mutex::scoped_lock lk(mutex);
  QueueProcessiung = true;
  while(RunNextEvent());

  QueueProcessing  = false;
  sync.notify_one();
};

};

Это сообщение отредактировал(а) iManiac - 9.6.2009, 10:32

xvr

Дата 9.6.2009, 12:36 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Комодератор
Сообщений: 7046
Регистрация: 28.8.2007
Где: Дублин, Ирландия

Репутация: 60
Всего: 223

Хм, у вас 'несколько' все наоборот - sync.wait должен стоять в ProcessQueue, а sync.notify_one в AddEvent
И сигнализировать он должен о том, что в очередь добавился элемент
Добавление и удаление элементов (но только САМО добавление и удаление, а не вся последующая обработка) должны быть защищены мьютексом

Это сообщение отредактировал(а) xvr - 9.6.2009, 12:36

iManiac

Дата 10.6.2009, 08:21 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 4
Регистрация: 19.9.2007

Репутация: нет
Всего: нет

Да нет, просто специфика задачи такая, ProcessQueue выполняется при рендере каждого кадра и ждать добавления события означает ожидания самого рендера, что неприемлимо... Потому так, а с безопасностью я разобрался, дело в том что внутри AddEvent был еще один вложенный AddEvent, и получалось что один поток ожидает самого себя...

xvr

Дата 10.6.2009, 09:57 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Комодератор
Сообщений: 7046
Регистрация: 28.8.2007
Где: Дублин, Ирландия

Репутация: 60
Всего: 223

Тогда вам condition вообще не нужен.

Заходим в ProcessQueue,
блокируем очередь (mutex'ом),
если очередь не пуста - взводим флаг, снимаем элемент с очереди.
Разблокируем очередь
Если флаг взведен - обрабатываем снятый элемент, повторяем все снова
Если флаг не взведен - выходим

1 Пользователей читают эту тему (1 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| C/C++: Общие вопросы \| Следующая тема »