#ifndef APPCONTROLLER_H
|
#define APPCONTROLLER_H
|
|
#include <basic/pipe/TimerElement.h>
|
#include <queue>
|
#include "RapidAppPipeController.h"
|
#include <condition_variable>
|
#include <mutex>
|
|
class AppController : public TimerElement {
|
public:
|
AppController(std::string path, int interval);
|
|
RapidAppPipeController *addController();
|
|
std::string startController();
|
|
private:
|
virtual void timerFunc() override;
|
|
private:
|
std::string m_path;
|
std::string m_pathOut;
|
std::queue<std::string> m_que;
|
std::vector<RapidAppPipeController *> m_vec;
|
|
bool m_state;
|
|
int m_nIndex;
|
std::mutex mtx;
|
|
pthread_cond_t func_cond;
|
pthread_mutex_t func_cond_mutex;
|
|
};
|
|
#endif // APPCONTROLLER_H
|
