C:/Users/Pasha/_Dev/fixforge-cpp/fix/cppEngine/include/OnixS/FIX/Threading.h

/*
* Copyright 2005-2011 Onix Solutions Limited [OnixS]. All rights reserved. 
* 
* This software owned by Onix Solutions Limited [OnixS] and is protected by copyright law 
* and international copyright treaties. 
* 
* Access to and use of the software is governed by the terms of the applicable ONIXS Software
* Services Agreement (the Agreement) and Customer end user license agreements granting 
* a non-assignable, non-transferable and non-exclusive license to use the software 
* for it's own data processing purposes under the terms defined in the Agreement.
* 
* Except as otherwise granted within the terms of the Agreement, copying or reproduction of any part 
* of this source code or associated reference material to any other location for further reproduction
* or redistribution, and any amendments to this copyright notice, are expressly prohibited. 
*
* Any reproduction or redistribution for sale or hiring of the Software not in accordance with 
* the terms of the Agreement is a violation of copyright law. 
*/

#if !defined(__ONIXS_FIXENGINE_THREADING_H__)
#define __ONIXS_FIXENGINE_THREADING_H__

#include "OnixS/FIX/ABI.h"

namespace OnixS
{
    namespace Threading
    {
        class ONIXS_FIXENGINE_API Mutex
        {
        public:
            friend ONIXS_FIXENGINE_API_DECL(class, Condition);

            Mutex();

            ~Mutex();

            void acquire();

            bool tryAcquire();

            void release();

        private:
            // Implementation details.
            void* impl_;

            // Copying & assignment is prohibited.

            Mutex(const Mutex&);
            Mutex& operator =(const Mutex&);
        };

        class ONIXS_FIXENGINE_API Semaphore
        {
        public:
            Semaphore(unsigned int count = 1);

            ~Semaphore();

            void acquire();

            bool tryAcquire();

            void release();

        private:
            // Implementation details.
            void* impl_;

            // Copying & assignment is prohibited.

            Semaphore(const Semaphore&);
            Semaphore& operator =(const Semaphore&);
        };

        class ONIXS_FIXENGINE_API Condition
        {
        public:
            Condition(Mutex& lock);

            ~Condition();

            void signal();

            void signalAll();

            void wait();

        private:
            // Implementation details.
            void* impl_;

            // Copying & assignment is prohibited.

            Condition(const Condition&);
            Condition& operator =(const Condition&);
        };

        template<class Acquirable> class Guard
        {
        public:
            Guard(Acquirable& acquirable)
                : acquirable_(acquirable)
            {
                acquirable_.acquire();
            }

            ~Guard()
            {
                acquirable_.release();
            }

        private:
            Acquirable& acquirable_;

            Guard(const Guard&);
            Guard& operator =(const Guard&);
        };

        // Aliases for guards for known synchronization objects.

        typedef Guard<Mutex> MutexGuard;
        typedef Guard<Semaphore> SemaphoreGuard;

        class ONIXS_FIXENGINE_API ThisThread
        {
        public:
            static void sleep(unsigned int milliseconds);

        private:
            // No instances of current thread are avaiable.
            ThisThread(const ThisThread&);
            ThisThread& operator =(const ThisThread&);
        };
    }
}

#endif // __ONIXS_FIXENGINE_THREADING_H__