threadgroup.h

来自「Socketlib: 一个轻量级的C++ 封装Socket C API 网络编程」· C头文件 代码 · 共 56 行

//**********************************************************************
//
// Copyright (C) 2005-2007 Zhang bao yuan([e-mail]).
// All rights reserved.
//
// This copy of Socketlib is licensed to you under the terms described 
// in the LICENSE.txt file included in this distribution.
//
//**********************************************************************

#pragma once
#include "../config.h"
#include "thread.h"
#include "threadmutex.h"
#include <vector>
namespace SYNC
{

class SOCKETLIB_API CThreadGroup
{
public:
	CThreadGroup(void);
	CThreadGroup(ThreadProc threadProc, void *pParameter);
	virtual ~CThreadGroup(void);

	bool  Start(ThreadProc threadProc, void *pParameter, int nThreadCount = 2, int nPriority = THREAD_PRIORITY_NORMAL );
	bool  Start(int nThreadCount = 2);
	bool  IsStop() const;
	void  Stop(DWORD nTimeOut);
	bool  Kill();

	//继续线程
	bool Resume(void);
	//挂起线程
	bool Suspend(void);

	//动态增减线程数
	int   AddThread(int nThreadCount);
	int   RemoveThread(int nThreadCount);
	int   GetThreadCount();

protected:
	bool  Clear();

protected:
	CThreadMutex		m_lock;
	std::vector<HANDLE> m_vecThreads;

	ThreadProc  m_threadProc;
	void	   *m_pParameter;

	CThread::ThreadCmd m_ThreadCmd;

};

};