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

[AD]

Не понимаю, почему нет паузы в выполнении. Делаю так:

connect(btnPauseVertical, SIGNAL(clicked()), this, SLOT(pauseVerticalCycles()));
/// Приостановка выполнения процесса перемещения в вертикальной проекции (или запуск с места остановки)
void AutoControl::pauseVerticalCycles()
{
    if(btnPauseVertical -> isChecked())
    {
        bool p = vertical -> wait();
        int u = 0;
    }
    /*else
        vertical -> start();*/
}

В чем недочеты? Почему не удается приостановить выполнение функции run()?

[BRE]

Не понимаю, почему нет паузы в выполнении. Делаю так:
В чем недочеты? Почему не удается приостановить выполнение функции run()?

Потому, что QThread::wait ждет момента завершения нити или наступления таймаута и выходит. Она нить не приостанавливает!

Сообщение отредактировал BRE - 4.6.2009, 17:35

[AD]

Тогда вопрос: как заставить его таймаутиться?

Даже точнее: приостанавливать выполнение run(), а потом запускать run() с места остановки?

Сообщение отредактировал AD - 4.6.2009, 17:39

[BRE]

Тогда вопрос: как заставить его таймаутиться?

Даже точнее: приостанавливать выполнение run(), а потом запускать run() с места остановки?

Циклы, флаги внутри run.
Посмотри на prog.org, там обсуждалась подобная тема: http://www.prog.org.ru/topic_8910_0.html

[AD]

Ну.... мне удалось сделать такую фишку!

Вот таким образом:

/// Класс потока - вращение вокруг горизонтальной оси заданное количество раз
class VerticalRotation: public QThread
{
    Q_OBJECT

private:
    int cur_num_cycle;                            ///< текущее номер цикла
    bool terminated;                            ///< флаг сигнализации о том, что функцию run надо прервать

private:
    void cycleRotate();

protected:
    virtual void run();

signals:
    void valueDecrement(int);
    void timeout(int);

private slots:
    void terminateCycle(int index);

public:
    void setNumberCycle(int index) { cur_num_cycle = index; }
    int currentNumber() const { return cur_num_cycle; }
    void setTerminate(bool bf) { terminated = bf; }
    bool isTeminated() const { return terminated; }
};

/// в конструкторе
connect(this, SIGNAL(timeout(int)), SLOT(terminateCycle(int)));

/// Прерывание цикла
void VerticalRotation::terminateCycle(int index)
{
    cur_num_cycle = index;
    terminated = true;
}

/// Выполнение цикла перемещений прожектора
void VerticalRotation::cycleRotate()
{
    int geted_angle_elev = VALFROMBYTES(inf_from_ed_packet.high_angle_elev, inf_from_ed_packet.low_angle_elev);
    readAngleElevation(geted_angle_elev, 10.);

    const int number_cycles = number_rotate;
    for(register int i=cur_num_cycle; i<number_cycles && !terminated; ++i)
    {
        int angle_elevation = -110 * 10;
        inf_to_ed_packet.low_angle_elev = LOWBYTE(angle_elevation);
        inf_to_ed_packet.high_angle_elev = HIGHBYTE(angle_elevation);
        if(imitTsl) imitTsl -> writeFromCtrlAutoPage();
        readAngleElevation(geted_angle_elev, -110.);

        angle_elevation = 10 * 10;
        inf_to_ed_packet.low_angle_elev = LOWBYTE(angle_elevation);
        inf_to_ed_packet.high_angle_elev = HIGHBYTE(angle_elevation);
        if(imitTsl) imitTsl -> writeFromCtrlAutoPage();
        readAngleElevation(geted_angle_elev, 10.);
        --number_rotate;
        emit valueDecrement(number_rotate);
        emit timeout(i);
    }
}

