VPF::Многопоточность - Форум программистов

Artemon

Дата 16.12.2010, 19:07 (ссылка)

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

Загрузка ...

а ты мне нравишься

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

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

Есть несколько потоков, задача:

1. Когда какой-то поток выполняет метод Write, все остальные потоки стоят и ждут.
2. Если хотябы один поток выполняет метод Read, то метод Write не может быть выполнен, но при этом Read может выполняться несколькими потоками одновременно.

У меня сейчас получается, либо выполняем ТОЛЬКО Write, либо ТОЛЬКО Read.

Код


QMutex mutexWrite;

class MyThread : public QThread
{
 public:
     MyThread(int val){this->val = val;}
     void run();

 protected:
     void Read();
     void Write();

     int val;
};

 void MyThread::run()
 {
    while(1)
    {
        if(val)
            Read();
        else
            Write();
    }
 }

 void MyThread::Read()
 {
     mutexWrite.lock();
         
     printf("\nRead");
     this->sleep(1);
    
     mutexWrite.unlock(); 
 }

 void MyThread::Write()
 {
     mutexWrite.lock();
     
     printf("\nWrite");
     this->sleep(5);

     mutexWrite.unlock();
 }

int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);

    MyThread* t0 = new MyThread(0);
    MyThread* t1 = new MyThread(1);
    MyThread* t2 = new MyThread(1);    
    MyThread* t3 = new MyThread(1);    
    
    t0->start();
    t1->start();
    t2->start();    
    t3->start();    

    return a.exec();
}

Это сообщение отредактировал(а) Artemon - 16.12.2010, 19:11

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

Контроль топлива на топливозаправщиках, мониторинг автотранспорта, расчет зарплаты водителей www.rscat.ru

borisbn

Дата 17.12.2010, 07:42 (ссылка)

(голосов:1)

Загрузка ...

Эксперт

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

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

QReadWriteLock

Это сообщение отредактировал(а) borisbn - 17.12.2010, 07:46

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

Женщины отличаются от программистов тем, что у них чары состоят из стрингов

borisbn

Дата 17.12.2010, 17:05 (ссылка)

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

Загрузка ...

Эксперт

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

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

Коллега на работе написал сам (просто интересно было, что в этом QreadWriteLock делается). Вот, что получилось. Не тестили. Если не сложно (и не напряжно по времени) - протесть, плиз

Код


class ReadWriteLocker
{
public:
    void lockForRead() {
        m_readMutex.lock();
        m_readMutex.unlock();

        QMutexLocker l( &m_countMutex );
        if ( 0 == m_readersCount ) {
            m_writeMutex.lock();
        }
        ++m_readersCount;
    }

    void unlockForRead() {
        QMutexLocker l( &m_countMutex );
        --m_readersCount;
        if ( 0 == m_readersCount ) {
            m_writeMutex.unlock();
        }
    }

    void lockForWrite() {
        m_readMutex.lock();
        m_writeMutex.lock();

    }

    void unlockForWrite() {
        m_writeMutex.unlock();
        m_readMutex.unlock();
    }

private:
    QMutex m_readMutex;
    QMutex m_writeMutex;
    QMutex m_countMutex;
    int m_readersCount;
};

Это сообщение отредактировал(а) borisbn - 17.12.2010, 17:06

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

Женщины отличаются от программистов тем, что у них чары состоят из стрингов

azesmcar

Дата 17.12.2010, 17:29 (ссылка)

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

Загрузка ...

uploading...

Профиль
Группа: Участник Клуба
Сообщений: 6291
Регистрация: 12.11.2004
Где: Армения

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

также можно реализовать на boost::shared_mutex

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