actobj.h

主动对象模式的实现

// ActObj.h
//
#include <queue>
#include "Thread.h"

using namespace std;

class MethodRequest
{
public:
    MethodRequest(int id):_id(id){};
    ~MethodRequest(){};

    int getID() const {return _id;};

    void call();
protected:
    int _id;
};

class ActivationQueue
{
public:
    ActivationQueue(){};
    ~ActivationQueue(){};

    int size(){return (int)_msgQueue.size();};

    void enqueue(MethodRequest &request);
    MethodRequest dequeue();
protected:
    queue<MethodRequest> _msgQueue;
    Mutex _mutex;
    Event _event;
};

class Scheduler
{
public:
    Scheduler(ActivationQueue *requestQueue);
    ~Scheduler(){};
protected:
    void _run();

    ActivationQueue *_requestQueue;
    Thread _controller;

    static DWORD WINAPI _controlEntry(void *arg);
};

class ReceiverImpl
{
public:
    ReceiverImpl(){};
    ~ReceiverImpl(){};
    
    static void activeOperation(int id);
    static Mutex coutMutex;
};

class RemoteProxy
{
public:
    RemoteProxy(int id){_request = new MethodRequest(id);};
    ~RemoteProxy(){delete _request;};

    int getID() const {return _request->getID();};

    void activeOperation();
private:
    MethodRequest *_request;

    static ActivationQueue *_activeQueue;
};