QThreadPrivate Class Reference

#include <qthread_p.h>

Inheritance diagram for QThreadPrivate:

Public Functions
	QThreadPrivate (QThreadData *d=0)
	~QThreadPrivate ()
Public Functions inherited from QObjectPrivate
void	_q_reregisterTimers (void *pointer)
void	addConnection (int signal, Connection *c)
void	cleanConnectionLists ()
void	connectNotify (const char *signal)
void	deleteChildren ()
void	disconnectNotify (const char *signal)
bool	isSender (const QObject *receiver, const char *signal) const
bool	isSignalConnected (uint signalIdx) const
	Returns true if the signal with index signal_index from object sender is connected. More...
void	moveToThread_helper ()
	QObjectPrivate (int version=QObjectPrivateVersion)
QObjectList	receiverList (const char *signal) const
QObjectList	senderList () const
void	setParent_helper (QObject *)
void	setThreadData_helper (QThreadData *currentData, QThreadData *targetData)
int	signalIndex (const char *signalName) const
	Returns the signal index used in the internal connectionLists vector. More...
virtual	~QObjectPrivate ()
Public Functions inherited from QObjectData
virtual	~QObjectData ()=0

Static Public Functions
static void	createEventDispatcher (QThreadData *data)
static void	finish (void *)
static void	finish (void *, bool lockAnyway=true)
static void *	start (void *arg)
static unsigned int __stdcall	start (void *)
static QThread *	threadForId (int id)
Static Public Functions inherited from QObjectPrivate
static void	clearGuards (QObject *)
static QObjectPrivate *	get (QObject *o)
static void	resetCurrentSender (QObject *receiver, Sender *currentSender, Sender *previousSender)
static Sender *	setCurrentSender (QObject *receiver, Sender *sender)
static void	signalSignature (const QMetaMethod &signal, QVarLengthArray< char > *result)

Public Variables
QThreadData *	data
bool	exited
bool	finished
HANDLE	handle
unsigned int	id
bool	isInFinish
QMutex	mutex
QThread::Priority	priority
int	returnCode
bool	running
uint	stackSize
bool	terminated
bool	terminatePending
bool	terminationEnabled
QWaitCondition	thread_done
pthread_t	thread_id
int	waiters
Public Variables inherited from QObjectPrivate
union {
QObject *   currentChildBeingDeleted
QAbstractDeclarativeData *   declarativeData
};
quint32	connectedSignals [2]
QObjectConnectionListVector *	connectionLists
Sender *	currentSender
QList< QPointer< QObject > >	eventFilters
ExtraData *	extraData
QString	objectName
Connection *	senders
QAtomicPointer< QtSharedPointer::ExternalRefCountData >	sharedRefcount
QThreadData *	threadData
void *	unused
Public Variables inherited from QObjectData
uint	blockSig: 1
QObjectList	children
uint	hasGuards: 1
uint	inEventHandler: 1
uint	inThreadChangeEvent: 1
uint	isWidget: 1
QMetaObject *	metaObject
uint	ownObjectName: 1
QObject *	parent
uint	pendTimer: 1
int	postedEvents
QObject *	q_ptr
uint	receiveChildEvents: 1
uint	sendChildEvents: 1
uint	unused: 22
uint	wasDeleted: 1

Additional Inherited Members
Public Types inherited from QObjectPrivate
typedef void(*	StaticMetaCallFunction) (QObject *, QMetaObject::Call, int, void **)

Detailed Description

Definition at line 137 of file qthread_p.h.

Constructors and Destructors

QThreadPrivate()

QThreadPrivate::QThreadPrivate

(

QThreadData *

d = 0

)

Definition at line 173 of file qthread.cpp.

    : QObjectPrivate(), running(false), finished(false), terminated(false),
      isInFinish(false), exited(false), returnCode(-1),
      stackSize(0), priority(QThread::InheritPriority), data(d)
{
#if defined (Q_OS_UNIX)
    thread_id = 0;
#elif defined (Q_WS_WIN)
    handle = 0;
    id = 0;
    waiters = 0;
#endif
#if defined (Q_WS_WIN) || defined (Q_OS_SYMBIAN)
    terminationEnabled = true;
    terminatePending = false;
#endif

    if (!data)
        data = new QThreadData;
}

