semaphoreimpl.h

来自「一个语言识别引擎」· C头文件 代码 · 共 42 行

// -*- mode:C++; tab-width:4; c-basic-offset:4; indent-tabs-mode:nil -*-
#ifndef _ACECHECK_SEMAPHOREIMPL_
#define _ACECHECK_SEMAPHOREIMPL_

#include <ace/Synch.h>


/**
 * A semaphore abstraction for mutual exclusion and resource management.
 */
class SemaphoreImpl {
public:
    SemaphoreImpl(int initialCount = 1) : sema(initialCount) {
    }

    virtual ~SemaphoreImpl() {}

    // blocking wait
    void wait() {
        int result = sema.acquire();
        while (result == -1) {
            result = sema.acquire();
        }
    }

    // polling wait
    bool check() {
        return (sema.tryacquire()<0)?0:1;
    }

    // increment
    void post() {
        sema.release();
    }

private:
    ACE_Semaphore sema;
};

#endif