21_BasicTaskScheduler基本任务调度器(一)——Live555源码阅读(一)任务调

原创
2015/06/16 09:01
阅读数 180

#21_BasicTaskScheduler基本任务调度器(一)——Live555源码阅读(一)任务调度相关类

[TOC]

这是Live555源码阅读的第二部分,包括了任务调度相关的三个类。任务调度是Live555源码中很重要的部分。

本文由乌合之众 lym瞎编,欢迎转载 my.oschina.net/oloroso

##BasicTaskScheduler基本任务调度器

BasicTaskScheduler很重要了,有了前面的铺垫,这个不会很难。 这个类的重点在于BasicTaskScheduler::SingleStep方法的实现。弄懂了这个,基于事件处理模型也就差不多弄懂了。 这里添加了四个数据成员,是用来select模型的。关于select模型,这里不解释了。在windows和unix/linux等平台都有相关的API,实现有点差别,但是原理是一致的。

	int fMaxNumSockets;		//最大的socket数,select调用时提高效率
	fd_set fReadSet;		//监控读操作的集合
	fd_set fWriteSet;		//监控写操作的集合
	fd_set fExceptionSet;	//监控有异常的集合

BasicTaskScheduler基本任务调度器

BasicTaskScheduler基本任务调度器

##BasicTaskScheduler基本任务调度器的定义

class BasicTaskScheduler : public BasicTaskScheduler0 {
public:
	static BasicTaskScheduler* createNew();
	virtual ~BasicTaskScheduler();

protected:
	BasicTaskScheduler();
	// called only by "createNew()"

protected:
	// Redefined virtual functions:

	/*
	*    设置select的超时时间为maxDelayTime(<=0 或大于一百万秒 时1百万秒)
	*    调用int selectResult = select(fMaxNumSockets, &readSet, &writeSet, &exceptionSet, &tv_timeToDelay);
	*    如果select出错返回,打印出错信息,并调用 internalError函数
	*    从处理程序描述链表中查找fLastHandledSocketNum代表的 处理程序描述对象指针,如果没找到,就在后面的while的时候从链表的头开始,否则从找到的位置开始
	*    从链表中取出处理程序描述节点对象,并调用其内部保存的处理程序
	*    设置fTriggersAwaitingHandling
	*    调用fDelayQueue.handleAlarm();
	*/
	virtual void SingleStep(unsigned maxDelayTime);
	// 添加到后台处理
	virtual void setBackgroundHandling(int socketNum, int conditionSet, BackgroundHandlerProc* handlerProc, void* clientData);
	// 从后台处理移出
	virtual void moveSocketHandling(int oldSocketNum, int newSocketNum);

protected:
	// To implement background operations: 实施后台操作
	int fMaxNumSockets;		//最大的socket数,select调用时提高效率
	fd_set fReadSet;		//监控读操作的集合
	fd_set fWriteSet;		//监控写操作的集合
	fd_set fExceptionSet;	//监控有异常的集合
};

##BasicTaskScheduler的构造与析构

BasicTaskScheduler的构造函数是protected权限的,其只在静态方法createNew中被调用。 创建的时候清零了四个成员,并调用了schedulerTickTask(this)

BasicTaskScheduler::BasicTaskScheduler()
: fMaxNumSockets(0) {
	FD_ZERO(&fReadSet);
	FD_ZERO(&fWriteSet);
	FD_ZERO(&fExceptionSet);

	schedulerTickTask(this); // ensures that we handle events frequently
}

###下面来介绍一下schedulerTickTask函数(调度滴答任务)

这个函数的作用就是将其参数转为(BasicTaskScheduler*)类型,然后调用scheduleDelayedTask来调度(创建)一个延时任务。有意思的是,这个延时任务程序就是这个函数自身,延时任务程序的参数也是其参数。延时时间是10毫秒。 这有点像是函数递归调用了。与之不同的是,如果不去调度任务,递归就是无效的。

#define MAX_SCHEDULER_GRANULARITY 10000 // 10 microseconds: We will return to the event loop at least this often
static void schedulerTickTask(void* clientData) {
	((BasicTaskScheduler*)clientData)->scheduleDelayedTask(MAX_SCHEDULER_GRANULARITY, schedulerTickTask, clientData);
}

析构函数是空的,就不说了。只要知道,在析构的时候会调用基类的析构函数。


展开阅读全文
打赏
0
0 收藏
分享
加载中
更多评论
打赏
0 评论
0 收藏
0
分享
返回顶部
顶部