Приостановка потока Опции

[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, выглядит как то странно.

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