sthread.c

自己开发基于P2P通讯的网络服务器

/*********************************************************************
 * 模块名称:sthread
 * 说明:线程管理模块
 * 其它说明: 
 * 作者: 刘青山 
 * 时间 : 2004-09-26 7:13:30 
*********************************************************************/
#include "natsvr.h"
#include "sthread.h"

static pthread_t  m_nThreadID[MAX_PATH];
static WORD		  m_iThreads = 0 ;

void CreateThreads( void *(*thread_func)(void*),void *pArgFunc,int iNums )
{
	int i;
	int iRet;

	for ( i=m_iThreads ; i<m_iThreads+iNums ;i++ )
	{
		/* 调用线程创建函数，并传递函数指针给线程创建函数*/
		iRet = pthread_create(&m_nThreadID[i], NULL, thread_func, pArgFunc );
	}
	m_iThreads+=iNums ;
}

void CloseAllThread() 
{
	int i;
	int iRet;

	for ( i=0 ; i< m_iThreads; i++ )
	{
		iRet = pthread_cancel(m_nThreadID[i]);
		iRet = pthread_join(m_nThreadID[i], NULL);
	}
	m_iThreads = 0 ;
}