thread.cpp

天之炼狱1服务器端源文件游戏服务端不完整

////////////////////////////////////////////////////////////////////////////////
//
// Thread.cpp
//
// by Reiot, the Lord of MUDMANIA(TM)
//
// Last Updated : 1999. 07. 02.
//
////////////////////////////////////////////////////////////////////////////////

//////////////////////////////////////////////////
// include files
//////////////////////////////////////////////////
#include "Thread.h"
#include "ThreadAttr.h"
#include "pthreadAPI.h"

using namespace pthreadAPI;


////////////////////////////////////////////////////////////////////////////////
//
// constructor
//
////////////////////////////////////////////////////////////////////////////////
//
// Thread 努贰胶甫 惑加罐篮 DerivedThread 绰 弥家茄 ThreadAttr 甫 傍蜡窍霸 等促. 
// 父距 DerivedThread 甫 咯矾 俺 父甸 鞘夸啊 乐促搁, 弊 皋筋靛 郴俊辑 利例茄 
// ThreadAttr 甫 积己茄 饶俊, 捞甫 窍困 静饭靛狼 积己磊俊 逞败林绊 葛电 窍困 
// 静饭靛甫 积己茄 饶俊, Thread-Attribute 按眉甫 昏力窍搁 瞪 巴捞促.
//
// 林狼且 痢篮, 按眉 积己苞 角力 静饭靛狼 矫累篮 悼矫俊 捞风绢瘤瘤 臼绰促绰
// 巴捞促. 溜 葛电 静饭靛狼 Start() 甫 荐青茄 饶俊 ThreadAttr 按眉甫 昏力秦具
// 茄促. 弊犯瘤 臼栏搁 俊矾啊 朝 巴捞促.
//
// 肚茄 葛电 静饭靛绰 new 肺 积己秦具 茄促. 泅犁 pthread_create() 狼 付瘤阜 
// 颇扼固磐肺 静饭靛 按眉狼 林家甫 逞败林霸 登绰单, 捞锭 窃荐 胶琶俊 静饭靛 
// 按眉啊 积己瞪 版快 Scope Rule俊 狼秦 俊矾啊 唱霸 等促. 公炼扒 静饭靛 按眉绰 
// 赛(Heap)俊 积己秦具父 茄促!!!
//
////////////////////////////////////////////////////////////////////////////////
Thread::Thread ( ThreadAttr * attr ) 
	 throw ()
: m_TID(0) , m_ThreadAttr(attr), m_Status(Thread::READY)
{
}


////////////////////////////////////////////////////////////////////////////////
//
// destructor (virtual)
//
////////////////////////////////////////////////////////////////////////////////
//
// DerivedThread 努贰胶俊辑 眠啊等 attribute 甫 昏力配废 窍扁 困秦辑 virtual 肺
// 沥狼登绢 乐促. 角力肺绰 酒公繁 老档 窍瘤 臼绰促.
//
////////////////////////////////////////////////////////////////////////////////
Thread::~Thread () 
	 throw ()
{
}


////////////////////////////////////////////////////////////////////////////////
//
// 静饭靛甫 积己茄促.
//
////////////////////////////////////////////////////////////////////////////////
//
// pthread_create() 俊 措秦辑 混旗焊档废 窍磊.
//
// int pthread_create ( pthread_t * tid , 
//                      pthread_attr_t * atttr , 
//                      void * (*start_routine)(void*) , 
//                      void * arg 
//                    );
//
// 积己俊 己傍窍搁 0 阑 府畔窍哥, 角菩且 版快 俊矾 内靛甫 府畔茄促.
// 俊矾 内靛绰 EAGAIN 捞 蜡老窍哥, 矫胶袍 府家胶啊 何练窍芭唱 静饭靛 箭磊啊
// 呈公 腹澜阑 狼固茄促.
//
// tid 狼 器牢磐甫 霉锅掳 颇扼固磐肺 林搁, 弊 救俊 thread identifier 啊 历厘等促.
//
// attr 捞 NULL 老 版快 Default Attribute 甫 啊柳 静饭靛啊 积己等促. 漂喊洒
// 绢恫 加己阑 瘤沥窍妨搁 利例茄 pthread_attr_t 甫 力傍窍搁 瞪 巴捞促.
//
// start_routine 栏肺绰 Thread 努贰胶狼 friend method 甫 荤侩窍绰单, 捞锭 arg 肺
// this - Thread Object - 甫 力傍窍霸 等促. 弊矾搁, start_routine 救俊辑绰 
// polymorphism 阑 荤侩秦辑 窍困 努贰胶狼 run() 皋筋靛甫 磊悼栏肺 龋免窍霸 
// 登骨肺.. 葛电 巴篮 啊瓷秦柳促. -_-;
//
////////////////////////////////////////////////////////////////////////////////
void Thread::start () 
     throw ( ThreadException , Error )
{ 
	__BEGIN_TRY
		
	if ( m_Status != Thread::READY )
		throw ThreadException("invalid thread's status");

	pthread_create_ex( &m_TID, ( m_ThreadAttr == NULL ? NULL : m_ThreadAttr->getAttr() ) , start_routine , this );
	
	__END_CATCH
}


////////////////////////////////////////////////////////////////////////////////
//
// 窍困 努贰胶俊辑 孤咆胶甫 郴器窍搁辑 犁沥狼秦具 茄促.
//
////////////////////////////////////////////////////////////////////////////////
void Thread::stop ()
	 throw ( Error )
{
	__BEGIN_TRY
		
	throw UnsupportedError();
		
	__END_CATCH
}

