Как правильно поместить объект в поток Опции Подписка на тему Сообщить другу Версия для печати Скачать тему Подписка на этот форум Режимы отображения Переключить на: Древовидный Стандартный Переключить на: Линейный

[mezmay]

В несложных ситуациях помещал объект в поток так:

class CWork //класс рабочего объекта
...

class CMyThread : public QThread
...

void CMyThread::run()
{
    CWork work;

    connect(m_pGUIThread, SIGNAL(someSignal()),
        &work, SLOT(someSlot()));
    ...
    // и т.д. и т.п.

   exec();
}

Если кому-то интересно в чем суть проекта, то она здесь: http://www.forum.crossplatform.ru/index.php?showtopic=9000

Здесь же задам более конкретный вопрос: допустим я создал два объекта типа CMyThread:

CMyThread thread_A;
thread_A.start();
CMyThread thread_B;
thread_B.start();

В каждом из них создались соответственно объекты work и начали жить в run()'е.
Один из этих объектов получил данные, скажем QByteArray, который надо передать во второй объект. Как по-нормальному их передать? Или стоит как-то по-другому организовывать работу объектов в потоках?

P.S. можно ли думать о передаче QByteArray через сигналы/слоты по значению, или пойти купить рыбу и у**ать себя по лицу?)

Сообщение отредактировал mezmay - 30.11.2012, 20:33

[ssoft]

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

class CWork //класс рабочего объекта
...

class CMyThread : public QThread
{
    typedef QSharedPointer< CWork > WorkPointer;
    WorkPointer work;

public:
    CWork * workObject () const;

signals:
   void workCreated ();

};

void CMyThread::run()
{
    work = WorkPointer( new CWork() );

    emit workCreated();

    exec();
}


// применение
int main ( int argc, char ** argv )
{
    QApplication app( argc, argv );

    CMyThread thread1;
    QEventLoop loop1;
    connect( &thread1, SIGNAL( workCreated() )
        , &loop1, SLOT( quit() ) );
    tread1.start();
    // ожидаем сигнала от tread1
    loop1.exec();

    CMyThread thread2;
    QEventLoop loop2;
    connect( &thread2, SIGNAL( workCreated() )
        , &loop2, SLOT( quit() ) );
    tread2.start();
    // ожидаем сигнала от tread2
    loop2.exec();

    // соединяем на здоровье
    connect ( tread1.workObject(), SIGNAL( ... )
        , tread2.workObject(), SLOT( ... ) ) );

    return app.exec();
}

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

Сообщение отредактировал ssoft - 30.11.2012, 8:43