QThread Class Reference

#include <qthread.h>

Inheritance diagram for QThread:

Public Member Functions
	QThread ()
virtual	~QThread ()
bool	isFinished () const
bool	isRunning () const
void	start ()
void	terminate ()
void	wait ()
void	setStackSize (unsigned int stackSize)
unsigned int	stackSize () const

Static Public Member Functions
static int	idealThreadCount ()

Protected Member Functions
virtual void	started ()
virtual void	finished ()
virtual void	terminated ()
virtual void	run ()

Private Attributes
QThreadPrivate *	d

Friends
class	QThreadPrivate

Detailed Description

Definition at line 47 of file qthread.h.

Constructor & Destructor Documentation

QThread::QThread ( )

explicit

Definition at line 45 of file qthread.cpp.

    : d(new QThreadPrivate)
{
}

QThread::~QThread ( )

virtual

Definition at line 50 of file qthread.cpp.

{
   QMutexLocker locker(&d->mutex);
   if (d->running && !d->finished)
      qWarning("QThread: Destroyed while thread is still running");
   delete d;
}

Member Function Documentation

virtual void QThread::finished ( )

inlineprotectedvirtual

Definition at line 66 of file qthread.h.

{}

int QThread::idealThreadCount ( )

static

Definition at line 193 of file qthread_unix.cpp.

{
    int cores = -1;
#if defined(_OS_MAC_)
    // Mac OS X
    cores = (int)MPProcessorsScheduled();
#elif defined(_OS_HPUX_)
    // HP-UX
    struct pst_dynamic psd;
    if (pstat_getdynamic(&psd, sizeof(psd), 1, 0) == -1) 
    {
      perror("pstat_getdynamic");
      cores = -1;
    } 
    else 
    {
      cores = (int)psd.psd_proc_cnt;
    }
#elif defined(_OS_BSDI_)
    // FreeBSD, OpenBSD, NetBSD, BSD/OS
    size_t len = sizeof(cores);
    int mib[2];
    mib[0] = CTL_HW;
    mib[1] = HW_NCPU;

    if (sysctl(mib, 2, &cores, &len, NULL, 0) != 0) 
    {
      perror("sysctl");
      cores = -1;
    }
#elif defined(_OS_IRIX_)
    // IRIX
    cores = (int)sysconf(_SC_NPROC_ONLN);
#else
    // the rest: Linux, Solaris, AIX, Tru64
    cores = (int)sysconf(_SC_NPROCESSORS_ONLN);
#endif
    return cores;  
}

bool QThread::isFinished

(

)

const

Definition at line 58 of file qthread.cpp.

{
    QMutexLocker locker(&d->mutex);
    return d->finished;
}

bool QThread::isRunning

(

)

const

Definition at line 64 of file qthread.cpp.

{
    QMutexLocker locker(&d->mutex);
    return d->running;
}

virtual void QThread::run ( )

inlineprotectedvirtual

Reimplemented in DotWorkerThread.

Definition at line 70 of file qthread.h.

{}

void QThread::setStackSize

(

unsigned int

stackSize

)

Definition at line 70 of file qthread.cpp.

{
  QMutexLocker locker(&d->mutex);
  if (d->running)
  {
    qWarning("QThread: Cannot change stack size while thread is running!");
    return;
  }
  d->stackSize = stackSize;
}

unsigned int QThread::stackSize

(

)

const

Definition at line 81 of file qthread.cpp.

{
  QMutexLocker locker(&d->mutex);
  return d->stackSize;
}

void QThread::start

(

)

Definition at line 117 of file qthread_unix.cpp.

{
    QMutexLocker locker(&d->mutex);
    if (d->running) return;

    // Block the SIGINT signal. The threads will inherit the signal mask.
    // This will avoid them catching SIGINT instead of this thread.
    sigset_t sigset, oldset;
    sigemptyset(&sigset);
    sigaddset(&sigset, SIGINT);
    pthread_sigmask(SIG_BLOCK, &sigset, &oldset);

    d->running = TRUE;
    d->finished = FALSE;

    pthread_attr_t attr;
    pthread_attr_init(&attr);
    pthread_attr_setdetachstate(&attr,PTHREAD_CREATE_DETACHED);
    pthread_attr_setinheritsched(&attr, PTHREAD_INHERIT_SCHED);
    if (d->stackSize>0)
    {
#if defined(_POSIX_THREAD_ATTR_STACKSIZE) && (_POSIX_THREAD_ATTR_STACKSIZE-0>0)
      pthread_attr_setstacksize(&attr,d->stackSize);
#endif
    }
    int code = pthread_create(&d->thread_id, &attr, QThreadPrivate::start, this);
    pthread_attr_destroy(&attr);

    if (code)
    {
        qWarning("QThread::start: Thread creation error: %d", code);

        d->running = FALSE;
        d->finished = FALSE;
        d->thread_id = 0;
    }
    else
    {
       // Restore the old signal mask only for this thread.
       pthread_sigmask(SIG_SETMASK, &oldset, NULL);
    }
}

virtual void QThread::started ( )

inlineprotectedvirtual

Definition at line 65 of file qthread.h.

{}

void QThread::terminate

(

)

Definition at line 160 of file qthread_unix.cpp.

{
    QMutexLocker locker(&d->mutex);

    if (!d->thread_id) return;

    int code = pthread_cancel(d->thread_id);
    if (code)
    {
        qWarning("QThread::start: Thread termination error: %d", code);
    }
    else
    {
        d->terminated = TRUE;
    }
}

virtual void QThread::terminated ( )

inlineprotectedvirtual

Definition at line 67 of file qthread.h.

{}

void QThread::wait

(

)

Definition at line 177 of file qthread_unix.cpp.

{
    QMutexLocker locker(&d->mutex);
    if (d->finished || !d->running) return;

    while (d->running)
    {
      d->thread_done.wait(locker.mutex());
    }
}

Friends And Related Function Documentation

friend class QThreadPrivate

friend

Definition at line 74 of file qthread.h.

Member Data Documentation

QThreadPrivate* QThread::d

private

Definition at line 73 of file qthread.h.

---

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

• doxygen-1.8.11/qtools/qthread.h
• doxygen-1.8.11/qtools/qthread.cpp
• doxygen-1.8.11/qtools/qthread_unix.cpp
• doxygen-1.8.11/qtools/qthread_win32.cpp