2e7b6b5ba5
--HG-- branch : refac-jit extra : convert_revision : svn%3A39bc706e-5318-0410-9160-8a85361fbb7c/branches/refac-jit%402369
42 lines
621 B
C++
42 lines
621 B
C++
#ifndef _INCLUDE_SMUD_H_
|
|
#define _INCLUDE_SMUD_H_
|
|
|
|
#include "smud.h"
|
|
#include "smud_connections.h"
|
|
|
|
void *ThreadCallback(void *data);
|
|
|
|
class ThreadWorker
|
|
{
|
|
public:
|
|
ThreadWorker();
|
|
~ThreadWorker();
|
|
public:
|
|
bool Start();
|
|
void CancelAndWait();
|
|
void AddConnection(int fd);
|
|
void Process();
|
|
private:
|
|
ConnectionPool *m_pPool;
|
|
pthread_t m_Thread;
|
|
pthread_mutex_t m_NotifyLock;
|
|
pthread_cond_t m_Notify;
|
|
bool m_bShouldCancel;
|
|
};
|
|
|
|
class ThreadPool
|
|
{
|
|
public:
|
|
ThreadPool();
|
|
~ThreadPool();
|
|
public:
|
|
void AddConnection(int fd);
|
|
bool Start();
|
|
void Stop();
|
|
private:
|
|
ThreadWorker *m_pWorker;
|
|
};
|
|
|
|
#endif //_INCLUDE_SMUD_H_
|
|
|