Russian Qt Forum

C++ (Qt)
Controller::Controller(QObject *parent) : QObject(parent)
{
    worker = new Worker;
    worker->moveToThread(&workerThread);
    workerThread.start();
}
Controller::~Controller() {
    workerThread.quit();
    workerThread.wait();
    worker->deleteLater();
}
 

C++ (Qt)
Worker::Worker(QObject *parent) : QObject(parent)
{
    workerThread = new QThread;
    moveToThread(workerThread);
    workerThread->start();
}
 
Worker::~Worker() {
    workerThread->quit();
    workerThread->wait();
    workerThread->deleteLater();
}

C++ (Qt)
Worker::~Worker() {
    workerThread->quit();
    if (QThread::currentThread() != workerThread)
     workerThread->wait();
    workerThread->deleteLater();
}

C++ (Qt)
// деструктор вызывается в потоке workerThread
Worker::~Worker() {
    // в потоке workerThread обращаемся к объекту главного потока workerThread
    // (возможны проблемы с конкурентным доступом) с командой завершения QEventLoop 
    workerThread->quit();
 
    // в потоке workerThread обращаемся к объекту главного потока workerThread
    // (возможны проблемы с конкурентным доступом) с командой ожидания завершения активности данного потока
    // получаем игнорирование команды и не завершенный поток workerThread
    workerThread->wait();
 
    // в очередь главный поток отправляем событие удаления объекта workerThread,
    // которое может быть обработано в главном потоке даже до завершения этого деструктора,
    // когда активность потока workerThread фактически не завершена.
    workerThread->deleteLater();
}

C++ (Qt)
Worker::~Worker() {
    workerThread->quit();
    workerThread->deleteLater();
}
 

C++ (Qt)
Controller::Controller(QObject *parent) : QObject(parent)
{
    WorkerPool* pool = new WorkerPool;
    connect(&poolThread, &QThread::finished, pool, &QObject::deleteLater);
    pool->moveToThread(&poolThread);
    poolThread.start();
 
    for(int i=0; i<2; i++) {
        Worker *worker = new Worker(i);
        pool->append(worker);
 
        connect(this, &Controller::operate, worker, &Worker::doWork);
        connect(worker, &Worker::resultReady, this, &Controller::handleResults);
    }
 
 
    connect(&timer, &QTimer::timeout, [this]() { emit operate("do it"); });
}

C++ (Qt)
Controller::~Controller() {
    poolThread.quit();
    poolThread.wait();
}

C++ (Qt)
WorkerPool::~WorkerPool() {
    for(auto worker: pool) {
        delete worker;
    }
}

0x33E8 pool created
0x33E8 worker 1 created
0x33E8 worker 2 created
start work
0x0ef4 do it 1: done
0x3e78 do it 2: done
0x0ef4 do it 1: done
0x3e78 do it 2: done
0x0ef4 do it 1: done
0x3e78 do it 2: done
end work
0x3BBC worker 1 deleted
0x3BBC worker 2 deleted
0x3BBC pool deleted