VPF::QThread бесконечные циклы - Форум программистов

Lindemann66

Дата 7.9.2011, 09:31 (ссылка)

(нет голосов)

Загрузка ...

Thinking...

Профиль
Группа: Участник
Сообщений: 117
Регистрация: 2.8.2011
Где: Ульяновск

Репутация: нет
Всего: нет

Всем привет!

У меня такой, возможно, глупый вопрос
Следующий код:
Заголовочные файлы

Код


//класс, выдающий сообщение в консоль
class Event {
public:
    void Show(QString str);
};

//класс главного потока
class MainThread {
private:
    Event *m_event;
public:
    MainThread();
    ~MainThread();
    void Run();
};

//класс второстепенного потока
class ChildThread : public QThread {
Q_OBJECT
private:
    Event *m_event;
    uint m_number;
public:
    void setNumber(uint number);
    void setEvent(Event *event);
    void run();
};

Реализация

Код


#include "Classes.h"

void Event::Show(QString str) {
    qDebug() << str;
}

MainThread::MainThread() {
    m_event = new Event();
}

MainThread::~MainThread() {
    delete m_event;
}

void MainThread::Run() {
    for (int i = 0; i < 10; i++) {
        ChildThread child;
        child.setNumber(i);
        child.setEvent(m_event);
        child.run();
    }
}

void ChildThread::setNumber(uint number) {
    m_number = number;
}

void ChildThread::setEvent(Event *event) {
    m_event = event;
}

void ChildThread::run() {
    while (true) {
        m_event->Show(QString("Run from %1 thread").arg(m_number));

        sleep(3);
    }
}

Суть
Нужно создать определённое число потоков (10 в данном примере)
И вызывать внутри каждого некую операцию (в данном случае - qDebug)

Проблема
Программа доходит до бесконечного цикла первого потока, и в нём и остаётся

Как можно сделать так, чтобы проинициализировались все 10 бесконечных циклов, и продолжали работу?

Буду очень благодарен за любые ответы smile

Это сообщение отредактировал(а) Lindemann66 - 7.9.2011, 09:32

--------------------

stay true

alexvs11

Дата 7.9.2011, 09:47 (ссылка)

(нет голосов)

Загрузка ...

hell is here

Профиль
Группа: Участник
Сообщений: 518
Регистрация: 21.8.2010

Репутация: 2
Всего: 10

start()

borisbn

Дата 7.9.2011, 10:33 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 4875
Регистрация: 6.2.2010
Где: Ростов-на-Дону

Репутация: 48
Всего: 135

Lindemann66, ты не создаёшь ни одного потока. То, что твой класс называется ChildThread и то, что он наследован от QThread - ещё не значит, что ты создаёшь поток. Сделай так:

Код


class MainThread {
private:
    Event *m_event;
    std::vector< ChildThread * > m_threads;
public:
    MainThread();
    ~MainThread();
    void Run();
};

class ChildThread : public QThread {
Q_OBJECT
private:
    Event *m_event;
    uint m_number;
    bool m_keepRun;
public:
    ChildThread() : m_keepRun( true ) {}
    void setNumber(uint number);
    void setEvent(Event *event);
    void run();
    void stop() { m_keepRun = false; }
};


MainThread::MainThread() {
    m_event = new Event();
    for ( int i = 0; i < 10; i++ ) {
        ChildThread * thread = new ChildThread();
        thread->setNumber( i );
        thread->setEvent( m_event );
        m_threads.push_back( thread );
    }
}

MainThread::~MainThread() {
    foreach ( const QThread * thread, m_threads ) {
        thread->stop();
        thread->wait();
        delete thread;
    }
    delete m_event;
}
void MainThread::Run() {
    foreach ( const QThread * thread, m_threads ) {
        thread->start();
    }
}

void ChildThread::run() {
    while ( m_keepRun ) {
        m_event->Show(QString("Run from %1 thread").arg(m_number));
        sleep(3);
    }
}

и ещё (просто замечание по стилю) - обычно принято интерфейс класса (секция public) выносить в начало описания, а внутренности, нужные только самому классу (секция private) - в конец. У тебя же наоборот.

--------------------

Женщины отличаются от программистов тем, что у них чары состоят из стрингов

Alca

Дата 7.9.2011, 10:40 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 3993
Регистрация: 14.6.2006

Репутация: 2
Всего: 50

Цитата

А как же порядок инициализации членов класса? smile

--------------------

C++ cross-platform library

Lindemann66