/// Запуск потока вращения в вертикальной плоскости
void VerticalRotation::run()
{
    if(!number_rotate) return;
    if(terminated) return;

    int geted_angle_elev = VALFROMBYTES(inf_from_ed_packet.high_angle_elev, inf_from_ed_packet.low_angle_elev);
    int angle_elevation = 10 * 10;                        ///< верхний предел прожектора
    if(geted_angle_elev < ((10. - 1.5) * 10) || geted_angle_elev > ((10. + 1.5) * 10))
    {
        inf_to_ed_packet.low_angle_elev = LOWBYTE(angle_elevation);
        inf_to_ed_packet.high_angle_elev = HIGHBYTE(angle_elevation);
        if(imitTsl) imitTsl -> writeFromCtrlAutoPage();
    }

    /// внешний цикл по количеству перемещений
    cycleRotate();

    if(!number_rotate) { terminated = false; quit(); }
}



connect(vertical, SIGNAL(timeout(int)), SLOT(pauseVerticalCycles()));
/// Приостановка выполнения процесса перемещения в вертикальной проекции (или запуск с места остановки)
void AutoControl::pauseVerticalCycles()
{
    if(btnPauseVertical -> isChecked()) vertical -> setTerminate(true);
    else { vertical -> setTerminate(false); vertical -> start(); }
}

[igor_bogomolov]

AD, мне всегда нравились твои краткие примеры

То что ты cделал противоречит тобою же поставленной задачей.

приостанавливать выполнение run(), а потом запускать run() с места остановки?

То, что ты делаешь, это называется завершение потока

if(terminated) return;

А в дальнейшем, ты создаешь его заново

vertical -> start();

т.е выполнение начнется с первой строки метода run.

В строке

if(!number_rotate) { terminated = false; quit(); }

quit убери, он тут ни к чему. Поток и так завершится.

Если ты реально хочешь приостановиь поток, а потом продолжить с места остановки, используй QMutex совместно с QWaitCondition. Да и в принципе мьютексами пользоваться не стесняйся

[AD]

Если ты реально хочешь приостановиь поток, а потом продолжить с места остановки, используй QMutex совместно с QWaitCondition. Да и в принципе мьютексами пользоваться не стесняйся

Если бы знал, как корректно ими воспользоваться - обязательно бы это сделал! Подскажешь, буду благодарен!

А вообще, да, я запускаю run с первой строчки, но:
1) у меня цикл начинается с места остановки;
2) условие, которое проверяется перед циклом, не выполняется, потому что прожектор и так, в крайнем верхнем положении!

P.S.
Подкорректировал код:

private slots:
void terminateCycle(int index) { terminated = true; }

/// Выполнение цикла перемещений прожектора
void VerticalRotation::cycleRotate()
{
    int geted_angle_elev = VALFROMBYTES(inf_from_ed_packet.high_angle_elev, inf_from_ed_packet.low_angle_elev);
    readAngleElevation(geted_angle_elev, 10.);

    const int number_cycles = number_rotate;
    for(register int i=0; i<number_cycles && !terminated; i++)
    {
        int angle_elevation = -110 * 10;
        inf_to_ed_packet.low_angle_elev = LOWBYTE(angle_elevation);
        inf_to_ed_packet.high_angle_elev = HIGHBYTE(angle_elevation);
        if(imitTsl) imitTsl -> writeFromCtrlAutoPage();
        readAngleElevation(geted_angle_elev, -110.);

        angle_elevation = 10 * 10;
        inf_to_ed_packet.low_angle_elev = LOWBYTE(angle_elevation);
        inf_to_ed_packet.high_angle_elev = HIGHBYTE(angle_elevation);
        if(imitTsl) imitTsl -> writeFromCtrlAutoPage();
        readAngleElevation(geted_angle_elev, 10.);
        --number_rotate;
        emit valueDecrement(number_rotate);
        if(checked_pause) emit timeout(i);
    }
}