~QThreadPrivate()

QThreadPrivate::~QThreadPrivate

(

)

Definition at line 194 of file qthread.cpp.

{
    data->deref();
}

Functions

createEventDispatcher()

void QThreadPrivate::createEventDispatcher ( QThreadData *  data )

static

Definition at line 274 of file qthread_unix.cpp.

Referenced by QEventLoop::QEventLoop(), and qt_adopted_thread_watcher_function().

{
#if defined(Q_OS_BLACKBERRY)
    data->eventDispatcher = new QEventDispatcherBlackberry;
#else
#if !defined(QT_NO_GLIB)
    if (qgetenv("QT_NO_GLIB").isEmpty()
        && qgetenv("QT_NO_THREADED_GLIB").isEmpty()
        && QEventDispatcherGlib::versionSupported())
        data->eventDispatcher = new QEventDispatcherGlib;
    else
#endif
    data->eventDispatcher = new QEventDispatcherUNIX;
#endif

    data->eventDispatcher->startingUp();
}

finish() [1/2]

void QThreadPrivate::finish ( void *  arg )

static

Definition at line 356 of file qthread_unix.cpp.

Referenced by destroy_current_thread_data(), finish(), qt_adopted_thread_watcher_function(), and start().

{
    QThread *thr = reinterpret_cast<QThread *>(arg);
    QThreadPrivate *d = thr->d_func();

    QMutexLocker locker(&d->mutex);

    d->isInFinish = true;
    d->priority = QThread::InheritPriority;
    bool terminated = d->terminated;
    void *data = &d->data->tls;
    locker.unlock();
    if (terminated)
        emit thr->terminated();
    emit thr->finished();
    QCoreApplication::sendPostedEvents(0, QEvent::DeferredDelete);
    QThreadStorageData::finish((void **)data);
    locker.relock();
    d->terminated = false;

    QAbstractEventDispatcher *eventDispatcher = d->data->eventDispatcher;
    if (eventDispatcher) {
        d->data->eventDispatcher = 0;
        locker.unlock();
        eventDispatcher->closingDown();
        delete eventDispatcher;
        locker.relock();
    }

    d->thread_id = 0;
    d->running = false;
    d->finished = true;

    d->isInFinish = false;
    d->thread_done.wakeAll();
}

finish() [2/2]

void QThreadPrivate::finish ( void *  arg, bool  lockAnyway = true  )

static

Definition at line 367 of file qthread_win.cpp.

{
    QThread *thr = reinterpret_cast<QThread *>(arg);
    QThreadPrivate *d = thr->d_func();

    QMutexLocker locker(lockAnyway ? &d->mutex : 0);
    d->isInFinish = true;
    d->priority = QThread::InheritPriority;
    bool terminated = d->terminated;
    void **tls_data = reinterpret_cast<void **>(&d->data->tls);
    locker.unlock();
    if (terminated)
        emit thr->terminated();
    emit thr->finished();
    QCoreApplication::sendPostedEvents(0, QEvent::DeferredDelete);
    QThreadStorageData::finish(tls_data);
    locker.relock();

    d->terminated = false;

    QAbstractEventDispatcher *eventDispatcher = d->data->eventDispatcher;
    if (eventDispatcher) {
        d->data->eventDispatcher = 0;
        locker.unlock();
        eventDispatcher->closingDown();
        delete eventDispatcher;
        locker.relock();
    }

    d->running = false;
    d->finished = true;
    d->isInFinish = false;

    if (!d->waiters) {
        CloseHandle(d->handle);
        d->handle = 0;
    }

    d->id = 0;

}

start() [1/2]

unsigned int __stdcall QT_ENSURE_STACK_ALIGNED_FOR_SSE QThreadPrivate::start ( void *  arg )

static

Definition at line 310 of file qthread_unix.cpp.

Referenced by finish(), qt_adopted_thread_watcher_function(), and QThread::start().

