1 /* 2 * Copyright (c) 2017 Dmitry Kazakov <dimula73@gmail.com> 3 * 4 * This program is free software; you can redistribute it and/or modify 5 * it under the terms of the GNU General Public License as published by 6 * the Free Software Foundation; either version 2 of the License, or 7 * (at your option) any later version. 8 * 9 * This program is distributed in the hope that it will be useful, 10 * but WITHOUT ANY WARRANTY; without even the implied warranty of 11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 12 * GNU General Public License for more details. 13 * 14 * You should have received a copy of the GNU General Public License 15 * along with this program; if not, write to the Free Software 16 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. 17 */ 18 19 #ifndef KISSHAREDTHREADPOOLADAPTER_H 20 #define KISSHAREDTHREADPOOLADAPTER_H 21 22 #include <QMutex> 23 #include <QWaitCondition> 24 25 #include <KisSharedRunnable.h> 26 27 class QThreadPool; 28 29 class KRITAGLOBAL_EXPORT KisSharedThreadPoolAdapter 30 { 31 public: 32 KisSharedThreadPoolAdapter(QThreadPool *parentPool); 33 ~KisSharedThreadPoolAdapter(); 34 35 void start(KisSharedRunnable *runnable, int priority = 0); 36 bool tryStart(KisSharedRunnable *runnable); 37 38 bool waitForDone(int msecs = -1); 39 40 private: 41 friend class KisSharedRunnable; 42 void notifyJobCompleted(); 43 44 KisSharedThreadPoolAdapter(KisSharedThreadPoolAdapter &rhs) = delete; 45 46 private: 47 QThreadPool *m_parentPool; 48 QMutex m_mutex; 49 QWaitCondition m_waitCondition; 50 int m_numRunningJobs; 51 }; 52 53 #endif // KISSHAREDTHREADPOOLADAPTER_H 54