MTDistributedIncomingSpikeScheduler.h

Go to the documentation of this file.

#ifndef MTDISTRIBUTEDINCOMINGSPIKESCHEDULER_H_
#define MTDISTRIBUTEDINCOMINGSPIKESCHEDULER_H_

#include "ThreadPool.h"
#include "GlobalMultiTargetDelayMap.h"
#include "STDistributedIncomingSpikeScheduler.h"


class IncomingSpikeSchedulerThreadPoolJob : public ThreadPoolJob
{
public:
    IncomingSpikeSchedulerThreadPoolJob(STDistributedIncomingSpikeScheduler
                                        *incomingSpikeScheduler)
            : _incomingSpikeScheduler(incomingSpikeScheduler)
    {}

    virtual void start()
    {
        _incomingSpikeScheduler->processMPIInputSpikeBuffers();
    }

protected:
    STDistributedIncomingSpikeScheduler * _incomingSpikeScheduler;
};


class MTDistributedIncomingSpikeScheduler : public DistributedIncomingSpikeScheduler
{
public:

    /*
     * Constructs an instance of MTDistributedIncomingSpikeScheduler.
     * 
     * \param numThreads Number of threads that are to be utilized in the processing.
     * 
     * \param inputBuffers Reference to an array of the MPI input buffers that are to be scaned for incoming spikes.
     * 
     * \param globalDelayMap Reference to the global delay map which contains the delays and target groups for each spike source.
     * 
     * \param spikeBuffer Destination buffer of the processing. For each incoming spike a set of target groups are inserted in the appropriate place with respect to the delay.
     * 
     * \param cycleSteps Number of simulation steps in one simulation cycle (usualy equal to minimum synapse delay).
     */
    MTDistributedIncomingSpikeScheduler(int numThreads,
                                        ThreadPool &threadPool,
                                        MPIInputBufferVector &inputBuffers,
                                        GlobalMultiTargetDelayMap &globalDelayMap,
                                        vector<PropagatedSpikeBuffer*> &spikeBuffers,
                                        int cycleSteps) ;

    virtual ~MTDistributedIncomingSpikeScheduler();

    virtual void processMPIInputSpikeBuffers();

protected:
    //
    int nThreads;


    ThreadPool &thr_pool;

    vector<STDistributedIncomingSpikeScheduler*> incomingSpikeSchedulers;


    vector<IncomingSpikeSchedulerThreadPoolJob*> jobs;
};

#endif /*MTDISTRIBUTEDINCOMINGSPIKESCHEDULER_H_*/

---