Thread::CondVar Class Reference

#include <Thread.h>

Public Member Functions
	CondVar ()
	~CondVar ()
void	signal ()
bool	wait (Mutex &_mutex, unsigned int _milliseconds=INFINITE)
bool	isWaiting ()

Detailed Description

CondVar: Conditional Variable Windows Note. Major Version >= 6, Vista, 2008 See. InitializeCondVaritionVariable

Definition at line 337 of file Thread.h.

Constructor & Destructor Documentation

CondVar()

Thread::CondVar::CondVar

(

)

Definition at line 579 of file Thread.cpp.

{
    __bWaiting = false;
#if __DCL_PTHREAD
    __DCL_VERIFY(pthread_cond_init(&__cond, NULL) == 0);
#elif __DCL_WINDOWS && _WIN32_WINNT >= 0x0600
    // Windows Vista, Windows Server 2008
    __DCL_ASSERT(IsWindowsVistaOrGreater());
    InitializeConditionVariable(&__cond);
#endif
 
}

~CondVar()

Thread::CondVar::~CondVar

(

)

Definition at line 592 of file Thread.cpp.

{
#if __DCL_PTHREAD
    __DCL_VERIFY(pthread_cond_destroy(&__cond) == 0);
#endif
}

Member Function Documentation

isWaiting()

bool Thread::CondVar::isWaiting ( )

inline

Definition at line 367 of file Thread.h.

{ return __bWaiting; }

signal()

void Thread::CondVar::signal

(

)

Definition at line 599 of file Thread.cpp.

{
#if __DCL_PTHREAD
    __DCL_VERIFY(pthread_cond_signal(&__cond) == 0);
#elif __DCL_WINDOWS
    #if _WIN32_WINNT >= 0x0600
    WakeConditionVariable(&__cond);
    #else
    __cond.set();
    #endif
#endif
}

wait()

bool Thread::CondVar::wait	(	Mutex &	_mutex,
		unsigned int	_milliseconds = INFINITE )

Returns

false는 timed-out Windows: GetLastError() == ERROR_TIMEOUT UNIX: errno == ETIMEDOUT

Definition at line 623 of file Thread.cpp.

{
    bool r = true;
    __bWaiting = true;
#if __DCL_PTHREAD
    // INFINITE == -1
    if (_milliseconds == (unsigned int) INFINITE) {
        __DCL_VERIFY(pthread_cond_wait(&__cond, (pthread_mutex_t*)&_mutex) == 0);
        r = true;
    }
    else {
        // millisoconds 1/1000
        // microseconds 1/1000000
        // nanoseconds  1/1000000000
        struct timeval tv;
        struct timezone tz;
        struct timespec ts;
        __DCL_VERIFY(gettimeofday(&tv, &tz) == 0);
        ts.tv_sec = tv.tv_sec + (_milliseconds / 1000);
        ts.tv_nsec = (tv.tv_usec * 1000) + ((_milliseconds % 1000) * 1000000);
        int n = pthread_cond_timedwait(&__cond, (pthread_mutex_t*)&_mutex, &ts);
        if (n != 0)
        {
            r = false;
            __DCL_ASSERT(n == ETIMEDOUT);
            errno = n;
        }
    }
#elif __DCL_WINDOWS
    #if _WIN32_WINNT >= 0x0600
    if (!SleepConditionVariableCS(&__cond,
            (CRITICAL_SECTION*)&_mutex, _milliseconds)) {
        r = false;
        __DCL_ASSERT(GetLastError() == ERROR_TIMEOUT);
    }
    #else
    _mutex.unlock();
    r = __cond.wait(INFINITE);
    _mutex.lock();
    if (r)
        __cond.reset();
    #endif
#endif
 
    __bWaiting = false;
    return r;
}

---

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

• Thread.h
• Thread.cpp