Дата 7.9.2011, 10:45 (ссылка)

(нет голосов)

Загрузка ...

Thinking...

Профиль
Группа: Участник
Сообщений: 117
Регистрация: 2.8.2011
Где: Ульяновск

Репутация: нет
Всего: нет

Спасибо за ответы smile

Почитав их, а также документацию, сделал так, как написано ниже:
Заголовочный файл

Код

//класс, выдающий сообщение в консоль
class Event {
public:
    void Show(QString str);
};

//класс второстепенного потока
class ChildThread : public QThread {
Q_OBJECT
public:
    ChildThread(QObject *parent = 0);
    void setNumber(uint number);
    void setEvent(Event *event);
protected:
    void timerEvent(QTimerEvent *event);
private:
    Event *m_event;
    uint m_number;
};

//класс главного потока
class MainThread {
public:
    MainThread();
    ~MainThread();
    void Run();
private:
    Event *m_event;
    QList<ChildThread *> threads;
};

Реализация

Код


void Event::Show(QString str) {
    qDebug() << str;
}

MainThread::MainThread() {
    m_event = new Event();
}

MainThread::~MainThread() {
    delete m_event;
    for (int i = 0; i < 3; i++) {
        delete threads[i];
    }
}

void MainThread::Run() {
    for (int i = 0; i < 3; i++) {
        ChildThread *child = new ChildThread();
        child->setNumber(i);
        child->setEvent(m_event);
        threads.push_back(child);
        child->start();
    }
}

ChildThread::ChildThread(QObject *parent) : QThread(parent) {
    startTimer(1000);
}

void ChildThread::setNumber(uint number) {
    m_number = number;
}

void ChildThread::setEvent(Event *event) {
    m_event = event;
}

void ChildThread::timerEvent(QTimerEvent *event) {
    m_number++;
    m_event->Show(QString("Run from %1 thread").arg(m_number));
}

Добавлено через 2 минуты и 5 секунд

Цитата(Alca @ 7.9.2011, 10:40

)

А как же порядок инициализации членов класса?

А что с ними?)

--------------------

stay true

Alca

Дата 7.9.2011, 11:15 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 3993
Регистрация: 14.6.2006

Репутация: 2
Всего: 50

Цитата

А что с ними?)

Инициализаци - сверху вниз

--------------------

C++ cross-platform library

borisbn

Дата 7.9.2011, 13:01 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 4875
Регистрация: 6.2.2010
Где: Ростов-на-Дону

Репутация: 48
Всего: 135

Lindemann66, у тебя не определено тело основной функции потока. А в случае с таймером наследоваться от QThread - вообще необязательно, как и вызывать start().
Ты попробовал как я тебе написал ?

Цитата(Alca @ 7.9.2011, 10:40

)

А как же порядок инициализации членов класса?

Члены класса (переменные, а не ф-ции) в public - вообще зло.
А за такое

Код


class X {
public:
    int x;
    X() : y(x ), x( 0 ) {} 
private:
    int y;
}

ты бы, наверное, и сам руки бы оторвал

--------------------

Женщины отличаются от программистов тем, что у них чары состоят из стрингов

Alca

Дата 7.9.2011, 13:07 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 3993
Регистрация: 14.6.2006

Репутация: 2
Всего: 50

Цитата

Члены класса (переменные, а не ф-ции) в public - вообще зло.

а если переменных много ( порядка 10-20) ? Делать для каждой по два метода (get, set) и по свойству?
Чего-то геморно...

Это сообщение отредактировал(а) Alca - 7.9.2011, 13:08

--------------------

C++ cross-platform library

borisbn

Дата 7.9.2011, 13:13 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 4875
Регистрация: 6.2.2010
Где: Ростов-на-Дону

Репутация: 48
Всего: 135

Цитата(Alca @ 7.9.2011, 13:07

)

а если переменных много ( порядка 10-20) ? Делать для каждой по два метода (get, set) и по свойству?

я себе для этого в VisualAssistant'е сделал snippet. А раньше (да и щаз иногда) делал макрос

Код


