HeadCountAlgo/strategy/components/headcount/include/HeadCountStrategy.h

#ifndef __HEADCOUNT_STRATEGY_H
#define __HEADCOUNT_STRATEGY_H

#include "Strategy.h"
#include "HeadCountCfg.h"
#include "YoloCrowdCfg.h"

NAMESPACE_MAS_BEGIN

NAMESPACE_HEADCOUNT_BEGIN

class HeadCountStrategy : public Strategy {

public:
	HeadCountStrategy ();
	virtual ~HeadCountStrategy();

    virtual TZ_INT Initialize();
    virtual TZ_INT Dispose();

    virtual TZ_INT SetStrategyCfg(const std::string & param);

	virtual TZ_INT DoStrategy(SPtr<StreamInfo> & streamInfo);

private:
    //TZ_INT m_timeThreshold;

    std::queue<std::string> m_qYoloCrowdQueue;
    //std::queue<TZ_INT> m_headCountQueue;

    tzc::Mutex m_yoloCrowdLock;
    //tzc::Mutex m_headCountLock;
};

NAMESPACE_HEADCOUNT_END

NAMESPACE_MAS_END

#endif