basictaskscheduler.h

rtsp协议的主要实现代码.对开发流媒体

// BasicTaskScheduler.h: interface for the BasicTaskScheduler class.
//
//////////////////////////////////////////////////////////////////////

#if !defined(AFX_BASICTASKSCHEDULER_H__872282DE_14EC_4BF7_8316_03A01D1B5450__INCLUDED_)
#define AFX_BASICTASKSCHEDULER_H__872282DE_14EC_4BF7_8316_03A01D1B5450__INCLUDED_

#if _MSC_VER > 1000
#pragma once
#endif // _MSC_VER > 1000
#include <list>
using namespace std;

#include "winsock.h"
#include "Type.h"

typedef void BackgroundHandlerProc(void* clientData, int mask);
#define SOCKET_READABLE    (1<<1)
#define SOCKET_WRITABLE    (1<<2)
#define SOCKET_EXCEPTION   (1<<3)

typedef struct 
{
	int socketNum;
	BackgroundHandlerProc* handlerProc;
	void* clientData;
}HanderSet;

class BasicTaskScheduler  
{
public:
	BasicTaskScheduler();
	virtual ~BasicTaskScheduler();
	//socket mutiply task scheduler
	void doEventLoop();
	void SingleStep();

	// For handling socket reads in the background:
	void turnOnBackgroundReadHandling(int socketNum,
		BackgroundHandlerProc* handlerProc,
		void* clientData);
	void turnOffBackgroundReadHandling(int socketNum);		
private:
	// To implement background reads:
	fd_set fReadSet;
	list<HanderSet *> fReadHandlers;
	int fLastHandledSocketNum;
};

#endif // !defined(AFX_BASICTASKSCHEDULER_H__872282DE_14EC_4BF7_8316_03A01D1B5450__INCLUDED_)