VPF::[Qt4]QThread, QMutex - Форум программистов

Acer

Дата 20.2.2009, 18:36 (ссылка)

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

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 652
Регистрация: 5.9.2007
Где: UA::DN

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

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

Код


this->mtx.lock(); /* QMutex mtx; */
RLog::writeSysLog( l );
this->mtx.unlock();

но это не работает :(
smile

SABROG

Дата 20.2.2009, 23:16 (ссылка)

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

Загрузка ...

Hacker

Профиль
Группа: Завсегдатай
Сообщений: 2481
Регистрация: 18.9.2006

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

Никогда не использовал, к сожалению. Используется в примере "Wait Conditions Example", может что-то там натолкнет на мысль. Возможно дело даже не в мутексе, а в системе буфферов. Может быть flush где-то не вовремя происходит... Ведь стримовая система заподлянская, ты можешь туда что-то записать, но не факт, что это появится в файле, пока буффер не переполнится.

--------------------

Национальная группа Russian Federation на QtCentre.

Acer

Дата 21.2.2009, 00:11 (ссылка)

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

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 652
Регистрация: 5.9.2007
Где: UA::DN

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

Хорошо. Спасибо, буду смотреть.

AndAnd

Дата 22.2.2009, 07:22 (ссылка)

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

Загрузка ...

Шустрый

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

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

Цитата(Acer @ 20.2.2009, 18:36)

Код


this->mtx.lock(); /* QMutex mtx; */
RLog::writeSysLog( l );
this->mtx.unlock();

тебе необходимо создать мьютекс видимый для всех потоков (или которые тебе нужны). И лучше использовать класс QReadWriteLock, он позволяет ожидать освобождения мьютекса без проверки. (т.е если мьютекс уже занят, то поток просто ожидает когда другой освободит мьютекс);

Код



//класс Global
QReadWriteLocker Mutex;


//поток1

QWriteLocker writeLock(&Global->Mutex);
RLog::writeSysLog( l );
writeLock.unlock();

//поток 2
QWriteLocker writeLock(&Global->Mutex);
RLog::writeSysLog( l );
writeLock.unlock();

Если нет необходимости явного захвата мьютекса, то можно использовать по возможности.
В следующем примере первый поток будет писать только тогда, когда попадёт на свободный мьютекс. А второй поток будет всегда захватывать (либо ожидать своей очереди) мьютекс.

Код



//поток1

if (Global->Mutex.tryLockForWrite ())
{
  RLog::writeSysLog( l );
  Global->Mutex.unlock();
}

//поток 2
QWriteLocker writeLock(&Global->Mutex);
RLog::writeSysLog( l );
writeLock.unlock();

Это сообщение отредактировал(а) AndAnd - 22.2.2009, 07:23

Acer

Дата 22.2.2009, 18:09 (ссылка)

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

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 652
Регистрация: 5.9.2007
Где: UA::DN

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

Точно! У меня же в каждом потоке свой mutex... smile

pethead

Дата 3.11.2010, 05:46 (ссылка)

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

Загрузка ...

Шустрый

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

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

а почему тогда в qt примерах и книжках переменная типа мутекс в потоке прописана а не глобально?

0 Пользователей читают эту тему (0 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| С/С++: Кроссплатформенное программирование, Qt/Gtk+/wxWidgets \| Следующая тема »