#ifndef _MSGQUEUE_H
#define _MSGQUEUE_H

#include "_global.h"
#include <agents.h>

#define MAX_MESSAGES 256

// Message structure
struct MESSAGE
{
    int msg;
    duint param1;
    duint param2;
};

// Message stack structure
class MESSAGE_STACK
{
public:
    Concurrency::unbounded_buffer<MESSAGE> msgs;

    int WaitingCalls;   // Number of threads waiting
    bool Destroy;       // Destroy stack as soon as possible
};

// Function definitions
MESSAGE_STACK* MsgAllocStack();
void MsgFreeStack(MESSAGE_STACK* Stack);
bool MsgSend(MESSAGE_STACK* Stack, int Msg, duint Param1, duint Param2);
bool MsgGet(MESSAGE_STACK* Stack, MESSAGE* Msg);
void MsgWait(MESSAGE_STACK* Stack, MESSAGE* Msg);

#endif // _MSGQUEUE_H