LeafOK_CVS/innwebd/thread_pool.h

/*******************************************************/
/*                                                     */
/*  LeafOK Innd                                        */
/*  Copyright (C) LeafOK.com, 2003-2004                */
/*                                                     */
/*  Programmed by Leaf                                 */
/*  E-mail:leaf@leafok.com  QQ:6049044                 */
/*                                                     */
/*  http://bbs.leafok.com                              */
/*  http://bbs.leafok.net                              */
/*  http://bbs.fenglin.info                            */
/*                                                     */
/*******************************************************/

#pragma once

#include <time.h>

#define THREAD_SPOOL_MAX_THREAD 256
#define THREAD_SPOOL_DEFAULT_TIMEOUT 10000
#define THREAD_SPOOL_SETLOCK_TMEOUT 100

class thread_pool
{
public:
        enum thread_status{
                S_UNKNOWN                               =       -1,
                S_UNUSED                                =       0,
                S_WORKING                               =       1,
                S_WAITING                               =       2,
                S_TERMINATED                    =       3
        };
        enum error_code{
                E_NOERROR                               =       0,
                E_LOCK_TIMEOUT                  =       1,
                E_MAX_THREAD_EXCEEDED   =       2,
                E_THREAD_NOT_FOUND              =       3
        };
private:
        UINT uThreadCount;
        UINT uThreadMax;
        HANDLE hThreadList[THREAD_SPOOL_MAX_THREAD];
        thread_status uThreadStatusList[THREAD_SPOOL_MAX_THREAD];
        double time_status_keep[THREAD_SPOOL_MAX_THREAD];
        double thread_timeout;
        bool bProcessLock;
        int SetLock(bool bLock, time_t tTimeout = THREAD_SPOOL_SETLOCK_TMEOUT);
        error_code uLastErrorCode;
public:
        thread_pool(UINT uThreadMax = THREAD_SPOOL_MAX_THREAD, double thread_timeout = THREAD_SPOOL_DEFAULT_TIMEOUT);
        ~thread_pool(void);
        UINT GetLastError(void);
        int AddThread(HANDLE hThread);
        int RemoveThread(HANDLE hThread);
        int SetThreadStatus(HANDLE hThread, UINT uStatus);
        UINT GetThreadStatus(HANDLE hThread);
};
1	/*******************************************************/
2	/* */
3	/* LeafOK Innd */
4	/* Copyright (C) LeafOK.com, 2003-2004 */
5	/* */
6	/* Programmed by Leaf */
7	/* E-mail:leaf@leafok.com QQ:6049044 */
8	/* */
9	/* http://bbs.leafok.com */
10	/* http://bbs.leafok.net */
11	/* http://bbs.fenglin.info */
12	/* */
13	/*******************************************************/
14
15	#pragma once
16
17	#include <time.h>
18
19	#define THREAD_SPOOL_MAX_THREAD 256
20	#define THREAD_SPOOL_DEFAULT_TIMEOUT 10000
21	#define THREAD_SPOOL_SETLOCK_TMEOUT 100
22
23	class thread_pool
24	{
25	public:
26	enum thread_status{
27	S_UNKNOWN = -1,
28	S_UNUSED = 0,
29	S_WORKING = 1,
30	S_WAITING = 2,
31	S_TERMINATED = 3
32	};
33	enum error_code{
34	E_NOERROR = 0,
35	E_LOCK_TIMEOUT = 1,
36	E_MAX_THREAD_EXCEEDED = 2,
37	E_THREAD_NOT_FOUND = 3
38	};
39	private:
40	UINT uThreadCount;
41	UINT uThreadMax;
42	HANDLE hThreadList[THREAD_SPOOL_MAX_THREAD];
43	thread_status uThreadStatusList[THREAD_SPOOL_MAX_THREAD];
44	double time_status_keep[THREAD_SPOOL_MAX_THREAD];
45	double thread_timeout;
46	bool bProcessLock;
47	int SetLock(bool bLock, time_t tTimeout = THREAD_SPOOL_SETLOCK_TMEOUT);
48	error_code uLastErrorCode;
49	public:
50	thread_pool(UINT uThreadMax = THREAD_SPOOL_MAX_THREAD, double thread_timeout = THREAD_SPOOL_DEFAULT_TIMEOUT);
51	~thread_pool(void);
52	UINT GetLastError(void);
53	int AddThread(HANDLE hThread);
54	int RemoveThread(HANDLE hThread);
55	int SetThreadStatus(HANDLE hThread, UINT uStatus);
56	UINT GetThreadStatus(HANDLE hThread);
57	};
webmaster@leafok.com	ViewVC Help
Powered by ViewVC 1.3.0-beta1