/**************************************************************************** ** ** Copyright (C) 2010 Nokia Corporation and/or its subsidiary(-ies). ** All rights reserved. ** Contact: Nokia Corporation (qt-info@nokia.com) ** ** This file is part of the QtCore module of the Qt Toolkit. ** ** $QT_BEGIN_LICENSE:LGPL$ ** No Commercial Usage ** This file contains pre-release code and may not be distributed. ** You may use this file in accordance with the terms and conditions ** contained in the Technology Preview License Agreement accompanying ** this package. ** ** GNU Lesser General Public License Usage ** Alternatively, this file may be used under the terms of the GNU Lesser ** General Public License version 2.1 as published by the Free Software ** Foundation and appearing in the file LICENSE.LGPL included in the ** packaging of this file. Please review the following information to ** ensure the GNU Lesser General Public License version 2.1 requirements ** will be met: http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html. ** ** In addition, as a special exception, Nokia gives you certain additional ** rights. These rights are described in the Nokia Qt LGPL Exception ** version 1.1, included in the file LGPL_EXCEPTION.txt in this package. ** ** If you have questions regarding the use of this file, please contact ** Nokia at qt-info@nokia.com. ** ** ** ** ** ** ** ** ** $QT_END_LICENSE$ ** ****************************************************************************/ #ifndef QTCONCURRENT_RUNBASE_H #define QTCONCURRENT_RUNBASE_H #include #ifndef QT_NO_CONCURRENT #include #include #include QT_BEGIN_HEADER QT_BEGIN_NAMESPACE QT_MODULE(Core) #ifndef qdoc namespace QtConcurrent { template struct SelectSpecialization { template struct Type { typedef Normal type; }; }; template <> struct SelectSpecialization { template struct Type { typedef Void type; }; }; template class RunFunctionTaskBase : public QFutureInterface , public QRunnable { public: QFuture start() { this->setRunnable(this); this->reportStarted(); QFuture future = this->future(); QThreadPool::globalInstance()->start(this, /*m_priority*/ 0); return future; } void run() {} virtual void runFunctor() = 0; }; template class RunFunctionTask : public RunFunctionTaskBase { public: void run() { if (this->isCanceled()) { this->reportFinished(); return; } #ifndef QT_NO_EXCEPTIONS try { #endif this->runFunctor(); #ifndef QT_NO_EXCEPTIONS } catch (QtConcurrent::Exception &e) { QFutureInterface::reportException(e); } catch (...) { QFutureInterface::reportException(QtConcurrent::UnhandledException()); } #endif this->reportResult(result); this->reportFinished(); } T result; }; template <> class RunFunctionTask : public RunFunctionTaskBase { public: void run() { if (this->isCanceled()) { this->reportFinished(); return; } #ifndef QT_NO_EXCEPTIONS try { #endif this->runFunctor(); #ifndef QT_NO_EXCEPTIONS } catch (QtConcurrent::Exception &e) { QFutureInterface::reportException(e); } catch (...) { QFutureInterface::reportException(QtConcurrent::UnhandledException()); } #endif this->reportFinished(); } }; } //namespace QtConcurrent #endif //qdoc QT_END_NAMESPACE QT_END_HEADER #endif // QT_NO_CONCURRENT #endif