Таймер в потоке

[deMax]

Нужен класс, который по таймеру из другого потока отправляет данные
Интерфейс :

Код:

QPointer<Checker> checker;
connect(checker, &Checker::newData, this, &MyClass::process, Qt::BlockingQueuedConnection); // process(QMap<QString, int>), QueuedConnection - не соединяется

Накидал реализацию:
.h

Код:

class Checker: public QObject
{
    Q_OBJECT
    QThread m_thread;
    QTimer m_timer;

signals:
    void stop();

private slots:
    void started();
    void stoped();
    void timeout();

public:
    Checker();
    ~Checker();
    Q_SIGNAL void newData(QMap<QString, int>);
};

.cpp

Код:

void Checker::started()
{
    m_timer.start(1000);
}

void Checker::stoped()
{
    m_timer.stop();
}

void Checker::timeout()
{
    emit newData({});
}

Checker::Checker()
{
    this->moveToThread(&m_thread);

    m_timer.moveToThread(&m_thread);
    m_thread.start();

    connect(&m_thread, &QThread::started, this, &Checker::started);
    connect(this, &Checker::stop, this, &Checker::stoped);
    connect(&m_timer, &QTimer::timeout, this, &Checker::timeout);
}

Checker::~Checker()
{
    emit stop();
    m_thread.quit();
    m_thread.wait();
}

Вроде работает, но валидно ли? И почему QueuedConnection не соединяет? Или через потоки только POD данные пробрасывать можно?

[Авварон]

Очень криво. НЕ НАДО обертку над тредом прокидывать в тред.

[deMax]

Ок. А как правильно? только QTimer в другой поток выносить? И слот timeevent должен в потоке выполняться.
Еще проблема, не могу в проекте передать QMap<QString, MyStruct> с опцией QueuedConnection. Пишет: QObject::connect: Cannot queue arguments of type 'QMap<QString, MyStruct>'
Делал qRegistredMetaType, Q_DECLARE_METATYPE, все таже ошибка. Или отправлять пустой сигнал?

[Авварон]

Ок. А как правильно? только QTimer в другой поток выносить? И слот timeevent должен в потоке выполняться.
Еще проблема, не могу в проекте передать QMap<QString, MyStruct> с опцией QueuedConnection. Пишет: QObject::connect: Cannot queue arguments of type 'QMap<QString, MyStruct>'
Делал qRegistredMetaType, Q_DECLARE_METATYPE, все таже ошибка. Или отправлять пустой сигнал?

Да, только таймер.

Тред1: Checker checker; QThread m_thread;
Тред2: QTimer m_timer.

Зачем timeout в потоке? Я бы предложил тогда сделать класс Worker и перегрузить у него timerEvent() вместо QTimer. Ну или добавить 4й объект, который будет делать работу по таймеру, но это больше boilerplate кода.

Чтобы передавалась мапа, надо зарегать тип, да; с этим может быть гемор, гугли. Возможно, MyStruct тоже надо зарегать. Ведь создается копия, значит Qt должна понимать, как скопировать тип.
Можно попробовать в QVariant завернуть, как воркэраунд.

[deMax]

Зачем timeout в потоке? Я бы предложил тогда сделать класс Worker и перегрузить у него timerEvent() вместо QTimer. Ну или добавить 4й объект, который будет делать работу по таймеру, но это больше boilerplate кода.

В Timeout у меня "тяжелый" код, тот который должен считаться в отдельном потоке. (Ну т.е. он легкий, но в гуйне ему делать нечего)

В принципе меня и вариант QtConcurrent::run устоил бы с while(!qApp->closingDown()) { ...hard...; sleep(10) }. Только программа при закрытие ждет 10 секундный интервал, чтоб поток завершить...

[qate]

В Timeout у меня "тяжелый" код, тот который должен считаться в отдельном потоке.

а почему просто не выкинуть рассчитанные данные их класса другого потока в класс gui без таймера ?

[deMax]

а почему просто не выкинуть рассчитанные данные их класса другого потока в класс gui без таймера ?

У меня мониторинг постоянный, таймер нужен, но его можно и в гуйне запустить.

хорошо, есть некая функция

Код:

std::function<QList<Data>> someFunc = [](){return QStrorageInfo()....;};

и класс

Код:

class MyGuiClass: public QObject { public slot: void someMethod(QList<Data>); } 

Нужно в потоке запустить someFuncton чтобы каждые N секунд гуйня получала список файлов. мониторинг задача фоновая, как правило на отлов ошибок и не очень важная и не должна отвлекать гуйню.

Задача пустяковая и решить её можно множеством способов, как не отстрелить себе ногу, а наиболее грамотно это сделать? Ну и чтоб ошибок потенциальных, возможных крешей и падений не было.

[Old]

Самое простое это прямо в GUI-потоке запустить таймер, из обработчика которого запускать нужную функцию через QtConcurrent::run и отслеживать ее завершение с помощью QFutureWatcher. А после завершение обновлять результат.

[Авварон]

+1 за конкурент

[deMax]

А создание/удаление потока? не будет ли проще поток постоянно держать открытым? Все таки не на go пишем, создание потока процедура не самая быстрая(конечно побыстрее чем лазить на диск, но все же). Или я не прав?

[sergek]

А создание/удаление потока? не будет ли проще поток постоянно держать открытым?

Runs function in a separate thread. The thread is taken from the global QThreadPool.

[Igors]

а почему просто не выкинуть рассчитанные данные их класса другого потока в класс gui без таймера ?

У меня мониторинг постоянный, таймер нужен, но его можно и в гуйне запустить.

хорошо, есть некая функция

Код:

std::function<QList<Data>> someFunc = [](){return QStrorageInfo()....;};

и класс

Код:

class MyGuiClass: public QObject { public slot: void someMethod(QList<Data>); } 

Нужно в потоке запустить someFuncton чтобы каждые N секунд гуйня получала список файлов. мониторинг задача фоновая, как правило на отлов ошибок и не очень важная и не должна отвлекать гуйню.

Задача пустяковая и решить её можно множеством способов, как не отстрелить себе ногу, а наиболее грамотно это сделать? Ну и чтоб ошибок потенциальных, возможных крешей и падений не было.

А зачем эту мапу вообще передавать/копировать? Сделать ее членом того же Checker'а, только защитить напр мутексом

[Авварон]

А зачем эту мапу вообще передавать/копировать? Сделать ее членом того же Checker'а, только защитить напр мутексом

И локать мьютекс дважды. Умно!

[Igors]

И локать мьютекс дважды. Умно!

Да собсно тут и флажком можно обойтись, без мутекса. Псевдокод

Код

C++ (Qt)
void CheckerL::timerEvent( QTimerEvent * )
{
// если получатель сигнала newData еще не сбросил флажок
// то мапа может быть в использовании, пропускаем
// (хотя и маловероятно на интервале 1 сек)
  if  (m_writeFlag) return;
 
// взводим флажок, мапа пишется 
  m_writeFlag = true;
 
// строим мапу
 BuildMap(m_data);
 
// посылаем сигнал в UI
 emit newData(this);
}
 

Получив сигнал newData, UI использует мапу и после этого сбрасывает checker->m_writeFlag, т.е. события таймера могут заполнять ее снова

[sergek]

Да собсно тут и флажком можно обойтись, без мутекса.

Интересно, с какими типами переменных такие операции атомарны?