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

[RazrFalcon]

thread = new QThread(this);
for (int p = 0; p < 3; ++p) {
  prc = new Processor(); // Processor класс-наследник qobject. В конструкторе запускает QProcess.
  prc->moveToThread(thread);
}
thread->start();

В итоге у меня запускается три Processor одновременно. А как сделать, что бы они стратовали по очереди? То есть, у меня есть отдельный поток, и в нем я запускаю обработку (что бы GUI не зависал). При том что новая обработка должна начинается сразу после окончания старой. А у меня как бы паралельно все работают.

[Dovgon]

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

[RazrFalcon]

Эммм... как то слишком сложно.
Может можно просто запускать процессы руками, когда захочу?

[RazrFalcon]

up!

[wiz29]

а зачем в таком случае 3 процесса запускать? (если они решают последовательно задачу)

[RazrFalcon]

Перефразирую.
Нужно запустить программу с разными ключами 3-и раза. Подряд.

PS: вы про

proga -a; proga -b; proga -c

.Да, не подумал о таком... Но это как то странно выглядит.

[MJIbIu]

Перефразирую.
Нужно запустить программу с разными ключами 3-и раза. Подряд.

PS: вы про

proga -a; proga -b; proga -c

.Да, не подумал о таком... Но это как то странно выглядит.

а зачем запускать 3 раза если они будут у тебя идти по порядку ?

proga a b c // 3 аргумента 
int main(int argc, char* argv[])
{
............
thread = new QThread(this);
prc = new Processor(argv); // засовывай в Processor и обрабатывай их там по очереди 
prc->moveToThread(thread);
thread->start();

}

мб я не так понял

Сообщение отредактировал MJIbIu - 31.8.2011, 16:27

[RazrFalcon]

Ну сейчас так и происходит.
Разве что:

bool QProcess::waitForFinished ( int msecs = 30000 )

приводит к зависанию главного окна, а не должен.

По этому выкрутился, пока что, запуском процесса по окончании предыдущего:

int curr = 0;

Processor::Processor(QStringList argsList, QObject *parent) :
    QObject(parent)
{
  proc = new QProcess(this);
  connect(proc,SIGNAL(finished(int)),this,SLOT(finished(int)));

  finished(1);
}

void Processor::finished(int)
{
  if (curr < argsList.count()) {
    proc->start("proga", argsList.at(curr));
    curr++;
  } else {
    emit done();
  }
}

Сообщение отредактировал RazrFalcon - 31.8.2011, 16:37

[ssoft]

Вот так работает. Быстрый набросок.

main.cpp

#include <QCoreApplication>
#include <QDir>
#include "ProcessManager.h"

int main ( int narg, char ** varg )
{
    QCoreApplication app( narg, varg );
    ProcessManager manager;
    app.connect( &manager, SIGNAL( finished() ), SLOT( quit() ), Qt::QueuedConnection );

    manager.append( QDir::currentPath() + "/test.bat" );
    manager.append( QDir::currentPath() + "/test.bat" );
    manager.append( QDir::currentPath() + "/test.bat" );
    manager.start();

    return app.exec();
}

ProcessManager.h

#ifndef PROCESSMANAGER_H
#define PROCESSMANAGER_H

#include <QObject>
#include <QProcess>

class ProcessManager : public QObject
{
    Q_OBJECT
private:
    QStringList proc_files;
    QProcess * process;
    int current_proc;

public:
    explicit ProcessManager ( QObject *parent = 0 );

    void append ( const QString & proc_file );
    void start ();

public slots:
    void nextProccess ();
    void onError ();

signals:
    void finished ();
};

#endif // PROCESSMANAGER_H

ProcessManager.cpp

#include <QDebug>
#include "ProcessManager.h"

ProcessManager::ProcessManager(QObject *parent)
    : QObject(parent)
    , process( new QProcess( this ) )
    , current_proc()
{
    connect( process, SIGNAL( error( QProcess::ProcessError ) )
        , this, SLOT( onError() ) );
    connect( process, SIGNAL( finished ( int, QProcess::ExitStatus ) )
        , this, SLOT( nextProccess() ) );
}

void ProcessManager::append ( const QString & proc_file )
{
    proc_files.append( proc_file );
}

void ProcessManager::start ()
{
    current_proc = 0;
    nextProccess ();
}