/// Запуск потока вращения в вертикальной плоскости
void VerticalRotation::run()
{
    if(!number_rotate) return;
    if(terminated) return;

    int geted_angle_elev = VALFROMBYTES(inf_from_ed_packet.high_angle_elev, inf_from_ed_packet.low_angle_elev);
    int angle_elevation = 10 * 10;                        ///< верхний предел прожектора
    if(geted_angle_elev < ((10. - 1.5) * 10) || geted_angle_elev > ((10. + 1.5) * 10))
    {
        inf_to_ed_packet.low_angle_elev = LOWBYTE(angle_elevation);
        inf_to_ed_packet.high_angle_elev = HIGHBYTE(angle_elevation);
        if(imitTsl) imitTsl -> writeFromCtrlAutoPage();
    }

    /// внешний цикл по количеству перемещений
    cycleRotate();

    if(!number_rotate) { checked_pause = false; terminated = false; quit(); }
}


/// Приостановка выполнения процесса перемещения в вертикальной проекции (или запуск с места остановки)
void AutoControl::pauseVerticalCycles()
{
    if(btnPauseVertical -> isChecked())
    {
        vertical -> setChecked(true);
        vertical -> setTerminate(true);
        btnPauseVertical -> setFlat(true);
    }
    else
    {
        vertical -> setChecked(false);
        vertical -> setTerminate(false);
        vertical -> start();
        btnPauseVertical -> setFlat(false);
    }
}

Сообщение отредактировал AD - 5.6.2009, 10:03

[Litkevich Yuriy]

AD, сворачивай код, слишком длинный

[igor_bogomolov]

2) условие, которое проверяется перед циклом, не выполняется, потому что прожектор и так, в крайнем верхнем положении!

Ну тогда убери строку раз она не нужна. А то этот quit в конце потока, как то глаз немного режет. Не нужет он там. Да и вообще, использование quit внутри run, выглядит как то странно.

1) у меня цикл начинается с места остановки;

Это другой вопрос. Что у тебя там происходит реально, разобраться даже и не пытался. Если все переменные сохраняются, и при новом запуске потока, все выглядит так, как будто ты продолжил с точки остонава, то можешь оставить и так. Это тоже вариант. Но только это не универсальное решение. Будешь решать другую задачу, опять сталкнешся с трудностями. Так что с мьютексами все равно надо разбираться. Тем более, что поток у тебя не безопасный. ИМХО.

Если бы знал, как корректно ими воспользоваться - обязательно бы это сделал!

Попробую небольшой тестовый пример накатать.

[AD]

Ну тогда убери строку раз она не нужна. А то этот quit в конце потока, как то глаз немного режет. Не нужет он там. Да и вообще, использование quit внутри run, выглядит как то странно.

Вот то что не пытался разобраться - это плохо! Я даже прокомментировал все действия. что выполняются в этих функциях!
А убрать - не уберу, потому что это условие не выполняется, когда туда заходим после паузы, а при первом заходе, как правило, оно срабатывает. Так и должно быть! А вообще был очень удивлен, что я впринципе могу работать с одной структурой в двух разных потоках. Убедился, что это так - единственное, разные поля этой структуры обрабатываются разными потоками!

[igor_bogomolov]

Вот то что не пытался разобраться - это плохо! Я даже прокомментировал все действия. что выполняются в этих функциях!

Да какая мне разница куда у тебя там прожектор крутится, или что такое VALFROMBYTES. Я смотрю на структуру программы, и на поставленный тобою вопрос. Решение поставленной тобой задачи, на мой взглад не правильное. В каком направлении двигаться, тебе сказали. А делать такие заявления, как минимум не уважение. Разбирайся тогда сам, мне мое время тоже дорого.

А убрать - не уберу, потому что это условие не выполняется, когда туда заходим после паузы, а при первом заходе, как правило, оно срабатывает.

Да черт с ним с условием. quit там зачем поставил. Он вообще не нужен если нет цикла обработки событий. Ты хоть в асистент загляни.

Tells the thread's event loop to exit with return code 0 (success). Equivalent to calling QThread::exit(0).

