diff options
Diffstat (limited to 'src/kernel/qobject.cpp')
| -rw-r--r-- | src/kernel/qobject.cpp | 36 |
1 files changed, 30 insertions, 6 deletions
diff --git a/src/kernel/qobject.cpp b/src/kernel/qobject.cpp index 20973c5..a3f4f18 100644 --- a/src/kernel/qobject.cpp +++ b/src/kernel/qobject.cpp @@ -66,9 +66,14 @@ class QObjectPrivate { { public: #ifndef QT_NO_USERDATA - QObjectPrivate( uint s ) : QPtrVector<QObjectUserData>(s){ setAutoDelete( TRUE ); } + QObjectPrivate( uint s ) : QPtrVector<QObjectUserData>(s) { + ownThread = NULL; + disableThreadPostedEvents = false; + setAutoDelete( TRUE ); + } #endif QThread* ownThread; + bool disableThreadPostedEvents; }; #if defined(QT_THREAD_SUPPORT) @@ -151,6 +156,25 @@ void QObject::moveToThread(QThread *targetThread) setThreadObject_helper(targetThread); } +/*! + Changes the way cross thread signals are handled + If disable is FALSE, signals emitted from one thread will be + posted to any other connected threads' event loops (default). + + If disable is TRUE, calls to emit from one thread + will immediately execute slots in another thread. + This mode of operation is inherently unsafe and is provided + solely to support thread management by a third party application. + */ +void QObject::disableThreadPostedEvents(bool disable) { + if ( !d ) { + d = new QObjectPrivate(0); + } + + d->ownThread = QThread::currentThreadObject(); + d->disableThreadPostedEvents = disable; +} + #endif class QSenderObjectList : public QObjectList, public QShared @@ -957,7 +981,7 @@ bool QObject::event( QEvent *e ) { QMetaCallEvent* metaEvent = dynamic_cast<QMetaCallEvent*>(e); if (metaEvent) { - if (d->ownThread == QThread::currentThreadObject()) { + if ((d->disableThreadPostedEvents) || (d->ownThread == QThread::currentThreadObject())) { QSenderObjectList* sol; QObject* oldSender = 0; sol = senderObjects; @@ -2592,7 +2616,7 @@ void QObject::activate_signal( QConnectionList *clist, QUObject *o ) sol->currentSender = this; } if ( c->memberType() == QSIGNAL_CODE ) { - if (object->d->ownThread == currentThread) { + if ((d->disableThreadPostedEvents) || (object->d->ownThread == currentThread)) { object->qt_emit( c->member(), o ); } else { @@ -2602,7 +2626,7 @@ void QObject::activate_signal( QConnectionList *clist, QUObject *o ) } } else { - if (object->d->ownThread == currentThread) { + if ((d->disableThreadPostedEvents) || (object->d->ownThread == currentThread)) { object->qt_invoke( c->member(), o ); } else { @@ -2632,7 +2656,7 @@ void QObject::activate_signal( QConnectionList *clist, QUObject *o ) sol->currentSender = this; } if ( c->memberType() == QSIGNAL_CODE ) { - if (object->d->ownThread == currentThread) { + if ((d->disableThreadPostedEvents) || (object->d->ownThread == currentThread)) { object->qt_emit( c->member(), o ); } else { @@ -2642,7 +2666,7 @@ void QObject::activate_signal( QConnectionList *clist, QUObject *o ) } } else { - if (object->d->ownThread == currentThread) { + if ((d->disableThreadPostedEvents) || (object->d->ownThread == currentThread)) { object->qt_invoke( c->member(), o ); } else { |