{
    pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, NULL);
    pthread_cleanup_push(QThreadPrivate::finish, arg);

    QThread *thr = reinterpret_cast<QThread *>(arg);
    QThreadData *data = QThreadData::get2(thr);

    // do we need to reset the thread priority?
    if (int(thr->d_func()->priority) & ThreadPriorityResetFlag) {
        thr->setPriority(QThread::Priority(thr->d_func()->priority & ~ThreadPriorityResetFlag));
    }

    data->threadId = (Qt::HANDLE)pthread_self();
    set_thread_data(data);

    data->ref();
    {
        QMutexLocker locker(&thr->d_func()->mutex);
        data->quitNow = thr->d_func()->exited;
    }

    // ### TODO: allow the user to create a custom event dispatcher
    createEventDispatcher(data);

#if (defined(Q_OS_LINUX) || (defined(Q_OS_MAC) && MAC_OS_X_VERSION_MAX_ALLOWED >= MAC_OS_X_VERSION_10_6) || defined(Q_OS_QNX))
    // sets the name of the current thread.
    QString objectName = thr->objectName();

    if (Q_LIKELY(objectName.isEmpty()))
        setCurrentThreadName(thr->d_func()->thread_id, thr->metaObject()->className());
    else
        setCurrentThreadName(thr->d_func()->thread_id, objectName.toLocal8Bit());

#endif

    emit thr->started();
    pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL);
    pthread_testcancel();
    thr->run();

    pthread_cleanup_pop(1);

    return 0;
}

start() [2/2]

static unsigned int __stdcall QThreadPrivate::start ( void *  )

static

threadForId()

static QThread* QThreadPrivate::threadForId ( int  id )

static

Properties

data

QThreadData* QThreadPrivate::data

Definition at line 185 of file qthread_p.h.

Referenced by QThread::currentThread(), finish(), QThreadPrivate(), and ~QThreadPrivate().

exited

bool QThreadPrivate::exited

Definition at line 152 of file qthread_p.h.

finished

bool QThreadPrivate::finished

Definition at line 148 of file qthread_p.h.

Referenced by destroy_current_thread_data(), finish(), and qt_adopted_thread_watcher_function().

handle

HANDLE QThreadPrivate::handle

Definition at line 174 of file qthread_p.h.

Referenced by finish(), and QThreadPrivate().

id

unsigned int QThreadPrivate::id

Definition at line 175 of file qthread_p.h.

Referenced by finish().

isInFinish

bool QThreadPrivate::isInFinish

Definition at line 150 of file qthread_p.h.

Referenced by finish().

mutex

QMutex QThreadPrivate::mutex

mutable

Definition at line 145 of file qthread_p.h.

Referenced by finish().

priority

QThread::Priority QThreadPrivate::priority

Definition at line 156 of file qthread_p.h.

Referenced by finish().

returnCode

int QThreadPrivate::returnCode

Definition at line 153 of file qthread_p.h.

running

bool QThreadPrivate::running

Definition at line 147 of file qthread_p.h.

Referenced by finish().

stackSize

uint QThreadPrivate::stackSize

Definition at line 155 of file qthread_p.h.

terminated

bool QThreadPrivate::terminated

Definition at line 149 of file qthread_p.h.

Referenced by finish().

terminatePending

bool QThreadPrivate::terminatePending

Definition at line 183 of file qthread_p.h.

Referenced by finish(), and QThreadPrivate().

terminationEnabled

bool QThreadPrivate::terminationEnabled

Definition at line 183 of file qthread_p.h.

Referenced by finish(), and QThreadPrivate().

thread_done

QWaitCondition QThreadPrivate::thread_done

Definition at line 162 of file qthread_p.h.

Referenced by finish().

thread_id

pthread_t QThreadPrivate::thread_id

Definition at line 161 of file qthread_p.h.

Referenced by finish(), and QThreadPrivate().

waiters

int QThreadPrivate::waiters

Definition at line 176 of file qthread_p.h.

Referenced by finish(), and QThreadPrivate().

---

The documentation for this class was generated from the following files:

• /src/corelib/thread/qthread_p.h
• /src/corelib/thread/qthread.cpp
• /src/corelib/thread/qthread_unix.cpp
• /src/corelib/thread/qthread_win.cpp