connect и типы Опции

[gpepsi]

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

Поставил Qt::DirectConnection. Сигнал стал приходить.
Но читая про него обнаружил еще и Qt::BlockingQueuedConnection, про который было написано, что он предназначен для
работы из различных потоков и так же блокирует очередь. Но есть коментарий, что этот сигнал может привести
к deadlock-у.

В чем тогда различае между ними, если оба блокируют, но только второй может зависнуть.

[Litkevich Yuriy]

при работе между потоками нужно использовать Авто (AutoConnection) или Через Очередь (QueuedConnection)

[gpepsi]

при работе между потоками нужно использовать Авто (AutoConnection) или Через Очередь (QueuedConnection)

использовал - не приходят

[gpepsi]

[quote name='gpepsi' date='1.10.2011, 23:58' post='53407']
[quote name='Litkevich Yuriy' post='53406' date='1.10.2011, 23:55']при работе между потоками нужно использовать Авто (AutoConnection) или Через Очередь (QueuedConnection)

ну может я что-то не так понял.

Пример 1 - хрена лысово:

#include <QCoreApplication>
#include <QThread>
#include <QDebug>

class Sender : public QThread {
    Q_OBJECT

private:
    virtual void run (void)
    {
        while(true)
        {
            emit send();
            QThread::msleep(1000);
        }
    }

signals:
    void send(void);
};

class Receiver : public QObject{
    Q_OBJECT

        public slots:
            void receive(void)
            {
                qDebug() << "OK";
            }
};

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

    Sender sender;
    Receiver receiver;
    QObject::connect(&sender, SIGNAL(send()), &receiver, SLOT(receive()), Qt::QueuedConnection);

    sender.start();
    sender.wait();

    return 0;
}

Пример 2 - работает:

#include <QCoreApplication>
#include <QThread>
#include <QDebug>

class Sender : public QThread {
    Q_OBJECT

private:
    virtual void run (void)
    {
        while(true)
        {
            emit send();
            QThread::msleep(1000);
        }
    }

signals:
    void send(void);
};

class Receiver : public QObject{
    Q_OBJECT

        public slots:
            void receive(void)
            {
                qDebug() << "OK";
            }
};

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

    Sender sender;
    Receiver receiver;
    QObject::connect(&sender, SIGNAL(send()), &receiver, SLOT(receive()), Qt::DirectConnection);

    sender.start();
    sender.wait();

    return 0;
}

Пример 3 - хрена лысово:

#include <QCoreApplication>
#include <QThread>
#include <QDebug>

class Sender : public QThread {
    Q_OBJECT

private:
    virtual void run (void)
    {
        while(true)
        {
            emit send();
            QThread::msleep(1000);
        }
    }

signals:
    void send(void);
};

class Receiver : public QObject{
    Q_OBJECT

        public slots:
            void receive(void)
            {
                qDebug() << "OK";
            }
};

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

    Sender sender;
    Receiver receiver;
    QObject::connect(&sender, SIGNAL(send()), &receiver, SLOT(receive()), Qt::BlockingQueuedConnection);

    sender.start();
    sender.wait();

    return 0;
}

Или я что-то не понял ?

[MoPDoBoPoT]

Хм, как интересно)
Наверное, дело в том, что для обработки сигналов испускаемых из другого потока (из метода run()) необходим цикл обработки событий (QThread::exec ()). А с соединением Qt::DirectConnection работает, потому что сигнал испускается самим потоком, а он создан в контексте главного потока.

[gpepsi]

А с соединением Qt::DirectConnection работает, потому что сигнал испускается самим потоком, а он создан в контексте главного потока.

создается сам объект, а run работает в другом потоке

[Гость_lanz_*]

MoPDoBoPoT все правильно говорит.

QObject::connect(&sender, SIGNAL(send()), &receiver, SLOT(receive()), Qt::QueuedConnection);

    sender.start();
    sender.wait();

[Гость_lanz_*]

Прошу прощения, криво отправилось.

MoPDoBoPoT все правильно говорит. Правильный код:

QObject::connect(&sender, SIGNAL(send()), &receiver, SLOT(receive()), Qt::QueuedConnection);

sender.start();
app.exec ();
sender.wait();

run работает в другом потоке, но объект источник сигнала создан в том же, поэтому DirectConnect работает. Принадлежность к треду свойство объекта, а не фрагмента кода. Не уверен что такое использование правильное, я бы делал:

class Sender : public Qbject {
    Q_OBJECT

public:
    void run (void)
    {
         while (true) {
            emit send ();
            QTest::qSleep (1000);
         }
    }

signals:
    void send(void);
};

class SenderThread : public QThread {
    Q_OBJECT
private:
    virtual void run (void)
    {
        Sender my_sender; // Объект создан в новом треде
        connect (...) // Коннектим сигнал сендера к объекту в главном потоке
                          // указатель на приемник можно получить по разному
        my_sender.run ();
    }
};

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

    Receiver receiver;
    SenderThread sender_thread;


    sender_thread.start();
    app.exec ();

    return 0;
}

Правильно запускать в методе run цикл обработки событий.