SysCriticalSection.cpp

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

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

#include <errno.h>
#include <Cntm/Exceptions/SystemException.h>
#include <Cntm/SystemUtils/SysCriticalSection.h>

Cntm::SpecUtils::SysCriticalSection::SysCriticalSection(bool Recurse)
{
        int err;
        if (Recurse)
        {
                pthread_mutexattr_t attr;
                pthread_mutexattr_init(&attr);
                pthread_mutexattr_settype(&attr, PTHREAD_MUTEX_RECURSIVE_NP);
                err = pthread_mutex_init(&mutex, &attr);
                pthread_mutexattr_destroy(&attr);
        }
        else
        {
                err = pthread_mutex_init(&mutex, NULL);
        }
        
        if (err != 0)
                throw SystemException("Cntm::SpecUtils::CritSectImpl::CritSectImpl", 
                        "pthread_mutex_init");  
}

Cntm::SpecUtils::SysCriticalSection::~SysCriticalSection()
{
        pthread_mutex_destroy(&mutex);
}

void Cntm::SpecUtils::SysCriticalSection::Enter()
{
        if (pthread_mutex_lock(&mutex) != 0)
                throw SystemException("Cntm::SpecUtils::CritSectImpl::Enter", "mutex_lock");
}

bool Cntm::SpecUtils::SysCriticalSection::TryEnter()
{
        switch (pthread_mutex_trylock(&mutex))
        {
                case 0: return true;
                case EBUSY: return false;
                default: throw SystemException("Cntm::SpecUtils::CritSectImpl::TryEnter",       "mutex_trylock");
        }
}

void Cntm::SpecUtils::SysCriticalSection::Leave()
{
        if (pthread_mutex_unlock(&mutex) != 0)
                throw SystemException("Cntm::SpecUtils::CritSectImpl::Leave", "mutex_unlock");
}

---