projects/ldc: druntime/src/common/core/sync/condition.d annotate

author	Robert Clipsham <robert@octarineparrot.com>
date	Tue, 02 Jun 2009 17:43:06 +0100
parents
children

rev	line source
1458 e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	1 /**
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	2 * The condition module provides a primitive for synchronized condition
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	3 * checking.
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	4 *
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	5 * Copyright: Copyright Sean Kelly 2005 - 2009.
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	6 * License: <a href="http://www.boost.org/LICENSE_1_0.txt>Boost License 1.0</a>.
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	7 * Authors: Sean Kelly
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	8 *
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	9 * Copyright Sean Kelly 2005 - 2009.
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	10 * Distributed under the Boost Software License, Version 1.0.
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	11 * (See accompanying file LICENSE_1_0.txt or copy at
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	12 * http://www.boost.org/LICENSE_1_0.txt)
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	13 */
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	14 module core.sync.condition;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	15
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	16
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	17 public import core.sync.exception;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	18 public import core.sync.mutex;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	19
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	20 version( Win32 )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	21 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	22 private import core.sync.semaphore;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	23 private import core.sys.windows.windows;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	24 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	25 else version( Posix )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	26 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	27 private import core.sync.config;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	28 private import core.stdc.errno;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	29 private import core.sys.posix.pthread;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	30 private import core.sys.posix.time;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	31 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	32
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	33
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	34 ////////////////////////////////////////////////////////////////////////////////
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	35 // Condition
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	36 //
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	37 // void wait();
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	38 // void notify();
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	39 // void notifyAll();
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	40 ////////////////////////////////////////////////////////////////////////////////
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	41
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	42
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	43 /**
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	44 * This class represents a condition variable as concieved by C.A.R. Hoare. As
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	45 * per Mesa type monitors however, "signal" has been replaced with "notify" to
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	46 * indicate that control is not transferred to the waiter when a notification
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	47 * is sent.
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	48 */
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	49 class Condition
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	50 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	51 ////////////////////////////////////////////////////////////////////////////
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	52 // Initialization
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	53 ////////////////////////////////////////////////////////////////////////////
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	54
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	55
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	56 /**
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	57 * Initializes a condition object which is associated with the supplied
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	58 * mutex object.
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	59 *
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	60 * Params:
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	61 * m = The mutex with which this condition will be associated.
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	62 *
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	63 * Throws:
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	64 * SyncException on error.
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	65 */
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	66 this( Mutex m )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	67 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	68 version( Win32 )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	69 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	70 m_blockLock = CreateSemaphoreA( null, 1, 1, null );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	71 if( m_blockLock == m_blockLock.init )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	72 throw new SyncException( "Unable to initialize condition" );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	73 scope(failure) CloseHandle( m_blockLock );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	74
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	75 m_blockQueue = CreateSemaphoreA( null, 0, int.max, null );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	76 if( m_blockQueue == m_blockQueue.init )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	77 throw new SyncException( "Unable to initialize condition" );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	78 scope(failure) CloseHandle( m_blockQueue );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	79
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	80 InitializeCriticalSection( &m_unblockLock );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	81 m_assocMutex = m;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	82 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	83 else version( Posix )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	84 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	85 m_mutexAddr = m.handleAddr();
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	86
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	87 int rc = pthread_cond_init( &m_hndl, null );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	88 if( rc )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	89 throw new SyncException( "Unable to initialize condition" );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	90 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	91 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	92
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	93
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	94 ~this()
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	95 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	96 version( Win32 )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	97 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	98 BOOL rc = CloseHandle( m_blockLock );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	99 assert( rc, "Unable to destroy condition" );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	100 rc = CloseHandle( m_blockQueue );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	101 assert( rc, "Unable to destroy condition" );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	102 DeleteCriticalSection( &m_unblockLock );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	103 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	104 else version( Posix )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	105 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	106 int rc = pthread_cond_destroy( &m_hndl );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	107 assert( !rc, "Unable to destroy condition" );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	108 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	109 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	110
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	111
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	112 ////////////////////////////////////////////////////////////////////////////
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	113 // General Actions
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	114 ////////////////////////////////////////////////////////////////////////////
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	115
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	116
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	117 /**
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	118 * Wait until notified.
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	119 *
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	120 * Throws:
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	121 * SyncException on error.
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	122 */
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	123 void wait()
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	124 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	125 version( Win32 )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	126 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	127 timedWait( INFINITE );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	128 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	129 else version( Posix )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	130 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	131 int rc = pthread_cond_wait( &m_hndl, m_mutexAddr );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	132 if( rc )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	133 throw new SyncException( "Unable to wait for condition" );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	134 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	135 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	136
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	137
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	138 /**
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	139 * Suspends the calling thread until a notification occurs or until the
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	140 * supplied time period has elapsed.
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	141 *
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	142 * Params:
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	143 * period = The time to wait, in 100 nanosecond intervals. This value may
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	144 * be adjusted to equal to the maximum wait period supported by
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	145 * the target platform if it is too large.
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	146 *
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	147 * In:
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	148 * period must be non-negative.
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	149 *
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	150 * Throws:
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	151 * SyncException on error.
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	152 *
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	153 * Returns:
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	154 * true if notified before the timeout and false if not.
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	155 */
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	156 bool wait( long period )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	157 in
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	158 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	159 assert( period >= 0 );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	160 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	161 body
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	162 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	163 version( Win32 )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	164 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	165 enum : uint
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	166 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	167 TICKS_PER_MILLI = 10_000,
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	168 MAX_WAIT_MILLIS = uint.max - 1
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	169 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	170
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	171 period /= TICKS_PER_MILLI;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	172 if( period > MAX_WAIT_MILLIS )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	173 period = MAX_WAIT_MILLIS;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	174 return timedWait( cast(uint) period );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	175 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	176 else version( Posix )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	177 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	178 timespec t = void;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	179 mktspec( t, period );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	180
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	181 int rc = pthread_cond_timedwait( &m_hndl, m_mutexAddr, &t );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	182 if( !rc )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	183 return true;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	184 if( rc == ETIMEDOUT )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	185 return false;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	186 throw new SyncException( "Unable to wait for condition" );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	187 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	188 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	189
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	190 /**
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	191 * Notifies one waiter.
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	192 *
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	193 * Throws:
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	194 * SyncException on error.
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	195 */
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	196 void notify()
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	197 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	198 version( Win32 )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	199 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	200 notify( false );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	201 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	202 else version( Posix )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	203 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	204 int rc = pthread_cond_signal( &m_hndl );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	205 if( rc )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	206 throw new SyncException( "Unable to notify condition" );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	207 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	208 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	209
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	210
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	211 /**
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	212 * Notifies all waiters.
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	213 *
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	214 * Throws:
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	215 * SyncException on error.
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	216 */
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	217 void notifyAll()
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	218 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	219 version( Win32 )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	220 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	221 notify( true );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	222 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	223 else version( Posix )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	224 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	225 int rc = pthread_cond_broadcast( &m_hndl );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	226 if( rc )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	227 throw new SyncException( "Unable to notify condition" );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	228 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	229 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	230
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	231
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	232 private:
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	233 version( Win32 )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	234 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	235 bool timedWait( DWORD timeout )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	236 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	237 int numSignalsLeft;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	238 int numWaitersGone;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	239 DWORD rc;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	240
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	241 rc = WaitForSingleObject( m_blockLock, INFINITE );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	242 assert( rc == WAIT_OBJECT_0 );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	243
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	244 m_numWaitersBlocked++;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	245
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	246 rc = ReleaseSemaphore( m_blockLock, 1, null );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	247 assert( rc );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	248
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	249 m_assocMutex.unlock();
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	250 scope(failure) m_assocMutex.lock();
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	251
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	252 rc = WaitForSingleObject( m_blockQueue, timeout );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	253 assert( rc == WAIT_OBJECT_0 \|\| rc == WAIT_TIMEOUT );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	254 bool timedOut = (rc == WAIT_TIMEOUT);
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	255
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	256 EnterCriticalSection( &m_unblockLock );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	257 scope(failure) LeaveCriticalSection( &m_unblockLock );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	258
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	259 if( (numSignalsLeft = m_numWaitersToUnblock) != 0 )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	260 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	261 if ( timedOut )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	262 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	263 // timeout (or canceled)
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	264 if( m_numWaitersBlocked != 0 )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	265 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	266 m_numWaitersBlocked--;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	267 // do not unblock next waiter below (already unblocked)
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	268 numSignalsLeft = 0;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	269 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	270 else
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	271 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	272 // spurious wakeup pending!!
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	273 m_numWaitersGone = 1;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	274 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	275 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	276 if( --m_numWaitersToUnblock == 0 )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	277 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	278 if( m_numWaitersBlocked != 0 )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	279 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	280 // open the gate
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	281 rc = ReleaseSemaphore( m_blockLock, 1, null );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	282 assert( rc );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	283 // do not open the gate below again
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	284 numSignalsLeft = 0;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	285 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	286 else if( (numWaitersGone = m_numWaitersGone) != 0 )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	287 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	288 m_numWaitersGone = 0;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	289 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	290 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	291 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	292 else if( ++m_numWaitersGone == int.max / 2 )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	293 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	294 // timeout/canceled or spurious event :-)
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	295 rc = WaitForSingleObject( m_blockLock, INFINITE );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	296 assert( rc == WAIT_OBJECT_0 );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	297 // something is going on here - test of timeouts?
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	298 m_numWaitersBlocked -= m_numWaitersGone;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	299 rc = ReleaseSemaphore( m_blockLock, 1, null );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	300 assert( rc == WAIT_OBJECT_0 );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	301 m_numWaitersGone = 0;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	302 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	303
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	304 LeaveCriticalSection( &m_unblockLock );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	305
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	306 if( numSignalsLeft == 1 )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	307 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	308 // better now than spurious later (same as ResetEvent)
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	309 for( ; numWaitersGone > 0; --numWaitersGone )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	310 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	311 rc = WaitForSingleObject( m_blockQueue, INFINITE );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	312 assert( rc == WAIT_OBJECT_0 );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	313 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	314 // open the gate
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	315 rc = ReleaseSemaphore( m_blockLock, 1, null );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	316 assert( rc );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	317 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	318 else if( numSignalsLeft != 0 )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	319 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	320 // unblock next waiter
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	321 rc = ReleaseSemaphore( m_blockQueue, 1, null );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	322 assert( rc );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	323 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	324 m_assocMutex.lock();
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	325 return !timedOut;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	326 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	327
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	328
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	329 void notify( bool all )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	330 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	331 DWORD rc;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	332
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	333 EnterCriticalSection( &m_unblockLock );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	334 scope(failure) LeaveCriticalSection( &m_unblockLock );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	335
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	336 if( m_numWaitersToUnblock != 0 )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	337 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	338 if( m_numWaitersBlocked == 0 )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	339 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	340 LeaveCriticalSection( &m_unblockLock );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	341 return;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	342 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	343 if( all )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	344 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	345 m_numWaitersToUnblock += m_numWaitersBlocked;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	346 m_numWaitersBlocked = 0;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	347 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	348 else
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	349 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	350 m_numWaitersToUnblock++;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	351 m_numWaitersBlocked--;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	352 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	353 LeaveCriticalSection( &m_unblockLock );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	354 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	355 else if( m_numWaitersBlocked > m_numWaitersGone )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	356 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	357 rc = WaitForSingleObject( m_blockLock, INFINITE );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	358 assert( rc == WAIT_OBJECT_0 );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	359 if( 0 != m_numWaitersGone )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	360 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	361 m_numWaitersBlocked -= m_numWaitersGone;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	362 m_numWaitersGone = 0;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	363 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	364 if( all )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	365 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	366 m_numWaitersToUnblock = m_numWaitersBlocked;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	367 m_numWaitersBlocked = 0;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	368 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	369 else
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	370 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	371 m_numWaitersToUnblock = 1;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	372 m_numWaitersBlocked--;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	373 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	374 LeaveCriticalSection( &m_unblockLock );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	375 rc = ReleaseSemaphore( m_blockQueue, 1, null );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	376 assert( rc );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	377 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	378 else
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	379 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	380 LeaveCriticalSection( &m_unblockLock );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	381 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	382 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	383
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	384
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	385 // NOTE: This implementation uses Algorithm 8c as described here:
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	386 // http://groups.google.com/group/comp.programming.threads/
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	387 // browse_frm/thread/1692bdec8040ba40/e7a5f9d40e86503a
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	388 HANDLE m_blockLock; // auto-reset event (now semaphore)
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	389 HANDLE m_blockQueue; // auto-reset event (now semaphore)
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	390 Mutex m_assocMutex; // external mutex/CS
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	391 CRITICAL_SECTION m_unblockLock; // internal mutex/CS
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	392 int m_numWaitersGone = 0;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	393 int m_numWaitersBlocked = 0;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	394 int m_numWaitersToUnblock = 0;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	395 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	396 else version( Posix )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	397 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	398 pthread_cond_t m_hndl;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	399 pthread_mutex_t* m_mutexAddr;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	400 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	401 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	402
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	403
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	404 ////////////////////////////////////////////////////////////////////////////////
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	405 // Unit Tests
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	406 ////////////////////////////////////////////////////////////////////////////////
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	407
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	408
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	409 version( unittest )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	410 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	411 private import core.thread;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	412 private import core.sync.mutex;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	413 private import core.sync.semaphore;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	414
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	415
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	416 void testNotify()
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	417 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	418 auto mutex = new Mutex;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	419 auto condReady = new Condition( mutex );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	420 auto semDone = new Semaphore;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	421 auto synLoop = new Object;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	422 int numWaiters = 10;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	423 int numTries = 10;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	424 int numReady = 0;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	425 int numTotal = 0;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	426 int numDone = 0;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	427 int numPost = 0;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	428
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	429 void waiter()
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	430 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	431 for( int i = 0; i < numTries; ++i )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	432 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	433 synchronized( mutex )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	434 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	435 while( numReady < 1 )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	436 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	437 condReady.wait();
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	438 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	439 --numReady;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	440 ++numTotal;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	441 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	442
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	443 synchronized( synLoop )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	444 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	445 ++numDone;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	446 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	447 semDone.wait();
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	448 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	449 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	450
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	451 auto group = new ThreadGroup;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	452
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	453 for( int i = 0; i < numWaiters; ++i )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	454 group.create( &waiter );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	455
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	456 for( int i = 0; i < numTries; ++i )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	457 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	458 for( int j = 0; j < numWaiters; ++j )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	459 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	460 synchronized( mutex )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	461 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	462 ++numReady;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	463 condReady.notify();
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	464 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	465 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	466 while( true )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	467 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	468 synchronized( synLoop )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	469 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	470 if( numDone >= numWaiters )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	471 break;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	472 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	473 Thread.yield();
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	474 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	475 for( int j = 0; j < numWaiters; ++j )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	476 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	477 semDone.notify();
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	478 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	479 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	480
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	481 group.joinAll();
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	482 assert( numTotal == numWaiters * numTries );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	483 }
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	484
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	485
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	486 void testNotifyAll()
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	487 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	488 auto mutex = new Mutex;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	489 auto condReady = new Condition( mutex );
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	490 int numWaiters = 10;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	491 int numReady = 0;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	492 int numDone = 0;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	493 bool alert = false;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	494
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	495 void waiter()
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	496 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	497 synchronized( mutex )
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	498 {
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	499 ++numReady;
e0b2d67cfe7c Added druntime (this should be removed once it works). Robert Clipsham <robert@octarineparrot.com> parents: diff changeset	500 while( !alert )

1458

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

1 /**

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

2 * The condition module provides a primitive for synchronized condition

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

3 * checking.

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

4 *

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

5 * Copyright: Copyright Sean Kelly 2005 - 2009.

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

6 * License: <a href="http://www.boost.org/LICENSE_1_0.txt>Boost License 1.0</a>.

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

7 * Authors: Sean Kelly

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

8 *

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

9 * Copyright Sean Kelly 2005 - 2009.

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

10 * Distributed under the Boost Software License, Version 1.0.

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

11 * (See accompanying file LICENSE_1_0.txt or copy at

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

12 * http://www.boost.org/LICENSE_1_0.txt)

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

13 */

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

14 module core.sync.condition;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

15

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

16

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

17 public import core.sync.exception;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

18 public import core.sync.mutex;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

19

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

20 version( Win32 )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

21 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

22 private import core.sync.semaphore;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

23 private import core.sys.windows.windows;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

24 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

25 else version( Posix )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

26 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

27 private import core.sync.config;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

28 private import core.stdc.errno;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

29 private import core.sys.posix.pthread;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

30 private import core.sys.posix.time;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

31 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

32

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

33

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

34 ////////////////////////////////////////////////////////////////////////////////

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

35 // Condition

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

36 //

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

37 // void wait();

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

38 // void notify();

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

39 // void notifyAll();

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

40 ////////////////////////////////////////////////////////////////////////////////

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

41

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

42

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

43 /**

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

44 * This class represents a condition variable as concieved by C.A.R. Hoare. As

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

45 * per Mesa type monitors however, "signal" has been replaced with "notify" to

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

46 * indicate that control is not transferred to the waiter when a notification

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

47 * is sent.

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

48 */

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

49 class Condition

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

50 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

51 ////////////////////////////////////////////////////////////////////////////

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

52 // Initialization

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

53 ////////////////////////////////////////////////////////////////////////////

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

54

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

55

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

56 /**

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

57 * Initializes a condition object which is associated with the supplied

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

58 * mutex object.

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

59 *

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

60 * Params:

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

61 * m = The mutex with which this condition will be associated.

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

62 *

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

63 * Throws:

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

64 * SyncException on error.

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

65 */

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

66 this( Mutex m )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

67 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

68 version( Win32 )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

69 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

70 m_blockLock = CreateSemaphoreA( null, 1, 1, null );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

71 if( m_blockLock == m_blockLock.init )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

72 throw new SyncException( "Unable to initialize condition" );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

73 scope(failure) CloseHandle( m_blockLock );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

74

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

75 m_blockQueue = CreateSemaphoreA( null, 0, int.max, null );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

76 if( m_blockQueue == m_blockQueue.init )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

77 throw new SyncException( "Unable to initialize condition" );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

78 scope(failure) CloseHandle( m_blockQueue );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

79

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

80 InitializeCriticalSection( &m_unblockLock );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

81 m_assocMutex = m;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

82 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

83 else version( Posix )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

84 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

85 m_mutexAddr = m.handleAddr();

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

86

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

87 int rc = pthread_cond_init( &m_hndl, null );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

88 if( rc )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

89 throw new SyncException( "Unable to initialize condition" );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

90 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

91 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

92

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

93

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

94 ~this()

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

95 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

96 version( Win32 )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

97 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

98 BOOL rc = CloseHandle( m_blockLock );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

99 assert( rc, "Unable to destroy condition" );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

100 rc = CloseHandle( m_blockQueue );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

101 assert( rc, "Unable to destroy condition" );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

102 DeleteCriticalSection( &m_unblockLock );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

103 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

104 else version( Posix )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

105 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

106 int rc = pthread_cond_destroy( &m_hndl );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

107 assert( !rc, "Unable to destroy condition" );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

108 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

109 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

110

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

111

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

112 ////////////////////////////////////////////////////////////////////////////

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

113 // General Actions

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

114 ////////////////////////////////////////////////////////////////////////////

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

115

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

116

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

117 /**

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

118 * Wait until notified.

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

119 *

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

120 * Throws:

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

121 * SyncException on error.

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

122 */

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

123 void wait()

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

124 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

125 version( Win32 )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

126 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

127 timedWait( INFINITE );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

128 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

129 else version( Posix )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

130 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

131 int rc = pthread_cond_wait( &m_hndl, m_mutexAddr );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

132 if( rc )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

133 throw new SyncException( "Unable to wait for condition" );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

134 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

135 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

136

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

137

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

138 /**

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

139 * Suspends the calling thread until a notification occurs or until the

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

140 * supplied time period has elapsed.

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

141 *

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

142 * Params:

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

143 * period = The time to wait, in 100 nanosecond intervals. This value may

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

144 * be adjusted to equal to the maximum wait period supported by

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

145 * the target platform if it is too large.

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

146 *

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

147 * In:

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

148 * period must be non-negative.

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

149 *

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

150 * Throws:

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

151 * SyncException on error.

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

152 *

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

153 * Returns:

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

154 * true if notified before the timeout and false if not.

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

155 */

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

156 bool wait( long period )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

157 in

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

158 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

159 assert( period >= 0 );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

160 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

161 body

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

162 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

163 version( Win32 )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

164 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

165 enum : uint

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

166 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

167 TICKS_PER_MILLI = 10_000,

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

168 MAX_WAIT_MILLIS = uint.max - 1

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

169 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

170

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

171 period /= TICKS_PER_MILLI;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

172 if( period > MAX_WAIT_MILLIS )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

173 period = MAX_WAIT_MILLIS;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

174 return timedWait( cast(uint) period );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

175 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

176 else version( Posix )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

177 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

178 timespec t = void;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

179 mktspec( t, period );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

180

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

181 int rc = pthread_cond_timedwait( &m_hndl, m_mutexAddr, &t );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

182 if( !rc )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

183 return true;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

184 if( rc == ETIMEDOUT )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

185 return false;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

186 throw new SyncException( "Unable to wait for condition" );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

187 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

188 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

189

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

190 /**

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

191 * Notifies one waiter.

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

192 *

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

193 * Throws:

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

194 * SyncException on error.

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

195 */

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

196 void notify()

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

197 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

198 version( Win32 )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

199 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

200 notify( false );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

201 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

202 else version( Posix )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

203 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

204 int rc = pthread_cond_signal( &m_hndl );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

205 if( rc )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

206 throw new SyncException( "Unable to notify condition" );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

207 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

208 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

209

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

210

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

211 /**

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

212 * Notifies all waiters.

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

213 *

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

214 * Throws:

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

215 * SyncException on error.

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

216 */

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

217 void notifyAll()

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

218 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

219 version( Win32 )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

220 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

221 notify( true );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

222 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

223 else version( Posix )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

224 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

225 int rc = pthread_cond_broadcast( &m_hndl );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

226 if( rc )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

227 throw new SyncException( "Unable to notify condition" );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

228 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

229 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

230

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

231

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

232 private:

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

233 version( Win32 )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

234 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

235 bool timedWait( DWORD timeout )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

236 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

237 int numSignalsLeft;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

238 int numWaitersGone;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

239 DWORD rc;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

240

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

241 rc = WaitForSingleObject( m_blockLock, INFINITE );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

242 assert( rc == WAIT_OBJECT_0 );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

243

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

244 m_numWaitersBlocked++;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

245

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

246 rc = ReleaseSemaphore( m_blockLock, 1, null );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

247 assert( rc );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

248

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

249 m_assocMutex.unlock();

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

250 scope(failure) m_assocMutex.lock();

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

251

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

252 rc = WaitForSingleObject( m_blockQueue, timeout );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

253 assert( rc == WAIT_OBJECT_0 || rc == WAIT_TIMEOUT );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

254 bool timedOut = (rc == WAIT_TIMEOUT);

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

255

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

256 EnterCriticalSection( &m_unblockLock );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

257 scope(failure) LeaveCriticalSection( &m_unblockLock );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

258

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

259 if( (numSignalsLeft = m_numWaitersToUnblock) != 0 )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

260 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

261 if ( timedOut )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

262 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

263 // timeout (or canceled)

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

264 if( m_numWaitersBlocked != 0 )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

265 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

266 m_numWaitersBlocked--;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

267 // do not unblock next waiter below (already unblocked)

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

268 numSignalsLeft = 0;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

269 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

270 else

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

271 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

272 // spurious wakeup pending!!

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

273 m_numWaitersGone = 1;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

274 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

275 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

276 if( --m_numWaitersToUnblock == 0 )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

277 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

278 if( m_numWaitersBlocked != 0 )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

279 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

280 // open the gate

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

281 rc = ReleaseSemaphore( m_blockLock, 1, null );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

282 assert( rc );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

283 // do not open the gate below again

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

284 numSignalsLeft = 0;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

285 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

286 else if( (numWaitersGone = m_numWaitersGone) != 0 )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

287 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

288 m_numWaitersGone = 0;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

289 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

290 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

291 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

292 else if( ++m_numWaitersGone == int.max / 2 )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

293 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

294 // timeout/canceled or spurious event :-)

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

295 rc = WaitForSingleObject( m_blockLock, INFINITE );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

296 assert( rc == WAIT_OBJECT_0 );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

297 // something is going on here - test of timeouts?

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

298 m_numWaitersBlocked -= m_numWaitersGone;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

299 rc = ReleaseSemaphore( m_blockLock, 1, null );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

300 assert( rc == WAIT_OBJECT_0 );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

301 m_numWaitersGone = 0;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

302 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

303

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

304 LeaveCriticalSection( &m_unblockLock );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

305

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

306 if( numSignalsLeft == 1 )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

307 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

308 // better now than spurious later (same as ResetEvent)

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

309 for( ; numWaitersGone > 0; --numWaitersGone )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

310 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

311 rc = WaitForSingleObject( m_blockQueue, INFINITE );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

312 assert( rc == WAIT_OBJECT_0 );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

313 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

314 // open the gate

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

315 rc = ReleaseSemaphore( m_blockLock, 1, null );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

316 assert( rc );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

317 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

318 else if( numSignalsLeft != 0 )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

319 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

320 // unblock next waiter

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

321 rc = ReleaseSemaphore( m_blockQueue, 1, null );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

322 assert( rc );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

323 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

324 m_assocMutex.lock();

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

325 return !timedOut;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

326 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

327

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

328

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

329 void notify( bool all )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

330 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

331 DWORD rc;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

332

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

333 EnterCriticalSection( &m_unblockLock );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

334 scope(failure) LeaveCriticalSection( &m_unblockLock );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

335

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

336 if( m_numWaitersToUnblock != 0 )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

337 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

338 if( m_numWaitersBlocked == 0 )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

339 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

340 LeaveCriticalSection( &m_unblockLock );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

341 return;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

342 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

343 if( all )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

344 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

345 m_numWaitersToUnblock += m_numWaitersBlocked;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

346 m_numWaitersBlocked = 0;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

347 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

348 else

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

349 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

350 m_numWaitersToUnblock++;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

351 m_numWaitersBlocked--;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

352 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

353 LeaveCriticalSection( &m_unblockLock );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

354 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

355 else if( m_numWaitersBlocked > m_numWaitersGone )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

356 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

357 rc = WaitForSingleObject( m_blockLock, INFINITE );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

358 assert( rc == WAIT_OBJECT_0 );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

359 if( 0 != m_numWaitersGone )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

360 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

361 m_numWaitersBlocked -= m_numWaitersGone;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

362 m_numWaitersGone = 0;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

363 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

364 if( all )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

365 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

366 m_numWaitersToUnblock = m_numWaitersBlocked;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

367 m_numWaitersBlocked = 0;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

368 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

369 else

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

370 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

371 m_numWaitersToUnblock = 1;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

372 m_numWaitersBlocked--;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

373 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

374 LeaveCriticalSection( &m_unblockLock );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

375 rc = ReleaseSemaphore( m_blockQueue, 1, null );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

376 assert( rc );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

377 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

378 else

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

379 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

380 LeaveCriticalSection( &m_unblockLock );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

381 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

382 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

383

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

384

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

385 // NOTE: This implementation uses Algorithm 8c as described here:

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

386 // http://groups.google.com/group/comp.programming.threads/

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

387 // browse_frm/thread/1692bdec8040ba40/e7a5f9d40e86503a

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

388 HANDLE m_blockLock; // auto-reset event (now semaphore)

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

389 HANDLE m_blockQueue; // auto-reset event (now semaphore)

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

390 Mutex m_assocMutex; // external mutex/CS

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

391 CRITICAL_SECTION m_unblockLock; // internal mutex/CS

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

392 int m_numWaitersGone = 0;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

393 int m_numWaitersBlocked = 0;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

394 int m_numWaitersToUnblock = 0;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

395 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

396 else version( Posix )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

397 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

398 pthread_cond_t m_hndl;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

399 pthread_mutex_t* m_mutexAddr;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

400 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

401 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

402

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

403

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

404 ////////////////////////////////////////////////////////////////////////////////

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

405 // Unit Tests

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

406 ////////////////////////////////////////////////////////////////////////////////

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

407

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

408

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

409 version( unittest )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

410 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

411 private import core.thread;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

412 private import core.sync.mutex;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

413 private import core.sync.semaphore;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

414

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

415

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

416 void testNotify()

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

417 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

418 auto mutex = new Mutex;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

419 auto condReady = new Condition( mutex );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

420 auto semDone = new Semaphore;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

421 auto synLoop = new Object;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

422 int numWaiters = 10;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

423 int numTries = 10;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

424 int numReady = 0;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

425 int numTotal = 0;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

426 int numDone = 0;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

427 int numPost = 0;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

428

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

429 void waiter()

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

430 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

431 for( int i = 0; i < numTries; ++i )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

432 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

433 synchronized( mutex )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

434 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

435 while( numReady < 1 )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

436 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

437 condReady.wait();

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

438 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

439 --numReady;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

440 ++numTotal;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

441 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

442

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

443 synchronized( synLoop )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

444 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

445 ++numDone;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

446 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

447 semDone.wait();

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

448 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

449 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

450

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

451 auto group = new ThreadGroup;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

452

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

453 for( int i = 0; i < numWaiters; ++i )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

454 group.create( &waiter );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

455

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

456 for( int i = 0; i < numTries; ++i )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

457 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

458 for( int j = 0; j < numWaiters; ++j )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

459 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

460 synchronized( mutex )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

461 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

462 ++numReady;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

463 condReady.notify();

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

464 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

465 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

466 while( true )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

467 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

468 synchronized( synLoop )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

469 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

470 if( numDone >= numWaiters )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

471 break;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

472 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

473 Thread.yield();

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

474 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

475 for( int j = 0; j < numWaiters; ++j )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

476 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

477 semDone.notify();

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

478 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

479 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

480

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

481 group.joinAll();

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

482 assert( numTotal == numWaiters * numTries );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

483 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

484

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

485

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

486 void testNotifyAll()

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

487 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

488 auto mutex = new Mutex;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

489 auto condReady = new Condition( mutex );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

490 int numWaiters = 10;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

491 int numReady = 0;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

492 int numDone = 0;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

493 bool alert = false;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

494

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

495 void waiter()

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

496 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

497 synchronized( mutex )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

498 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

499 ++numReady;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

500 while( !alert )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

501 condReady.wait();

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

502 ++numDone;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

503 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

504 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

505

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

506 auto group = new ThreadGroup;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

507

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

508 for( int i = 0; i < numWaiters; ++i )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

509 group.create( &waiter );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

510

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

511 while( true )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

512 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

513 synchronized( mutex )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

514 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

515 if( numReady >= numWaiters )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

516 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

517 alert = true;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

518 condReady.notifyAll();

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

519 break;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

520 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

521 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

522 Thread.yield();

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

523 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

524 group.joinAll();

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

525 assert( numReady == numWaiters && numDone == numWaiters );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

526 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

527

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

528

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

529 void testWaitTimeout()

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

530 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

531 auto mutex = new Mutex;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

532 auto condReady = new Condition( mutex );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

533 bool waiting = false;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

534 bool alertedOne = true;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

535 bool alertedTwo = true;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

536

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

537 void waiter()

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

538 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

539 synchronized( mutex )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

540 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

541 waiting = true;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

542 alertedOne = condReady.wait( 10_000_000 ); // 1s

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

543 alertedTwo = condReady.wait( 10_000_000 ); // 1s

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

544 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

545 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

546

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

547 auto thread = new Thread( &waiter );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

548 thread.start();

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

549

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

550 while( true )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

551 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

552 synchronized( mutex )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

553 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

554 if( waiting )

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

555 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

556 condReady.notify();

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

557 break;

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

558 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

559 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

560 Thread.yield();

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

561 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

562 thread.join();

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

563 assert( waiting && alertedOne && !alertedTwo );

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

564 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

565

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

566

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

567 unittest

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

568 {

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

569 testNotify();

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

570 testNotifyAll();

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

571 testWaitTimeout();

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

572 }

e0b2d67cfe7c Added druntime (this should be removed once it works).

Robert Clipsham <robert@octarineparrot.com>

parents:

diff changeset

573 }

Mercurial > projects > ldc

annotate druntime/src/common/core/sync/condition.d @ 1458:e0b2d67cfe7c