Вопрос ламера о реализации многопоточности

[Hvzh]

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

Код:

    for(;;)
    {
        if(сameraID == 0)
            continue;
        else
        {
            std::cout << "StartController::service new camera ID = " << cameraID << std::endl ;
            break;
        }
    }

Значение cameraID должно менятся в слоте, который выглядит вот так:

Код:

void StartController::cameraStarted(int id)
{
    cameraID = id;
    qDebug() << "StartController::cameraStarted: cameraID = " << cameraID;
}

Может, вся проблема из-за цикла?

[Пантер]

Блин, конечно из-за цикла. Зачем тебе цикл нужен?

[Hvzh]

Вот полная функция:

Код:

void StartController::service(HttpRequest &request, HttpResponse &response) {
    QJsonObject json;

    cameraID = 0;
    newCameraID = 0;

    QByteArray url = request.getParameter("url");
    QByteArray minArea = request.getParameter("minArea");
    QByteArray maxArea = request.getParameter("maxArea");
    QByteArray startx = request.getParameter("x0");
    QByteArray starty = request.getParameter("y0");
    QByteArray endx = request.getParameter("x1");
    QByteArray endy = request.getParameter("y1");

    dbthread = new QThread;
    impthread = new QThread;

    worker = new DbWriteWorker();
    worker->setInterval(60);
    worker->moveToThread(dbthread);

    impworker = new ImageProcessingWorker(0, QString::fromUtf8(startx).toInt(), QString::fromUtf8(starty).toInt(),
                                          QString::fromUtf8(endx).toInt(), QString::fromUtf8(endy).toInt(),
                                          QString::fromUtf8(minArea).toInt(), QString::fromUtf8(maxArea).toInt(), 1, QString::fromUtf8(url));
    impworker->moveToThread(impthread);
    // Соединяем сигнал started потока, со слотом process "рабочего" класса, т.е. начинается выполнение нужной работы.
    connect(dbthread, SIGNAL(started()), worker, SLOT(process()));
    connect(impthread, SIGNAL(started()), impworker, SLOT(process()));

    // По завершению выходим из потока, и удаляем рабочий класс
    connect(worker, SIGNAL(finished()), dbthread, SLOT(quit()));
    connect(worker, SIGNAL(finished()), worker, SLOT(deleteLater()));
    connect(impworker, SIGNAL(finished()), impthread, SLOT(quit()));
    connect(impworker, SIGNAL(finished()), impworker, SLOT(deleteLater()));

    // Удаляем поток, после выполнения операции
    connect(dbthread, SIGNAL(finished()), dbthread, SLOT(deleteLater()));
    connect(impthread, SIGNAL(finished()), impthread, SLOT(deleteLater()));
    connect(impworker, SIGNAL(sendCounters(int,int, int)), worker, SLOT(waitForDB(int,int,int)));

    //connect(worker, SIGNAL(getDataSignal()), impworker, SLOT(prepareCounters()));

    dbthread->start();
    impthread->start();

    std::cout << "Waiting for new camera connection" << std::endl ;

    for(;;)
    {
        if(сameraID == 0)
            continue;
        else
        {
            std::cout << "StartController::service new camera ID = " << cameraID << std::endl ;
            break;
        }
    }

    if(cameraID > 0)
    {
        json["result"] = "Ok";
    }
    else
    {
         json["result"] = "Error";
    }
    json["cameraID"] = cameraID;

    QJsonDocument saveDoc(json);
    response.write(saveDoc.toJson(),true);
}

[Пантер]

Код

C++ (Qt)
connect(impworker, SIGNAL(newCameraOpened(int)), this, SLOT(cameraStarted(int)));
 
QEventLoop eventLoop;
connect(impworker, SIGNAL(newCameraOpened(int)), &eventLoop, SLOT(quit()));
eventLoop.exec();
 
//Here we know cameraId
 

[Пантер]

Если у тебя Qt5 и 11 стандарт, лучше лямбду вместо слота заюзать.

Код

C++ (Qt)
connect(impworker, SIGNAL(newCameraOpened(int)), [&eventLoop, &cameraId] (int id) {cameraId = id; eventLoop.quit();});
 

[Hvzh]

Сейчас попробую...

[Hvzh]

Ура, работает. Еще одно огромное спасибо!

[Hvzh]

Ну, и до кучи еще один вопрос. Есть функция отключения камеры, которая принимает оь браузера один параметр - ID камеры. Сейчас она выглядит так:

Код:

void StopController::service(HttpRequest &request, HttpResponse &response) {
    QJsonObject json;

    camSatus = -1;

    QByteArray par = request.getParameter("id");

    qDebug() << "StopController::ID int = " << par.toInt();

    procToKill = par.toInt();

    for(;;)
    {
        if(procToKill == 0)
            break;
    }

     json["result"] = "Ok";
     json["value"] = par.toInt();

        QJsonDocument saveDoc(json);
    response.write(saveDoc.toJson(),true);
}

Остановка сейчас сделана через глобальную переменную procToKill. Это работает, но вариант совершенно неподходящий при большом количестве подключений. При этом функция о процессах ничего, кроме переданного ID не знает. Я могу послать сигнал, например, stopCamera(cameraID), но как мне ответ поймать? И как заставить impworker этот сигнал ловить?

[Пантер]

У тебя каждая камера это отдельный процесс? Храни мапу соответствия номера камеры и номера процесса. Или я тчо-то не так понял.

[Hvzh]

Каждая камера - отдельный поток

[Пантер]

Храни где-нибудь мапу соответствия.

[Hvzh]

Храни где-нибудь мапу соответствия.

Ну, могу я получить ИД потока, но он же, вроде, для внутреннего пользования, и остановить поток используя Thread ID вроде нельзя

[Пантер]

QMap<int, QThread*> threads;

[Пантер]

А еще лучше:

QMap<int, YouClass*> m;
m->stop();

[Hvzh]

А еще лучше:

QMap<int, YouClass*> m;
m->stop();

Сделал так. Работает. Еще раз огромное спасибо!