QTMainSynchroSpace.cpp

См. документацию.

/*
 * CntmLib - Подсчет ссылок, потоки, синхронизация, асинхронные процедуры, события
 * Copyright (c) 2005, Овсеевич Роман, CntmLib@mail.ru
 * _______________________________________________________________________________
 * Разрешено свободное использование, копирование, распространение, изменение
 * (изменение сведений об авторских правах запрещено). Запрещена продажа и 
 * включение всей библиотеки или ее частей в другие библиотеки. В сведениях об
 * авторских правах на программу (или сведениях о программе, об авторах, 
 * использованных средствах разработки и т.д.) должна быть указана информация
 * о библиотеке CntmLib, ее авторе и, возможно, сайте или email'е.
 * Библиотека поставляется "как есть", без каких-либо гарантий со стороны автора.
 */ 

#ifdef CNTM_USE_QT_SS

#include <iostream>
#include <Cntm/Synchro/QTMainSynchroSpace.h>
#include <Cntm/Synchro/LoopInNoMainThreadException.h>
#include <Cntm/Synchro/NoReentrantModeException.h>

// EventLoop //////////////////////////////////////////////////////////////////////////////////////////////////////////////////

bool Cntm::QTMainSynchroSpace::EventLoop::created = false;

int Cntm::QTMainSynchroSpace::EventLoop::enterLoop()
{
/*DebugOut*///  std::cerr << "Before enterLoop " << loopLevel() << std::endl;
        implement->ReentrantEnter(loopLevel());
        int res = QEventLoop::enterLoop();
        implement->ReentrantLeave(loopLevel());
/*DebugOut*///  std::cerr << "After enterLoop " << loopLevel() << std::endl;
        return res;
}


// Implement //////////////////////////////////////////////////////////////////////////////////////////////////////////////////

Cntm::QTMainSynchroSpace::Implement::Implement(): instance(NULL)
{
        if (!SynchroSpace::SetMainSynchroSpaceFactory(this))
                throw IllegalStateException("Cntm::QTMainSynchroSpace::Prepare", "Попытка повторного создания главного синхропространства");
        holdInstance = SynchroSpace::Main(); // Получаем свою собственную ссылку на главное синхропространство.
}

bool Cntm::QTMainSynchroSpace::Implement::event(QEvent* e)
{
        switch (e->type())
        {
                case QEvent::User + 0:
                        taskQueue.Exec();
                        return true;
                        
                case QEvent::User + 1:
                        QApplication::exit(0); 
                        return true;
                        
                default:
                        return false;
        }
}

Cntm::SynchroSpace::Ptr Cntm::QTMainSynchroSpace::Implement::QueryMainInstance()
{
        // Сначала пытаемся воспользоваться указателем, который храним на время работы.
        SynchroSpace::Ptr res = holdInstance;
        if (res) return res;

        // Инициализируем ссылочный указатель из обычного. Если объект не существует
        // или он находится в состоянии удаления, то создаем новый объект.
        boost::recursive_mutex::scoped_lock lock(instanceMutex);
        res.SetPointer(instance);
        if (!res)
        {
                res = new QTMainSynchroSpace();
                instance = res.Pointer();
        }
        return res;
}

void Cntm::QTMainSynchroSpace::Implement::ReentrantEnter(int Level)
{
        // Проверка, что реентерабельный вход произведен в главном потоке.
        if (!QTMainSynchroSpace::IsMainThread())
        {
                std::cerr << "Критическая ошибка: Библиотека QT не позволяет запускать цикл обработки событий не из главного потока." << std::endl;
                throw LoopInNoMainThreadException("Cntm::QTMainSynchroSpace::Implement::ReentrantEnter", "Библиотека QT не позволяет запускать цикл обработки событий не из главного потока");
        }

        // Проверка того, что реентерабельный вход вообще разрешен.
        SynchroSpace::Ptr space = SynchroSpace::Main();
        if (space && !space->IsReentrantMode())
        {
                std::cerr << "Критическая ошибка: Запуск цикла обработки событий QT когда вход в главное синхропространство произведен не в REENTRANT режиме." << std::endl;
                throw NoReentrantModeException("Cntm::QTMainSynchroSpace::Implement::ReentrantEnter", "Запуск цикла обработки событий QT когда вход в главное синхропространство произведен не в REENTRANT режиме");
        }
        
        // Посылаем сообщение для выполнения отложенных синхрозадач (т.к. их следует выполнять в цикле обработки сообщений).
        QApplication::postEvent(this, new QEvent(QEvent::Type(QEvent::User + 0)));
        
        // Выходим из критической секции QApplication.
        qApp->unlock();
}

void Cntm::QTMainSynchroSpace::Implement::ReentrantLeave(int Level)
{
        // Перед выходом из реентерабельного входа входим в критическую секцию QApplication.
        qApp->lock();
}

void Cntm::QTMainSynchroSpace::Implement::Start()
{
        // Входим в синхросекцию QApplication в главном потоке (выйдем перед входом 
        // в цикл обработки событий или в конце).
        qApp->lock();
}

void Cntm::QTMainSynchroSpace::Implement::Finish()
{
        holdInstance.SetNull(); // Освобождаем свою ссылку на главное синхропространство.
        while (instance) qApp->exec(); // Запускаем цикл обработки событий пока остается главное синхропространство.
        qApp->unlock(); // Выходим из синхросекции QApplication в главном потоке.
}

void Cntm::QTMainSynchroSpace::Implement::MainInstanceDeleted(QTMainSynchroSpace* Inst) 
{
        // Если синхропространство не было пересоздано когда текущее пространство находилось в удаляемом состоянии,
        // сбрасываем указатель и посылаем сообщение о выходе из цикла обработки сообщений. Если пространство было
        // пересоздано, то указатель трогать не надо, а о выходе сообщит новое пространство при своем удалении.
        boost::recursive_mutex::scoped_lock lock(instanceMutex);
        if (instance == Inst)
        {
                instance = NULL;
                QApplication::postEvent(this, new QEvent(QEvent::Type(QEvent::User + 1)));
        }
}


// QTMainSynchroSpace /////////////////////////////////////////////////////////////////////////////////////////////////////////

Cntm::QTMainSynchroSpace::Implement* Cntm::QTMainSynchroSpace::implement;

void Cntm::QTMainSynchroSpace::Prepare()
{
        EventLoop::CreateEventLoop();
        implement = new Implement;
}

#endif //CNTM_USE_QT_SS

---