SysSignalFlag.h

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

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

#ifndef CNTM_SYSSIGNALFLAG_H
#define CNTM_SYSSIGNALFLAG_H
#include <pthread.h>
#include <sys/time.h>
#include <boost/utility.hpp>
#include <Cntm/Utils/IntTypes.h>
#include <Cntm/SystemUtils/SysCriticalSection.h>

namespace Cntm
{
        namespace SpecUtils
        {
        
                /**
                 * Реализация сигнального флага. Он имеет 2 состояния сигнальное (установленное) и несигнальное (сброшенное).
                 *
                 * Когда флаг находится в несигнальном состоянии, то потоки, вызывающие функцию Wait() переводятся в ожидающее состояние. Когда флаг переходит в сигнальное состояние, ожидание завершается. Если флаг на момент входа в Wait находился в сигнальном состоянии, то ожидание не производится.
                 *
                 * Сигнальный флаг может быть 2 типов: с автосбросом и без автосброса. В первом случае, когда функция Wait завершает свою работу при переходе в сигнальное состояние, флаг автоматически переводится обратно в несигнальное состояние. Это обеспечивает проход только одного из нескольких потоков, ожидающих на флаге.
                 * @author Овсеевич Р.
                 * \ingroup SystemUtils
                 */
                class SysSignalFlag: boost::noncopyable
                {
                public:

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

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

                        /**
                         * Ожидает перехода в сигнальное состояние. MSecTimeout - интервал ожидания наступления сигнального состояния в мс. Если объект находится в сигнальном состоянии, возврат происходит сразу с результатом true. Если сигнальное состояние наступило до истечения MSecTimeout или уже было на момент вызова Wait, то возвращается true, иначе возвращается false. Если MSecTimeout = 0, ожидания не происходит, возвращается true, если объект был в сигнальном состоянии, и false в противном случае.
                         * 
                         * Исключение: SystemException в случае ошибки вызова системной функции.
                         * @param Infinite - бесконечное ожидание.
                         * @param MSecTimeout - длительность ожидания в мсек.
                         */
                        bool Wait(bool Infinite, uint MSecTimeout);

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

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

                private:
                
                        /**
                         * Тип флага: с автосбросом или нет.
                         */
                        bool autoReset;
                        /**
                         * Мьютекс.
                         */
                        SysCriticalSection mutex;
                        /**
                         * Условная переменная.
                         */
                        pthread_cond_t cond;
                        /**
                         * Состояние.
                         */
                        bool flag;

                        /**
                         * Перевести флаг в сигнальное состояние для одного или для всех ожидающих потоков в зависимости от типа флага.
                         */
                        void SignalCond();
                };

        }
}

#endif //CNTM_SYSSIGNALFLAG_H

---