SysCriticalSection.h

См. документацию.

/*
 * CntmLib - Подсчет ссылок, потоки, синхронизация, асинхронные процедуры, события
 * Copyright (c) 2005, Овсеевич Роман, CntmLib@mail.ru
 * _______________________________________________________________________________
 * Разрешено свободное использование, копирование, распространение, изменение
 * (изменение сведений об авторских правах запрещено). Запрещена продажа и 
 * включение всей библиотеки или ее частей в другие библиотеки. В сведениях об
 * авторских правах на программу (или сведениях о программе, об авторах, 
 * использованных средствах разработки и т.д.) должна быть указана информация
 * о библиотеке CntmLib, ее авторе и, возможно, сайте или email'е.
 * Библиотека поставляется "как есть", без каких-либо гарантий со стороны автора.
 */ 

#ifndef CNTM_SYSCRITICALSECTION_H
#define CNTM_SYSCRITICALSECTION_H
#include <pthread.h>
#include <boost/utility.hpp>

namespace Cntm
{
        namespace SpecUtils
        {       

                /**
                 * Реализация критической секции. 
                 * @author Овсеевич Р.
                 * \ingroup SystemUtils
                 */
                class SysCriticalSection: boost::noncopyable
                {
                public:

                        /**
                         * Блокирующий объект.
                         * @author Овсеевич Р.
                         * \ingroup SystemUtils
                         */
                        class Lock
                        {
                        public:
                        
                                /**
                                 * Конструктор.
                                 */
                                Lock(): critSect(NULL) {}

                                /**
                                 * Конструктор. Блокирует критическую сакцию.
                                 * 
                                 * Исключение: SystemException в случае ошибки вызова системной функции.
                                 */
                                Lock(SysCriticalSection& CritSect): critSect(&CritSect) { critSect->Enter(); }

                                /**
                                 * Деструктор. Разблокирует критическую сакцию.
                                 * 
                                 * Исключение: SystemException в случае ошибки вызова системной функции.
                                 */
                                ~Lock() { if (critSect) critSect->Leave(); }
                                
                                /**
                                 * Разблокировать критическую сакцию.
                                 * 
                                 * Исключение: SystemException в случае ошибки вызова системной функции.
                                 */
                                void Unlock() { if (critSect) critSect->Leave(); critSect = NULL; }
                                
                        private:
                        
                                /**
                                 * Указатель на критическую секцию. 
                                 */
                                SysCriticalSection* critSect;
                        };


                        /**
                         * Конструктор.
                         * 
                         * Исключение: SystemException в случае ошибки вызова системной функции.
                         * @param Recurse - создавать рекурсивный или обычный мютекс (по умолчанию рекурсивный).
                         */
                        SysCriticalSection(bool Recurse = true);

                        /**
                         * Деструктор. 
                         */
                        ~SysCriticalSection();

                        /**
                         * Возвращает указатель на линуксовый мьютекс. 
                         */
                        pthread_mutex_t* PthreadMutex() { return &mutex; }

                        /**
                         * Производит блокировку объекта. Ожидание разблокировки объекта другим потоком может тянуться бесконечно долго.
                         * 
                         * Исключение: SystemException в случае ошибки вызова системной функции. 
                         */
                        void Enter();

                        /**
                         * Производит попытку блокировки объекта. Если объект не заблокирован, то будет произведена его блокировка и будет возвращено true. В противном случае произойдет немедленный выход из метода и будет возвращено false. Данный метод предназначен для блокировки без ожидания.
                         * 
                         * Исключение: SystemException в случае ошибки вызова системной функции.
                         */
                        bool TryEnter();

                        /**
                         * Производит разблокировку объекта ранее заблокированного данным потоком.
                         * 
                         * Исключение: SystemException в случае ошибки вызова системной функции.
                         */
                        void Leave();

                private:                
                        /**
                         * Линуксовский мьтекс. 
                         */
                        pthread_mutex_t mutex;
                };

        }
}
#endif //CNTM_SYSCRITICALSECTION_H

---