65 lines
1.2 KiB
C++
65 lines
1.2 KiB
C++
#ifndef NETWORK_DEPENDENCIES_POST_BOX_H
|
|
#define NETWORK_DEPENDENCIES_POST_BOX_H
|
|
|
|
/////////////////////////////////////
|
|
// Created by Pontus Fransson 2013 //
|
|
/////////////////////////////////////
|
|
|
|
#include "IPostBox.h"
|
|
#include "../../Misc/Thread/OysterMutex.h"
|
|
#include "../../Misc/ThreadSafeQueue.h"
|
|
|
|
namespace Oyster
|
|
{
|
|
namespace Network
|
|
{
|
|
//With this class you can post items to it and then fetch them somewhere else.
|
|
//It is thread safe beacause of the ThreadSafeQueue.
|
|
template <class T>
|
|
class PostBox : public IPostBox<T>
|
|
{
|
|
public:
|
|
PostBox();
|
|
virtual ~PostBox();
|
|
|
|
virtual void PostMessage(T& message);
|
|
virtual T FetchMessage();
|
|
virtual bool IsFull();
|
|
|
|
private:
|
|
Utility::Container::ThreadSafeQueue<T> messages;
|
|
|
|
};
|
|
|
|
//Implementation of PostBox
|
|
template <class T>
|
|
PostBox<T>::PostBox()
|
|
{
|
|
}
|
|
|
|
template <class T>
|
|
PostBox<T>::~PostBox()
|
|
{
|
|
}
|
|
|
|
template <class T>
|
|
void PostBox<T>::PostMessage(T& message)
|
|
{
|
|
messages.Push(message);
|
|
}
|
|
|
|
template <class T>
|
|
T PostBox<T>::FetchMessage()
|
|
{
|
|
return messages.Pop();
|
|
}
|
|
|
|
template <class T>
|
|
bool PostBox<T>::IsFull()
|
|
{
|
|
return !messages.IsEmpty();
|
|
}
|
|
}
|
|
}
|
|
|
|
#endif |