| /**************************************************************************** |
| ** |
| ** Copyright (C) 2016 The Qt Company Ltd. |
| ** Copyright (C) 2016 Intel Corporation. |
| ** Contact: https://www.qt.io/licensing/ |
| ** |
| ** This file is part of the QtCore module of the Qt Toolkit. |
| ** |
| ** $QT_BEGIN_LICENSE:LGPL$ |
| ** Commercial License Usage |
| ** Licensees holding valid commercial Qt licenses may use this file in |
| ** accordance with the commercial license agreement provided with the |
| ** Software or, alternatively, in accordance with the terms contained in |
| ** a written agreement between you and The Qt Company. For licensing terms |
| ** and conditions see https://www.qt.io/terms-conditions. For further |
| ** information use the contact form at https://www.qt.io/contact-us. |
| ** |
| ** GNU Lesser General Public License Usage |
| ** Alternatively, this file may be used under the terms of the GNU Lesser |
| ** General Public License version 3 as published by the Free Software |
| ** Foundation and appearing in the file LICENSE.LGPL3 included in the |
| ** packaging of this file. Please review the following information to |
| ** ensure the GNU Lesser General Public License version 3 requirements |
| ** will be met: https://www.gnu.org/licenses/lgpl-3.0.html. |
| ** |
| ** GNU General Public License Usage |
| ** Alternatively, this file may be used under the terms of the GNU |
| ** General Public License version 2.0 or (at your option) the GNU General |
| ** Public license version 3 or any later version approved by the KDE Free |
| ** Qt Foundation. The licenses are as published by the Free Software |
| ** Foundation and appearing in the file LICENSE.GPL2 and LICENSE.GPL3 |
| ** included in the packaging of this file. Please review the following |
| ** information to ensure the GNU General Public License requirements will |
| ** be met: https://www.gnu.org/licenses/gpl-2.0.html and |
| ** https://www.gnu.org/licenses/gpl-3.0.html. |
| ** |
| ** $QT_END_LICENSE$ |
| ** |
| ****************************************************************************/ |
| |
| #ifndef QTHREAD_P_H |
| #define QTHREAD_P_H |
| |
| // |
| // W A R N I N G |
| // ------------- |
| // |
| // This file is not part of the Qt API. It exists purely as an |
| // implementation detail. This header file may change from version to |
| // version without notice, or even be removed. |
| // |
| // We mean it. |
| // |
| // |
| |
| #include "qplatformdefs.h" |
| #include "QtCore/qthread.h" |
| #include "QtCore/qmutex.h" |
| #include "QtCore/qstack.h" |
| #if QT_CONFIG(thread) |
| #include "QtCore/qwaitcondition.h" |
| #endif |
| #include "QtCore/qmap.h" |
| #include "QtCore/qcoreapplication.h" |
| #include "private/qobject_p.h" |
| |
| #include <algorithm> |
| #include <atomic> |
| |
| #ifdef Q_OS_WINRT |
| namespace ABI { |
| namespace Windows { |
| namespace Foundation { |
| struct IAsyncAction; |
| } |
| } |
| } |
| #endif // Q_OS_WINRT |
| |
| QT_BEGIN_NAMESPACE |
| |
| class QAbstractEventDispatcher; |
| class QEventLoop; |
| |
| class QPostEvent |
| { |
| public: |
| QObject *receiver; |
| QEvent *event; |
| int priority; |
| inline QPostEvent() |
| : receiver(nullptr), event(nullptr), priority(0) |
| { } |
| inline QPostEvent(QObject *r, QEvent *e, int p) |
| : receiver(r), event(e), priority(p) |
| { } |
| }; |
| Q_DECLARE_TYPEINFO(QPostEvent, Q_MOVABLE_TYPE); |
| |
| inline bool operator<(const QPostEvent &first, const QPostEvent &second) |
| { |
| return first.priority > second.priority; |
| } |
| |
| // This class holds the list of posted events. |
| // The list has to be kept sorted by priority |
| class QPostEventList : public QVector<QPostEvent> |
| { |
| public: |
| // recursion == recursion count for sendPostedEvents() |
| int recursion; |
| |
| // sendOffset == the current event to start sending |
| int startOffset; |
| // insertionOffset == set by sendPostedEvents to tell postEvent() where to start insertions |
| int insertionOffset; |
| |
| QMutex mutex; |
| |
| inline QPostEventList() |
| : QVector<QPostEvent>(), recursion(0), startOffset(0), insertionOffset(0) |
| { } |
| |
| void addEvent(const QPostEvent &ev) { |
| int priority = ev.priority; |
| if (isEmpty() || |
| constLast().priority >= priority || |
| insertionOffset >= size()) { |
| // optimization: we can simply append if the last event in |
| // the queue has higher or equal priority |
| append(ev); |
| } else { |
| // insert event in descending priority order, using upper |
| // bound for a given priority (to ensure proper ordering |
| // of events with the same priority) |
| QPostEventList::iterator at = std::upper_bound(begin() + insertionOffset, end(), ev); |
| insert(at, ev); |
| } |
| } |
| private: |
| //hides because they do not keep that list sorted. addEvent must be used |
| using QVector<QPostEvent>::append; |
| using QVector<QPostEvent>::insert; |
| }; |
| |
| #if QT_CONFIG(thread) |
| |
| class Q_CORE_EXPORT QDaemonThread : public QThread |
| { |
| public: |
| QDaemonThread(QObject *parent = nullptr); |
| ~QDaemonThread(); |
| }; |
| |
| class QThreadPrivate : public QObjectPrivate |
| { |
| Q_DECLARE_PUBLIC(QThread) |
| |
| public: |
| QThreadPrivate(QThreadData *d = nullptr); |
| ~QThreadPrivate(); |
| |
| void setPriority(QThread::Priority prio); |
| |
| mutable QMutex mutex; |
| QAtomicInt quitLockRef; |
| |
| bool running; |
| bool finished; |
| bool isInFinish; //when in QThreadPrivate::finish |
| std::atomic<bool> interruptionRequested; |
| |
| bool exited; |
| int returnCode; |
| |
| uint stackSize; |
| QThread::Priority priority; |
| |
| static QThread *threadForId(int id); |
| |
| #ifdef Q_OS_UNIX |
| QWaitCondition thread_done; |
| |
| static void *start(void *arg); |
| static void finish(void *); |
| |
| #endif // Q_OS_UNIX |
| |
| #ifdef Q_OS_WIN |
| static unsigned int __stdcall start(void *) noexcept; |
| static void finish(void *, bool lockAnyway=true) noexcept; |
| |
| Qt::HANDLE handle; |
| unsigned int id; |
| int waiters; |
| bool terminationEnabled, terminatePending; |
| #endif // Q_OS_WIN |
| #ifdef Q_OS_WASM |
| static int idealThreadCount; |
| #endif |
| QThreadData *data; |
| |
| static QAbstractEventDispatcher *createEventDispatcher(QThreadData *data); |
| |
| void ref() |
| { |
| quitLockRef.ref(); |
| } |
| |
| void deref() |
| { |
| if (!quitLockRef.deref() && running) { |
| QCoreApplication::instance()->postEvent(q_ptr, new QEvent(QEvent::Quit)); |
| } |
| } |
| }; |
| |
| #else // QT_CONFIG(thread) |
| |
| class QThreadPrivate : public QObjectPrivate |
| { |
| public: |
| QThreadPrivate(QThreadData *d = 0); |
| ~QThreadPrivate(); |
| |
| mutable QMutex mutex; |
| QThreadData *data; |
| bool running = false; |
| |
| static void setCurrentThread(QThread*) {} |
| static QThread *threadForId(int) { return QThread::currentThread(); } |
| static QAbstractEventDispatcher *createEventDispatcher(QThreadData *data); |
| |
| void ref() {} |
| void deref() {} |
| |
| Q_DECLARE_PUBLIC(QThread) |
| }; |
| |
| #endif // QT_CONFIG(thread) |
| |
| class QThreadData |
| { |
| public: |
| QThreadData(int initialRefCount = 1); |
| ~QThreadData(); |
| |
| static Q_AUTOTEST_EXPORT QThreadData *current(bool createIfNecessary = true); |
| #ifdef Q_OS_WINRT |
| static void setMainThread(); |
| #endif |
| static void clearCurrentThreadData(); |
| static QThreadData *get2(QThread *thread) |
| { Q_ASSERT_X(thread != nullptr, "QThread", "internal error"); return thread->d_func()->data; } |
| |
| |
| void ref(); |
| void deref(); |
| inline bool hasEventDispatcher() const |
| { return eventDispatcher.loadRelaxed() != nullptr; } |
| QAbstractEventDispatcher *createEventDispatcher(); |
| QAbstractEventDispatcher *ensureEventDispatcher() |
| { |
| QAbstractEventDispatcher *ed = eventDispatcher.loadRelaxed(); |
| if (Q_LIKELY(ed)) |
| return ed; |
| return createEventDispatcher(); |
| } |
| |
| bool canWaitLocked() |
| { |
| QMutexLocker locker(&postEventList.mutex); |
| return canWait; |
| } |
| |
| // This class provides per-thread (by way of being a QThreadData |
| // member) storage for qFlagLocation() |
| class FlaggedDebugSignatures |
| { |
| static const uint Count = 2; |
| |
| uint idx; |
| const char* locations[Count]; |
| |
| public: |
| FlaggedDebugSignatures() : idx(0) |
| { std::fill_n(locations, Count, static_cast<char*>(nullptr)); } |
| |
| void store(const char* method) |
| { locations[idx++ % Count] = method; } |
| |
| bool contains(const char *method) const |
| { return std::find(locations, locations + Count, method) != locations + Count; } |
| }; |
| |
| private: |
| QAtomicInt _ref; |
| |
| public: |
| int loopLevel; |
| int scopeLevel; |
| |
| QStack<QEventLoop *> eventLoops; |
| QPostEventList postEventList; |
| QAtomicPointer<QThread> thread; |
| QAtomicPointer<void> threadId; |
| QAtomicPointer<QAbstractEventDispatcher> eventDispatcher; |
| QVector<void *> tls; |
| FlaggedDebugSignatures flaggedSignatures; |
| |
| bool quitNow; |
| bool canWait; |
| bool isAdopted; |
| bool requiresCoreApplication; |
| }; |
| |
| class QScopedScopeLevelCounter |
| { |
| QThreadData *threadData; |
| public: |
| inline QScopedScopeLevelCounter(QThreadData *threadData) |
| : threadData(threadData) |
| { ++threadData->scopeLevel; } |
| inline ~QScopedScopeLevelCounter() |
| { --threadData->scopeLevel; } |
| }; |
| |
| // thread wrapper for the main() thread |
| class QAdoptedThread : public QThread |
| { |
| Q_DECLARE_PRIVATE(QThread) |
| |
| public: |
| QAdoptedThread(QThreadData *data = nullptr); |
| ~QAdoptedThread(); |
| void init(); |
| |
| private: |
| #if QT_CONFIG(thread) |
| void run() override; |
| #endif |
| }; |
| |
| QT_END_NAMESPACE |
| |
| #endif // QTHREAD_P_H |