MultiThreadSpikeScheduler.h

Go to the documentation of this file.

#ifndef MULTITHREADSPIKESCHEDULER_H_
#define MULTITHREADSPIKESCHEDULER_H_

#include "MTSpikeRoutingTables.h"
#include "MTPropagatedSpikeBuffers.h"
#include "SimParameter.h"
#include "SingleThreadSpikeScheduler.h"
#include <iostream>

using std::cout;
using std::endl;


class MultiThreadSpikeScheduler : public SpikeScheduler
{

public:

    MultiThreadSpikeScheduler(int numThreads,
                              MTSpikeRoutingTables &tables,
                              vector<PropagatedSpikeBuffer*> &stBuffers,
                              SimParameter &sp);

    virtual ~MultiThreadSpikeScheduler();

    /*
     * It is invoked by the SingleThreadSimEngine when some advancing spiking object generates a spike.
     * 
     * \param senderid Identifier of the sim object that emits the spike.
     * 
     * \param time The exact moment in time (from the start of the simulation) in secs when the spike occured.
     * 
     * \param engine engineid of the local engine where sender object belongs.
     */
    virtual void scheduleSpike(local_objectid_t senderid, float offsetFraction, engineid_t engine = 0);


    virtual void deliverSpikes(SpikeReceiverList &listActiveSynapses,
                               engineid_t engine, double simTime, int stepOffset = 0 );



    virtual void reset();


    virtual void advance(engineid_t engine = 0);


    virtual void nextCycle();

protected:
    int _numThreads;

    vector<SingleThreadSpikeScheduler> STschedulers;

    MTSpikeRoutingTables &rtables ;

    NodeLocalMultiTargetDelayMap &mTDelayMap;

    SpikeTargetGroupPool &tgtGrpPool ;

    SimParameter &_simParam ;

    vector<PropagatedSpikeBuffer*> &STbuffers;

    MTPropagatedSpikeBuffers mTSpikeBuffers;

    int * engineSteps;


    int nCycleSteps ;

};

#endif /*MULTITHREADSPIKESCHEDULER_H_*/

---