win32semaphore.cpp

来自「"More for C++" is a class library that p」· C++ 代码 · 共 74 行

//
//  This file is part of the "More for C++" library
//
//  Copyright (c) 1999-2003 by Thorsten Goertz ([e-mail])
//
//  The "More for C++" library is free software; you can redistribute it and/or
//  modify it under the terms of the license that comes with this package.
//
//  Read "license.txt" for more details.
//
//  THIS PACKAGE IS PROVIDED "AS IS" AND WITHOUT ANY EXPRESS OR IMPLIED
//  WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED WARRANTIES
//  OF MERCHANTIBILITY AND FITNESS FOR A PARTICULAR PURPOSE.

////////////////////////////////////////////////////////////////////////////////

#ifndef _WIN32
#define _WIN32
#endif

#include <windows.h>
#include "win32semaphore.hpp"

using namespace more::os::win32;

////////////////////////////////////////////////////////////////////////////////

Win32Semaphore::Win32Semaphore
(
  size_t nNoOfResources
)
{
  m_hSemaphore = CreateSemaphore( NULL, nNoOfResources, nNoOfResources, NULL );
}

////////////////////////////////////////////////////////////////////////////////

void Win32Semaphore::finalize( )
{
  CloseHandle( m_hSemaphore );
}

////////////////////////////////////////////////////////////////////////////////

void Win32Semaphore::acquire
(
  size_t nMillisecondsToWait

) throw( Semaphore::TimeOut )
{
  if( WaitForSingleObject( m_hSemaphore, nMillisecondsToWait ) == WAIT_TIMEOUT )
  {
    throw Semaphore::TimeOut( );
  }
}

////////////////////////////////////////////////////////////////////////////////

void Win32Semaphore::acquire( )
{
  WaitForSingleObject( m_hSemaphore, INFINITE );
}

////////////////////////////////////////////////////////////////////////////////

void Win32Semaphore::release( )
{
  LONG nLastCount;

  ReleaseSemaphore( m_hSemaphore, 1, &nLastCount );
}

////////////////////////////////////////////////////////////////////////////////