////////////////////////////////////////////////////////////////////////////////
//
// 漂沥 静饭靛啊 辆丰且 锭鳖瘤 泅犁 静饭靛甫 肛冕促.
//
// 咯扁辑 *泅犁* 静饭靛扼绰单 林狼窍扼. 静饭靛 A 啊 静饭靛 B 甫 扁促府绰 巴捞
// 酒聪骨肺, 捞 皋筋靛绰 static 捞绢具 茄促. 
//
// 捞锭 status 绰 绢恫 单捞鸥备炼扼档 啊瓷窍促. (structure, class...)
//
////////////////////////////////////////////////////////////////////////////////
void Thread::join ( const Thread & t )
     throw ( ThreadException , Error )
{ 
	__BEGIN_TRY

	pthread_join_ex ( t.getTID() , NULL );
	
	__END_CATCH
}

void Thread::join ( const Thread & t, void * status )
     throw ( ThreadException , Error )
{ 
	__BEGIN_TRY

	pthread_join_ex ( t.getTID() , &status );
	
	__END_CATCH
}

void Thread::join ( const Thread * t )
     throw ( ThreadException , Error )
{ 
	__BEGIN_TRY

	pthread_join_ex ( t->getTID() , NULL );
	
	__END_CATCH
}

void Thread::join ( const Thread * t, void * status )
     throw ( ThreadException , Error )
{ 
	__BEGIN_TRY

	pthread_join_ex ( t->getTID() , &status );
	
	__END_CATCH
}


////////////////////////////////////////////////////////////////////////////////
//
// 静饭靛甫 Detached 葛靛肺 官槽促.
//
// 绢恫 静饭靛啊 detached 葛靛老 版快, 辆丰且 锭 磊悼利栏肺 胶琶 殿狼 府家胶甫
// 馆吵窍霸 等促. 父距 酒聪扼搁 join()阑 烹秦辑 辆丰且 锭鳖瘤 扁促啡促啊 府家胶甫
// 馆吵窍霸 秦具 茄促. 捞犯霸 瞪 版快 矫胶袍狼 欺器刚胶啊 冻绢瘤霸 登骨肺, 措何盒
// 狼 静饭靛甸俊 乐绢辑 捞 皋筋靛甫 龋免秦林绰 巴捞 亮阑 巴捞促.
//
////////////////////////////////////////////////////////////////////////////////
void Thread::detach () 
     throw ( Error )
{
	__BEGIN_TRY

	pthread_detach_ex(m_TID);
	
	__END_CATCH
}


////////////////////////////////////////////////////////////////////////////////
//
// 泅犁 静饭靛甫 辆丰矫挪促.
//
// void pthread_exit ( void * retval );
//
// 鞘夸窍促搁 绢恫 单捞鸥备炼扼档 府畔秦辑 join 窍绰 静饭靛肺 逞辨 荐 乐促.
// (弊矾唱, 措何盒狼 静饭靛甸捞 detached 肺 倒酒埃促搁 NULL 阑 府畔窍绰 巴捞
// 亮阑 巴捞促.)
//
////////////////////////////////////////////////////////////////////////////////
void Thread::exit ( void * retval )
	 throw ()
{
	pthread_exit_ex( retval );
}


////////////////////////////////////////////////////////////////////////////////
//
// thread's start routine
//
// Thread 努贰胶狼 friend method 捞促.
//
// REENTRANT function 捞搁 郴啊 焊扁浚 救傈且 淀 茄单.. 怕荐绰 thread 按眉甫
// thread specific data 肺 父甸菌窜 富靖捞具. 龋泉. 静饭靛 胶琶 救俊辑 角青登搁 
// 肯寒窍霸 促弗 霸 登瘤 臼唱? 
//
// 窍困 努贰胶狼 run()阑 virtual肺 龋免窍扁 傈饶俊, 静饭靛狼 惑怕甫 RUNNING,
// EXIT肺 官操绰单 林狼窍扼. 老窜 EXIT肺 官差搁, 静饭靛绰 歹捞惑 犁矫累瞪 荐 绝促.
//
////////////////////////////////////////////////////////////////////////////////
void * start_routine ( void * derivedThread )
	   throw ()
{
	Thread * thread = (Thread *)derivedThread;
	
	// set thread's status to "RUNNING"
	thread->setStatus(Thread::RUNNING);

	// here - polymorphism used. (derived::run() called.)
	thread->run();
	
	// set thread's status to "EXIT"
	thread->setStatus(Thread::EXIT);

	Thread::exit(NULL);

	return NULL;	// avoid compiler's warning
}


////////////////////////////////////////////////////////////////////////////////
//
// 泅犁 静饭靛狼 TID 甫 舅酒辰促. static 糕滚窃荐捞促.
//
////////////////////////////////////////////////////////////////////////////////
TID Thread::self ()
	 throw ()
{
	return pthread_self_ex();
}


////////////////////////////////////////////////////////////////////////////////
//
// return thread information string
//
////////////////////////////////////////////////////////////////////////////////
string Thread::toString () const
       throw ()
{
	__BEGIN_TRY

	StringStream msg;
	msg << "Thread[" << (uint)m_TID<< "]" ;
	return msg.toString();
	
	__END_CATCH
}