thread.h

firtext搜索引擎源码

//
// Copyright(C) 2005--2006 Institute of Computing Tech, Chinese Academy of Sciences. 
// All rights reserved.
// This file is part of FirteX (www.firtex.org)
//
// Use of the FirteX is subject to the terms of the software license set forth in 
// the LICENSE file included with this software, and also available at
// http://www.firtex.org/license.html
//
// Author	: 郭瑞杰(GuoRuijie)
// Email	: [e-mail],[e-mail]
// Created	: 2005/11/18
//

#ifndef _THREAD_LINUX_H
#define _THREAD_LINUX_H

#include <pthread.h>
#include <assert.h>

#include "thread/Runnalble.h"


namespace firtex
{
	namespace thread
	{
		class CThread
		{
		public:
			CThread()
				: m_hThread(0)
				, m_pid(0)
			{
			}
			~CThread()
			{
			}		

		protected:
			static void* _dispatch(void *arg)
			{
				CRunnalble* task = reinterpret_cast<CRunnalble*>(arg);
				//m_pid = ::getpid();

				task->run();

				pthread_exit((void**)0);
				return (void*)0;
			}
		public:
			bool spawn(CRunnalble* task, bool bDetach = false) 
			{
				int nRet = pthread_create(&m_hThread, 0, _dispatch, task);
				if(bDetach)
					pthread_detach(m_hThread);
				return (nRet != 0);
			}			
			pid_t getpid(){return m_pid;}
		public:
			static int			kill(pthread_t hThread){ return pthread_cancel(hThread); }

			static int			detach(pthread_t hThread){ return pthread_detach(hThread); }			

			static void			exit(){ pthread_exit(0); }

			static pthread_t	self(){return pthread_self();}
			static void sleep(int ms)
			{
				if (ms <= 1)
					return;
				struct timespec t1, t2;
				t1.tv_sec = (ms / 1000);
				t1.tv_nsec = (ms % 1000) * 1000000;
				int result = nanosleep(&t1, &t2);
				if (result < 0) {
					t1 = t2;
					nanosleep(&t1, &t2);
				}
			}
		protected:
			pthread_t	m_hThread;	
			pid_t		m_pid;
		};
	}
}


#endif