Thread portable class Gate portable class Timer class Pool class Terimber 2.0 About C++

Downloads Products & Services Support Clients Open Source About Home / Open source / Terimber 2.0 primitives.h Go to the documentation of this file. /* * The Software License * ================================================================================= * Copyright (c) 2003-.The Terimber Corporation. All rights reserved. * ================================================================================= * Redistributions of source code must retain the above copyright notice, * this list of conditions and the following disclaimer. * Redistributions in binary form must reproduce the above copyright notice, * this list of conditions and the following disclaimer in the documentation * and/or other materials provided with the distribution. * The end-user documentation included with the redistribution, if any, * must include the following acknowledgment: * "This product includes software developed by the Terimber Corporation." * ================================================================================= * THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESSED OR IMPLIED WARRANTIES, * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY * AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. * IN NO EVENT SHALL THE TERIMBER CORPORATION OR ITS CONTRIBUTORS BE LIABLE FOR * ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON * ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. * ================================================================================ */ #ifndef _terimber_primitives_h_ #define _terimber_primitives_h_ #include "allinc.h" #include "base/proto.h" BEGIN_TERIMBER_NAMESPACE #pragma pack(4) class mutex { // prevents copy objects mutex(const mutex& x); mutex& operator=(const mutex& x); public: #if OS_TYPE == OS_WIN32 typedef CRITICAL_SECTION _HANDLE_; #else typedef pthread_mutex_t _HANDLE_; #endif mutex(); ~mutex(); bool lock() const; void unlock() const; bool trylock() const; operator _HANDLE_*() { return &_handle; } operator const _HANDLE_*() const { return &_handle; } private: mutable _HANDLE_ _handle; }; class mutex_keeper { public: mutex_keeper( const mutex& mtx, bool use_try = false ) : _mtx(mtx) { _locked = use_try ? _mtx.trylock() : _mtx.lock(); } ~mutex_keeper() { if (_locked) _mtx.unlock(); } inline void unlock() const { if (_locked) { _mtx.unlock(); _locked = false; } } inline void lock() const { if (!_locked) { _mtx.lock(); _locked = true; } } inline operator bool() const { return _locked; } inline bool operator!() const { return !_locked; } private: const mutex& _mtx; mutable bool _locked; }; class event { event(const event& x); event& operator=(const event& x); public: #if OS_TYPE == OS_WIN32 typedef HANDLE _HANDLE_; #else typedef class HANDLE { public: mutex _mtx; pthread_cond_t* _cond; bool _manual_reset; bool _signaled; } *_HANDLE_; #endif event( bool manual_reset = false, bool init_state = false ); ~event(); void signal() const; void nonsignal() const; operator _HANDLE_() const { return #if OS_TYPE == OS_WIN32 _handle; #else &_handle; #endif } size_t wait( size_t timeout = INFINITE ) const; private: mutable HANDLE _handle; }; class semaphore { semaphore(const semaphore& x); semaphore& operator=(const semaphore& x); public: #if OS_TYPE == OS_WIN32 typedef HANDLE _HANDLE_; #else typedef class HANDLE { public: mutex _mtx; pthread_cond_t* _cond; size_t _init_count; size_t _max_count; } *_HANDLE_; #endif semaphore( size_t initial_count = 1, size_t max_count = 1 ); ~semaphore(); bool release( size_t count = 1 ) const; size_t wait( size_t timeout = INFINITE ) const; private: mutable HANDLE _handle; }; class semaphore_keeper { public: semaphore_keeper( const semaphore& sema, size_t timeout = INFINITE ) : _sema(sema) { _approved = (WAIT_OBJECT_0 == _sema.wait(timeout)); } ~semaphore_keeper() { if (_approved) _sema.release(); } inline operator bool() const { return _approved; } inline bool operator!() const { return !_approved; } private: const semaphore& _sema; bool _approved; }; #pragma pack() END_TERIMBER_NAMESPACE #endif

© Copyright Terimber 2003-.