1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
|
#ifndef __workerthread__
#define __workerthread__
#include "network/named_pipe.h"
#include "ethread.h"
#include "equeue.h"
// ---------------------------------------------
// parsing thread
// ---------------------------------------------
class WorkerThread : public eThread {
eQueue<clNamedPipe*> *m_queue;
public:
WorkerThread(eQueue<clNamedPipe*> *queue);
~WorkerThread();
public:
virtual void start();
};
// ---------------------------------------------
// is alive thread
// ---------------------------------------------
class IsAliveThread : public eThread {
int m_pid;
std::string m_socket;
public:
IsAliveThread(int pid, const std::string &socketName) : m_pid(pid), m_socket(socketName) {}
~IsAliveThread(){}
public:
virtual void start();
};
#endif // __workerthread__
|