#define GETSET(type, name) \
public: \
    type name() const {return m_##name;} \
    void set##name##(type value){m_##name=value;} \
protected: \
    type m_##name

--------------------

Женщины отличаются от программистов тем, что у них чары состоят из стрингов

Alca

Дата 7.9.2011, 13:28 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 3993
Регистрация: 14.6.2006

Репутация: 2
Всего: 50

borisbn, я имею ввиду, что объем код начинает увеличиваться со страшной силой

Добавлено через 15 секунд
Впадло скролить

--------------------

C++ cross-platform library

spyswamp

Дата 7.9.2011, 20:48 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 349
Регистрация: 18.8.2006

Репутация: 1
Всего: 7

Alca, значит это очень плохой класс, который содержит в себе 10-20 переменных-членов, которые надо куда-то выдавать. Говорит лишь о проблеме дизайна, не более.

--------------------

- why you call it beta?
- cuz it's betta then nothin'

Alca

Дата 7.9.2011, 21:47 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 3993
Регистрация: 14.6.2006

Репутация: 2
Всего: 50

https://github.com/skynowa/xLib/blob/master...Lib/Net/CxCgi.h smile

--------------------

C++ cross-platform library

Lindemann66

Дата 8.9.2011, 12:56 (ссылка)

(нет голосов)

Загрузка ...

Thinking...

Профиль
Группа: Участник
Сообщений: 117
Регистрация: 2.8.2011
Где: Ульяновск

Репутация: нет
Всего: нет

Цитата(borisbn @ 7.9.2011, 13:01

)

Ты попробовал как я тебе написал ?

Да, попробовал smile

Респект

Единственно, не сработало

Код


foreach ( const QThread * thread, m_threads ) {
        thread->start();
    }

ругается на QThread (в 2ух местах, где foreach)

Цитата

error: 'const class QThread' has no member named 'stop'
error: passing 'const QThread' as 'this' argument of 'bool QThread::wait(long unsigned int)' discards qualifiers
error: passing 'const QThread' as 'this' argument of 'void QThread::start(QThread::Priority)' discards qualifiers

Поэтому заменил на

Код


foreach ( ChildThread *thread, m_threads ) {
        thread->start();
    }

Теперь буду пробовать прикрутить мутексы

Добавлено @ 13:00

Цитата(borisbn @ 7.9.2011, 13:01

)

Код


class X {
public:
    int x;
    X() : y(x ), x( 0 ) {} 
private:
    int y;
}

ты бы, наверное, и сам руки бы оторвал

да!

Цитата(borisbn @ 7.9.2011, 13:13

)

А раньше (да и щаз иногда) делал макрос

красиво
Тоже так делаю

Добавлено @ 13:08
Кстати, не подскажешь, как в твоём коде сделать так, чтобы операция действия с каждым event (там вывод в консоль выполняется) блокировалась мутексом?
Если, например, будет

Код


void ChildThread::run() {
    while ( m_keepRun ) {
        m_event->Show(QString("Run from %1 thread (1)").arg(m_number));
        sleep(m_number);
        m_event->Show(QString("Run from %1 thread (2)").arg(m_number));
        sleep(m_number);
        m_event->Show(QString("Run from %1 thread (3)").arg(m_number));
        sleep(m_number);
    }
}

Это сообщение отредактировал(а) Lindemann66 - 8.9.2011, 13:14

--------------------

stay true

borisbn

Дата 8.9.2011, 13:27 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 4875
Регистрация: 6.2.2010
Где: Ростов-на-Дону

Репутация: 48
Всего: 135

Цитата(Lindemann66 @ 8.9.2011, 12:56

)

Кстати, не подскажешь, как в твоём коде сделать так, чтобы операция действия с каждым event (там вывод в консоль выполняется) блокировалась мутексом?

Код


class Event {
public:
    void Show(QString str);
private:
    QMutex m_mutex;
};

void Event::Show(QString str) {
    QMutexLocker( & m_mutex );
    qDebug() << str;
}

--------------------

Женщины отличаются от программистов тем, что у них чары состоят из стрингов

Lindemann66

Дата 8.9.2011, 13:45 (ссылка)

(нет голосов)

Загрузка ...

Thinking...

Профиль
Группа: Участник
Сообщений: 117
Регистрация: 2.8.2011
Где: Ульяновск

Репутация: нет
Всего: нет

Спасибо

только если вот так написать QMutexLocker(&m_mutex);, то будет ошибка

Цитата

error: 'm_mutex' declared as reference but not initialized

Я вот так написал QMutexLocker locker(&m_mutex);
Без ошибок собралось

Это сообщение отредактировал(а) Lindemann66 - 8.9.2011, 13:46

--------------------

stay true

0 Пользователей читают эту тему (0 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| С/С++: Кроссплатформенное программирование, Qt/Gtk+/wxWidgets \| Следующая тема »