This function does nothing if the thread does not have an event loop.

[AD]

Хорошо, quit() убрал.

А делать такие заявления, как минимум не уважение. Разбирайся тогда сам, мне мое время тоже дорого.

Прости, вот обижать я не хотел.
Просто некоторые вещи для анализа кода в целом можно и опустить, на мой взгляд. Если что, не сердись - неспециально! Прости!

Указанная функция из двух байт (параметры) собирает одно числа типа int!

[igor_bogomolov]

Вот простенький пример, как приостановить поток при помощи QMutex & QWaitCondition.

mythread.h

#ifndef DIALOG_H
#define DIALOG_H

#include <QThread>
#include <QMutex>
#include <QWaitCondition>

class myThread : public QThread
{
    Q_OBJECT

    bool pause;
    QMutex mutex;
    QWaitCondition cond;

public:
    myThread(QObject *parent = 0);
    ~myThread();

protected:
    void run();

private slots:
    void togglePaused();
};

#endif // DIALOG_H

mythread.cpp

#include "mythread.h"
#include <QtDebug>

myThread::myThread(QObject *parent)
    : QThread(parent), pause(false)
{

}

myThread::~myThread()
{
}

void myThread::togglePaused()
{
    if (pause) {
        cond.wakeOne();
        pause = false;
    } else {
        pause = true;
    }
}

void myThread::run()
{
    const int Timeout = 3 * 100;
    int count = 0;

    forever {
        while(pause) {
            mutex.lock();
            cond.wait(&mutex);
            mutex.unlock();
        }

        qDebug() << count++;
        msleep(Timeout);
    }
}

main.cpp

#include <QtGui>
#include "mythread.h"

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

    QDialog dlg;
    QPushButton *pb = new QPushButton("Pause", &dlg);
    QHBoxLayout *hbl = new QHBoxLayout(&dlg);
    hbl->addWidget(pb);
    dlg.setLayout(hbl);

    myThread *thread = new myThread(&dlg);
    QObject::connect(pb, SIGNAL(clicked()), thread, SLOT(togglePaused()));
    thread->start();

    dlg.show();
    return a.exec();
}

.pro

TARGET = pauseThread
TEMPLATE = app
CONFIG += console
SOURCES += main.cpp\
        mythread.cpp
HEADERS  += mythread.h

Прикрепленные файлы

 pauseThread.zip ( 1.53 килобайт ) Кол-во скачиваний: 154

 

[flankerr]

#include <sys/timeb.h>
#include <time.h>

....

void CMyThreadClass::MySleep(unsigned int uiPause_ms)
{
  int long long delta_ms = 0;
  struct timeb    timeb_prev;
  struct timeb    timeb_cur;
  ftime(&timeb_prev);
  do
  {
    ftime(&timeb_cur);
    delta_ms = 1000 * (timeb_cur.time - timeb_prev.time) + (timeb_cur.millitm - timeb_prev.millitm);
  }
  while(delta_ms < uiPause_ms);
};

просто, но зато ресуры проца буду юзаться...

Сообщение отредактировал flankerr - 8.6.2009, 13:26

[BRE]

просто но зато ресуры проца буду юзаться...

А зачем загружать процессор глупыми вычислениями времени? Если уж нити нужна пауза, лучше что-бы она в это время вообще ресурсы процессора не ела и он занялся чем-то более нужным.

Сообщение отредактировал BRE - 8.6.2009, 13:26

[flankerr]

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

[BRE]

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

IMHO, не очень хорошее отношение к коду. Да, для тебя, как для разработчика, так сделать проще . А вот если в каждой программе запущенной на компе, разработчики сделают по одному-паре таких потоков, и эти программы будут крутиться одновременно, то производительность может упасть очень сильно.

[Litkevich Yuriy]

тему разделил, см. sleep в main'е
Всё таки от приостановки отдельного потока сильно отличается.