VuoTriggerSet.hh

Go to the documentation of this file.

 
#pragma once
 
#include <set>
#include <dispatch/dispatch.h>
 
template<typename TriggerDataType, typename TriggerContextType = void *>
class VuoTriggerSet
{
public:
    typedef void (*TriggerFunctionType)(TriggerDataType);
 
    VuoTriggerSet();
    ~VuoTriggerSet();
 
    void addTrigger(TriggerFunctionType trigger);
    void addTrigger(TriggerFunctionType trigger, TriggerContextType context);
    void removeTrigger(TriggerFunctionType trigger);
    unsigned int size(void);
 
    void fire(TriggerDataType data);
    void fire(void (^)(TriggerFunctionType trigger, TriggerContextType context));
 
private:
    dispatch_queue_t queue; 
    std::set<TriggerFunctionType> triggers;
    std::set< std::pair<TriggerFunctionType, TriggerContextType> > triggersWithContext;
};
 
template<typename TriggerDataType, typename TriggerContextType>
VuoTriggerSet<TriggerDataType, TriggerContextType>::VuoTriggerSet()
{
    this->queue = dispatch_queue_create("VuoTriggerSet", NULL);
}
 
template<typename TriggerDataType, typename TriggerContextType>
VuoTriggerSet<TriggerDataType, TriggerContextType>::~VuoTriggerSet()
{
#if !__has_feature(objc_arc)
    dispatch_release(this->queue);
#endif
}
 
template<typename TriggerDataType, typename TriggerContextType>
void VuoTriggerSet<TriggerDataType, TriggerContextType>::addTrigger(TriggerFunctionType trigger)
{
    dispatch_sync(queue, ^{
        triggers.insert(trigger);
    });
}
 
template<typename TriggerDataType, typename TriggerContextType>
void VuoTriggerSet<TriggerDataType, TriggerContextType>::addTrigger(TriggerFunctionType trigger, TriggerContextType context)
{
    dispatch_sync(queue, ^{
        triggersWithContext.insert(std::make_pair(trigger, context));
    });
}
 
template<typename TriggerDataType, typename TriggerContextType>
void VuoTriggerSet<TriggerDataType, TriggerContextType>::removeTrigger(TriggerFunctionType trigger)
{
    dispatch_sync(queue, ^{
        triggers.erase(trigger);
 
        for (typename std::set< std::pair<TriggerFunctionType, TriggerContextType> >::iterator it = triggersWithContext.begin(); it != triggersWithContext.end(); )
            if (it->first == trigger)
                triggersWithContext.erase(it++);
            else
                ++it;
    });
}
 
template<typename TriggerDataType, typename TriggerContextType>
unsigned int VuoTriggerSet<TriggerDataType, TriggerContextType>::size(void)
{
    __block unsigned int size;
    dispatch_sync(queue, ^{
        size = triggers.size() + triggersWithContext.size();
    });
    return size;
}
 
template<typename TriggerDataType, typename TriggerContextType>
void VuoTriggerSet<TriggerDataType, TriggerContextType>::fire(TriggerDataType data)
{
    dispatch_sync(queue, ^{
                       for (typename std::set<TriggerFunctionType>::iterator it = triggers.begin(); it != triggers.end(); ++it)
                           (*it)(data);
                   });
}
 
template<typename TriggerDataType, typename TriggerContextType>
void VuoTriggerSet<TriggerDataType, TriggerContextType>::fire(void (^block)(TriggerFunctionType trigger, TriggerContextType context))
{
    dispatch_sync(queue, ^{
        for (typename std::set< std::pair<TriggerFunctionType, TriggerContextType> >::iterator it = triggersWithContext.begin(); it != triggersWithContext.end(); ++it)
            block(it->first, it->second);
    });
}