#include "Utility.h"
#include "Atomic.h"
#include "AsyncConsumerPolicies.h"
#include <boost/thread/thread.hpp>
#include <boost/thread/mutex.hpp>
#include <boost/tuple/tuple.hpp>
#include <boost/bind.hpp>
Namespaces | |
namespace | ark |
Classes | |
class | ark::AsyncConsumer< T, SourceQueuePolicy > |
Defines | |
#define | ARK_ASYNC_CONSUMER_DEFAULT_SOURCE_QUEUE_POLICY async_consumer_policies::MessagePortQueue |
|
AsyncConsumer Generic policy based class for consumers of a message T, running in their own thread. |