socketthread.cpp

线程池+socket

/**************************************************************
 * SocketThread.cpp : implementation file
 * Copyright 2004-2005 TianMuLingHang
 * All rights reserved.
 * Author: Zeng Wenchuan
 * Date:   Jan 9, 2005
 * Modify: 
 * Date:
 * Email:  [e-mail]
 * Site:   http://zeng_aven.go.nease.net/
 *************************************************************/
#include "SocketThread.h"
#include "SocketBase.h"

CSocketThread::CSocketThread() : 
	m_pSocket(NULL), m_pThreadPool(NULL)
{
}

CSocketThread::~CSocketThread()
{
}

void CSocketThread::Run()
{
	SocketThread();
}

void CSocketThread::SocketThread()
{
	for (;;)
	{
		pthread_mutex_lock(&m_mutex);
		pthread_cond_wait(&m_cond, &m_mutex);
		
		m_pSocket->SelectMsg();
		
		m_pThreadPool->MoveToIdleList(this);	
		SetState(Thread_Idle);
		pthread_mutex_unlock(&m_mutex);
	}
}

void CSocketThread::SetNewSocket(CSocketBase *pSocket)
{
	m_pSocket = pSocket;
	Wakeup();
}