LeafOK_CVS/innwebd/thread_pool.h

/*******************************************************/
/*                                                     */
/*  LeafOK Innbbsd                                     */
/*                                                     */
/*  Copyright (C) LeafOK.com, 2003-2008                */
/*                                                     */
/*  http://www.leafok.com                              */
/*                                                     */
/*******************************************************/

#pragma once

#include <time.h>

#define TS_MAX_THREAD                   256
#define TS_DEFAULT_TIMEOUT              10000
#define TS_SETLOCK_TIMEOUT              100

class thread_pool
{
public:
        enum thread_status{
                S_UNKNOWN                               =       -1,
                S_UNUSED                                =       0,
                S_WORKING                               =       1,
                S_WAITING                               =       2
        };
        enum error_code{
                E_NOERROR                               =       0,
                E_LOCK_TIMEOUT                  =       1,
                E_MAX_THREAD_EXCEEDED   =       2,
                E_THREAD_NOT_FOUND              =       3,
                E_INVALID_TIMEOUT               =       4,
                E_KILL_THREAD_FAILED    =       5,
                E_KILLER_BEGIN_FAILED   =       6,
                E_KILLER_END_FAILED             =       7,
                E_INVALID_THREAD                =       8
        };
private:
        UINT uThreadCount;
        UINT uThreadMax;
        ULONG ulThreadIdList[TS_MAX_THREAD];
        thread_status uThreadStatusList[TS_MAX_THREAD];
        clock_t time_status_set[TS_MAX_THREAD];
        clock_t thread_timeout[TS_MAX_THREAD];
        bool bProcessLock;
        int SetLock(bool bLock, clock_t tTimeout = TS_SETLOCK_TIMEOUT);
        error_code uLastErrorCode;
        ULONG ulThreadKillerId;
        bool bTerminateThreadKiller;
public:
        thread_pool(UINT uThreadMax = TS_MAX_THREAD);
        ~thread_pool(void);
        static DWORD KillDeadThread(LPVOID pParam);
        int GetLastError(void) const;
        int AddThread(ULONG ulThreadId, clock_t thread_timeout = TS_DEFAULT_TIMEOUT);
        int RemoveThread(ULONG ulThreadId);
        int SetThreadStatus(ULONG ulThreadId, int uStatus);
        int GetThreadStatus(ULONG ulThreadId);
        int GetThreadCount(void) const;
        int EnableKillDeadThread(void);
        int DisableKillDeadThread(void);
        int KillAllThread(void);
};
1	sysadm	1.1	/*******************************************************/
2			/* */
3	sysadm	1.5	/* LeafOK Innbbsd */
4	sysadm	1.1	/* */
5	sysadm	1.7	/* Copyright (C) LeafOK.com, 2003-2008 */
6	sysadm	1.1	/* */
7	sysadm	1.7	/* http://www.leafok.com */
8	sysadm	1.1	/* */
9			/*******************************************************/
10
11			#pragma once
12
13			#include <time.h>
14
15	sysadm	1.2	#define TS_MAX_THREAD 256
16			#define TS_DEFAULT_TIMEOUT 10000
17			#define TS_SETLOCK_TIMEOUT 100
18	sysadm	1.1
19			class thread_pool
20			{
21			public:
22			enum thread_status{
23			S_UNKNOWN = -1,
24			S_UNUSED = 0,
25			S_WORKING = 1,
26	sysadm	1.2	S_WAITING = 2
27	sysadm	1.1	};
28			enum error_code{
29			E_NOERROR = 0,
30			E_LOCK_TIMEOUT = 1,
31			E_MAX_THREAD_EXCEEDED = 2,
32	sysadm	1.2	E_THREAD_NOT_FOUND = 3,
33			E_INVALID_TIMEOUT = 4,
34	sysadm	1.5	E_KILL_THREAD_FAILED = 5,
35			E_KILLER_BEGIN_FAILED = 6,
36			E_KILLER_END_FAILED = 7,
37			E_INVALID_THREAD = 8
38	sysadm	1.1	};
39			private:
40			UINT uThreadCount;
41			UINT uThreadMax;
42	sysadm	1.5	ULONG ulThreadIdList[TS_MAX_THREAD];
43	sysadm	1.2	thread_status uThreadStatusList[TS_MAX_THREAD];
44			clock_t time_status_set[TS_MAX_THREAD];
45	sysadm	1.3	clock_t thread_timeout[TS_MAX_THREAD];
46	sysadm	1.1	bool bProcessLock;
47	sysadm	1.2	int SetLock(bool bLock, clock_t tTimeout = TS_SETLOCK_TIMEOUT);
48	sysadm	1.1	error_code uLastErrorCode;
49	sysadm	1.5	ULONG ulThreadKillerId;
50	sysadm	1.4	bool bTerminateThreadKiller;
51	sysadm	1.1	public:
52	sysadm	1.3	thread_pool(UINT uThreadMax = TS_MAX_THREAD);
53	sysadm	1.1	~thread_pool(void);
54	sysadm	1.3	static DWORD KillDeadThread(LPVOID pParam);
55			int GetLastError(void) const;
56	sysadm	1.5	int AddThread(ULONG ulThreadId, clock_t thread_timeout = TS_DEFAULT_TIMEOUT);
57			int RemoveThread(ULONG ulThreadId);
58			int SetThreadStatus(ULONG ulThreadId, int uStatus);
59			int GetThreadStatus(ULONG ulThreadId);
60	sysadm	1.3	int GetThreadCount(void) const;
61			int EnableKillDeadThread(void);
62			int DisableKillDeadThread(void);
63	sysadm	1.5	int KillAllThread(void);
64	sysadm	1.1	};
webmaster@leafok.com	ViewVC Help
Powered by ViewVC 1.3.0-beta1