185 lines
3.4 KiB
C++
185 lines
3.4 KiB
C++
#ifndef _library__dispatch__hpp__included__
|
|
#define _library__dispatch__hpp__included__
|
|
|
|
#include <iostream>
|
|
#include <map>
|
|
#include <set>
|
|
#include <list>
|
|
#include <functional>
|
|
#include "threadtypes.hpp"
|
|
|
|
namespace dispatch
|
|
{
|
|
mutex_class& global_init_lock();
|
|
|
|
template<typename... T> struct source;
|
|
|
|
/**
|
|
* Dispatch target handler.
|
|
*/
|
|
template<typename... T> struct target
|
|
{
|
|
/**
|
|
* Create a new target handler.
|
|
*/
|
|
target()
|
|
{
|
|
src = NULL;
|
|
fn = dummy;
|
|
}
|
|
/**
|
|
* Destroy a target, detaching it from source.
|
|
*/
|
|
inline ~target();
|
|
/**
|
|
* Connect a target to given source and give a handler.
|
|
*
|
|
* Parameter d: The source to connect to.
|
|
* Parameter _fn: The function to use as handler.
|
|
*/
|
|
inline void set(source<T...>& d, std::function<void(T...)> _fn);
|
|
private:
|
|
static void dummy(T... args) {};
|
|
void set_source(source<T...>* d) { src = d; }
|
|
void call(T... args) { fn(args...); }
|
|
source<T...>* src;
|
|
std::function<void(T...)> fn;
|
|
friend class source<T...>;
|
|
};
|
|
|
|
/**
|
|
* Dispatch source (event generator).
|
|
*/
|
|
template<typename... T> struct source
|
|
{
|
|
/**
|
|
* Create a new event source.
|
|
*
|
|
* Parameter _name: The name of the event.
|
|
*/
|
|
source(const char* _name)
|
|
{
|
|
init();
|
|
name = _name;
|
|
}
|
|
/**
|
|
* Destory an event source.
|
|
*
|
|
* All targets are disconnected.
|
|
*/
|
|
~source()
|
|
{
|
|
delete _targets;
|
|
delete lck;
|
|
lck = NULL;
|
|
}
|
|
/**
|
|
* Send an event.
|
|
*
|
|
* Parameter args: The arguments to send.
|
|
*/
|
|
void operator()(T... args)
|
|
{
|
|
init();
|
|
uint64_t k = 0;
|
|
typename std::map<uint64_t, target<T...>*>::iterator i;
|
|
lck->lock();
|
|
i = targets().lower_bound(k);
|
|
while(i != targets().end()) {
|
|
k = i->first + 1;
|
|
target<T...>* t = i->second;
|
|
lck->unlock();
|
|
try {
|
|
t->call(args...);
|
|
} catch(std::exception& e) {
|
|
(*errstrm) << name << ": Error in handler: " << e.what() << std::endl;
|
|
}
|
|
lck->lock();
|
|
i = targets().lower_bound(k);
|
|
}
|
|
lck->unlock();
|
|
}
|
|
/**
|
|
* Connect a new target.
|
|
*
|
|
* Parameters target: The target to connect.
|
|
*/
|
|
void connect(target<T...>& target)
|
|
{
|
|
init();
|
|
umutex_class h(*lck);
|
|
targets()[next_cbseq++] = ⌖
|
|
target.set_source(this);
|
|
}
|
|
/**
|
|
* Disconnect a target.
|
|
*
|
|
* Parameters target: The target to disconnect.
|
|
*/
|
|
void disconnect(target<T...>& target)
|
|
{
|
|
init();
|
|
if(!lck)
|
|
return;
|
|
umutex_class h(*lck);
|
|
for(auto i = targets().begin(); i != targets().end(); i++)
|
|
if(i->second == &target) {
|
|
targets().erase(i);
|
|
break;
|
|
}
|
|
target.set_source(NULL);
|
|
}
|
|
/**
|
|
* Set stream to send error messages to.
|
|
*
|
|
* Parameter to: The stream (if NULL, use std::cerr).
|
|
*/
|
|
void errors_to(std::ostream* to)
|
|
{
|
|
errstrm = to ? to : &std::cerr;
|
|
}
|
|
private:
|
|
void init()
|
|
{
|
|
if(inited)
|
|
return;
|
|
umutex_class h(global_init_lock());
|
|
if(inited)
|
|
return;
|
|
errstrm = &std::cerr;
|
|
next_cbseq = 0;
|
|
name = "(unknown)";
|
|
_targets = NULL;
|
|
lck = new mutex_class;
|
|
inited = true;
|
|
}
|
|
mutex_class* lck;
|
|
std::map<uint64_t, target<T...>*>& targets()
|
|
{
|
|
if(!_targets) _targets = new std::map<uint64_t, target<T...>*>;
|
|
return *_targets;
|
|
}
|
|
std::map<uint64_t, target<T...>*>* _targets;
|
|
uint64_t next_cbseq;
|
|
std::ostream* errstrm;
|
|
const char* name;
|
|
bool inited;
|
|
source(const source<T...>&);
|
|
source<T...>& operator=(const source<T...>&);
|
|
};
|
|
|
|
template <typename... T> target<T...>::~target()
|
|
{
|
|
if(src)
|
|
src->disconnect(*this);
|
|
}
|
|
|
|
template <typename... T> void target<T...>::set(source<T...>& d, std::function<void(T...)> _fn)
|
|
{
|
|
fn = _fn;
|
|
src = &d;
|
|
if(src)
|
|
src->connect(*this);
|
|
}
|
|
}
|
|
#endif
|