Коллизия QEventLoop

Рекомендуем хостинг TIMEWEB

Стабильный хостинг, на котором располагается социальная сеть EVILEG. Для проектов на Django рекомендуем VDS хостинг.

Привет. Можно попродробнее? Вы создаёте два 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();
    }
}