Danbias/Code/Network/NetworkDependencies/PostBox.h

65 lines
1.2 KiB
C
Raw Normal View History

#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"
2013-11-28 16:20:50 +01:00
#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)
{
2013-11-28 16:20:50 +01:00
messages.Push(message);
}
template <class T>
T PostBox<T>::FetchMessage()
{
return messages.Pop();
}
template <class T>
bool PostBox<T>::IsFull()
{
2013-11-28 16:20:50 +01:00
return !messages.IsEmpty();
}
}
}
#endif