void ProcessManager::nextProccess ()
{
    if ( current_proc < proc_files.count() )
        process->start( proc_files.at( current_proc++ ) );
    else
        emit finished();
}

void ProcessManager::onError ()
{
    qWarning() << "Process execute error";
    emit finished();
}

[RazrFalcon]

Оно то может и работает. Но у меня не консольное приложение.
У меня есть 2-а потока. Главный и второстепенный, в котором и запускается обработка. Так вот там уже Ваш способ не прокатит
Проблема ведь в том, что я не могу запустить обработку НЕ в конструкторе класса, который помещаю в поток.

[ssoft]

Оно то может и работает. Но у меня не консольное приложение.
У меня есть 2-а потока. Главный и второстепенный, в котором и запускается обработка. Так вот там уже Ваш способ не прокатит
Проблема ведь в том, что я не могу запустить обработку НЕ в конструкторе класса, который помещаю в поток.

Очень даже прокатывает.

1. Причем здесь тип приложения?

ProcessManager можно создать в любом потоке, можно и во второстепенном.

2. Обработка, как я понимаю, происходит в вызываемых процессах, а не во второстепенном потоке.

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

[RazrFalcon]

Ну у меня ваш код не заработал. Так что...

[ssoft]

Ну у меня ваш код не заработал. Так что...

Всем желающим рабочий пример

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

 test.zip ( 4.07 килобайт ) Кол-во скачиваний: 83

 

[RazrFalcon]

../test/program/main.cpp:2: error: conio.h: No such file or directory

уже весeло...

Зачем вообще юзать std в кьюте?

Сообщение отредактировал RazrFalcon - 7.9.2011, 17:06

[RazrFalcon]

Вопрос все еще открыт.

[Sokoloff]

Вопрос все еще открыт.

Через сигнал finished, нормальное решение.

[RazrFalcon]

Если вы про тот что я привел, то тут тоже не все гладко.
Валятся такие ошибки:

QObject: Cannot create children for a parent that is in a different thread.
(Parent is QProcess(0x92891d8), parent's thread is QThread(0x90fb448), current thread is QThread(0x91b9470)
QObject: Cannot create children for a parent that is in a different thread.
(Parent is QProcess(0x92891d8), parent's thread is QThread(0x90fb448), current thread is QThread(0x91b9470)
QObject: Cannot create children for a parent that is in a different thread.
(Parent is QProcess(0x92891d8), parent's thread is QThread(0x90fb448), current thread is QThread(0x91b9470)
QObject: Cannot create children for a parent that is in a different thread.
(Parent is QProcess(0x92891d8), parent's thread is QThread(0x90fb448), current thread is QThread(0x91b9470)
QObject: Cannot create children for a parent that is in a different thread.
(Parent is QProcess(0x92891d8), parent's thread is QThread(0x90fb448), current thread is QThread(0x91b9470)

Если сделать дополнительно waitForFinished(), то вроде пашет, но текст на сигнал readyReadStandardOutput() не приходит, так как процесс ждет...

Вот и не ясно как оно должно работать?

Вопрос: нужен ли waitForFinished() внутри дочернего потока?

[RazrFalcon]

Up

[RazrFalcon]

Написал пример (в аттаче).
Почему оно не работает?

У меня с waitForFinished(); главное окно не появляется, без - валятся потоки:

Раскрывающийся текст

"0
" 
QObject: Cannot create children for a parent that is in a different thread.
(Parent is QProcess(0x9d81ab0), parent's thread is QThread(0x9cef448), current thread is QThread(0x9ddb810)
QObject: Cannot create children for a parent that is in a different thread.
(Parent is QProcess(0x9d81ab0), parent's thread is QThread(0x9cef448), current thread is QThread(0x9ddb810)
QObject: Cannot create children for a parent that is in a different thread.
(Parent is QProcess(0x9d81ab0), parent's thread is QThread(0x9cef448), current thread is QThread(0x9ddb810)
QObject: Cannot create children for a parent that is in a different thread.
(Parent is QProcess(0x9d81ab0), parent's thread is QThread(0x9cef448), current thread is QThread(0x9ddb810)
QObject: Cannot create children for a parent that is in a different thread.
(Parent is QProcess(0x9d81ab0), parent's thread is QThread(0x9cef448), current thread is QThread(0x9ddb810)
"0
" 
QObject: Cannot create children for a parent that is in a different thread.
(Parent is QProcess(0x9d81ab0), parent's thread is QThread(0x9cef448), current thread is QThread(0x9ddb810)
QObject: Cannot create children for a parent that is in a different thread.
(Parent is QProcess(0x9d81ab0), parent's thread is QThread(0x9cef448), current thread is QThread(0x9ddb810)
QObject: Cannot create children for a parent that is in a different thread.
(Parent is QProcess(0x9d81ab0), parent's thread is QThread(0x9cef448), current thread is QThread(0x9ddb810)
QObject: Cannot create children for a parent that is in a different thread.
(Parent is QProcess(0x9d81ab0), parent's thread is QThread(0x9cef448), current thread is QThread(0x9ddb810)
QObject: Cannot create children for a parent that is in a different thread.
(Parent is QProcess(0x9d81ab0), parent's thread is QThread(0x9cef448), current thread is QThread(0x9ddb810)
"0
" 
QObject: Cannot create children for a parent that is in a different thread.
(Parent is QProcess(0x9d81ab0), parent's thread is QThread(0x9cef448), current thread is QThread(0x9ddb810)
QObject: Cannot create children for a parent that is in a different thread.
(Parent is QProcess(0x9d81ab0), parent's thread is QThread(0x9cef448), current thread is QThread(0x9ddb810)
QObject: Cannot create children for a parent that is in a different thread.
(Parent is QProcess(0x9d81ab0), parent's thread is QThread(0x9cef448), current thread is QThread(0x9ddb810)
QObject: Cannot create children for a parent that is in a different thread.
(Parent is QProcess(0x9d81ab0), parent's thread is QThread(0x9cef448), current thread is QThread(0x9ddb810)
QObject: Cannot create children for a parent that is in a different thread.
(Parent is QProcess(0x9d81ab0), parent's thread is QThread(0x9cef448), current thread is QThread(0x9ddb810)
"0
" 
QObject: Cannot create children for a parent that is in a different thread.
(Parent is QProcess(0x9d81ab0), parent's thread is QThread(0x9cef448), current thread is QThread(0x9ddb810)
QObject: Cannot create children for a parent that is in a different thread.
(Parent is QProcess(0x9d81ab0), parent's thread is QThread(0x9cef448), current thread is QThread(0x9ddb810)
QObject: Cannot create children for a parent that is in a different thread.
(Parent is QProcess(0x9d81ab0), parent's thread is QThread(0x9cef448), current thread is QThread(0x9ddb810)
QObject: Cannot create children for a parent that is in a different thread.
(Parent is QProcess(0x9d81ab0), parent's thread is QThread(0x9cef448), current thread is QThread(0x9ddb810)
QObject: Cannot create children for a parent that is in a different thread.
(Parent is QProcess(0x9d81ab0), parent's thread is QThread(0x9cef448), current thread is QThread(0x9ddb810)
QProcess::start: Process is already running
"0

А вывод должен быть таким:

0
1
2
3
4
etc.

Заранее спасибо!

Сообщение отредактировал RazrFalcon - 13.10.2011, 4:15

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

 thread_example.zip ( 2.91 килобайт ) Кол-во скачиваний: 64

 

[BRE]

Ну так Qt в консоль тебе все пишет.

[RazrFalcon]

И что я должен исправить?!

[BRE]

И что я должен исправить?!

Thread::Thread(QObject *parent) :
    QObject(parent)
{
    curr = 0;

    proc = new QProcess( this );        // <<<<<<<<<<<< Здесь нужно указывать родителя. Иначе при перемещении объекта этого класса в рабочий поток, объект proc перемещен не будет!
    connect(proc,SIGNAL(readyRead()),this,SLOT(readOutput()));
    connect(proc,SIGNAL(finished(int)),this,SLOT(startNew()));

    startNew();
}

[RazrFalcon]

Огромное спасибо! Теперь пашет.
И как я не мог до этого додуматься уже как 2-а месяца...

[PAFOS]

Разве что:
bool QProcess::waitForFinished ( int msecs = 30000 )
приводит к зависанию главного окна, а не должен.

решается просто

while( !process->waitForFinished(10) )
qApp->processEvents(); // все потоки работают и GUI не виснет