Коллизия QEventLoop

We recommend hosting TIMEWEB

Stable hosting, on which the social network EVILEG is located. For projects on Django we recommend VDS hosting.

Привет. Можно попродробнее? Вы создаёте два QEventLoop в логике своей программы? Используете мьютексы? или что?

Обычно dead lock`и исправляются только переписыванием логики программы. Но каждый случай индивидуален.

Приложение трэкинг задач. Есть вложения. Добавляем вложение и отправляем его на сервер. Для синхронного вызова методов в синхронизации, используем QEventLoop при отправке вложений. В момент синхронизации при попытке входа в задачу, показывается курсор ожидания (ожидания завершения синхронизации), для которого также используется QEventLoop . В итоге получается конфликт и QEventLoop в реализации курсора перекрывает, другой. Синхронизация не заканчивается.

// MyModelVm.cpp
void MyModelVm::transitionStart(int modelEntityNumber) {
    Navigator::instance().showWaitCursor("...Cинхронизация данных");
    m_currentEntity = modelEntityNumber;

    QEventLoop loop;
    AutoDisconnect(
        connect(&myModelManager::instance(), &myModelManager::activeSyncChanged, [this, &loop] {

            if ( !isActiveSync() && !isChangedLocal() ) {
                loop.quit();
                emit isActiveSyncChanged();
            }
        });
    )
    loop.exec();
}

// myModelManager.cpp
void myModelManager::sendObjects() {
    qDebug() << "<=> sending objects";

    QList<QSharedPointer<LocalModel>> addedLocalModel = myModelManager::instance().getLocalAddedModel();
    qDebug() << "Number of objects added" << addedLocalModel.size();

    int sendObjectsCount = 0;
    int modelCount = addedLocalModel.size();
    if (sendObjectsCount) {
        QEventLoop loop;
        for (auto& localModel : addedLocalModel) {
            auto filesReply = myModelManager::instance().postFiles(ObjectHelper::filePath(localModel->fileName, localModel->fileId));
            myModelManager::instance().replyReady(filesReply,
                                                    [this, localModel, modelCount, &sendObjectsCount, &loop]
                                                    (const BaseResult& filesResult)
            {
                if (filesResult.code() == ServiceCodeResult::OK) {
                    qDebug() << "Model" << localModel->fileName << "recieved to file-server";
                    QSharedPointer<FilesJson> jsonDataFiles = FilesJson::fromJson(filesResult.jsonDocument());
                    QString fId = jsonDataFiles->id;
                    QString fName = jsonDataFiles->fileName;
                    QString xId = StringHelper::createUuid();
                    auto postChangesModelReply = myModelManager::instance().postChangesAddModel(fName, fName, fId, xId);
                    myModelManager::instance().replyReady(postChangesModelReply,
                                                            [this, localModel, externalId, fileId, modelCount, &sendObjectsCount, &loop]
                                                            (const BaseResult& changesResult)
                    {
                        if (changesResult.code() == ServiceCodeResult::OK) {
                            qDebug() << "Attachment" << localModel->fileName << "recieved to MT Attachment";
                            m_mutex.lock(); //QMutex
                            ++sendAttachmentCount;
                            localModel->externalId = externalId;
                            localModel->fileId = fileId;
                            localModel->changeType = ChangeType::None;
                            myModelManager::instance().updateLocalModel(localModel);

                            if (sendObjectsCount == modeltCount) {
                                qDebug() << "=== sendAttachmentChanges Ok";
                                m_mutex.unlock();
                                loop.quit();
                                return;
                            }
                            m_mutex.unlock();
                        } else {
                            qDebug() << "Ошибка отправки файла: " + localModel->fName + " : " + changesResult.message() + " (postChangesModel)";
                            Logger::instance().write("Ошибка отправки файла: " + localModel->fName + " : " + changesResult.message(), Logger::ERROR);
                            qDebug() << "=== sendObjects Fail";
                            loop.quit();
                            return;
                        }
                    });
                } else {
                    qDebug() << "Ошибка отправки файла: " + localModel->fName + " : " + filesResult.message() + " (postFiles)";
                    Logger::instance().write("Ошибка отправки файла: " + localModel->fName + " : " + filesResult.message(), Logger::ERROR);
                    qDebug() << "=== sendObjects Fail";
                    loop.quit();
                    return;
                }
            });
        }
        loop.exec();
    }
}