设计一条简单的等待工作队列之软件模型设计与实现(三)-阿里云开发者社区

开发者社区> 云计算> 正文

设计一条简单的等待工作队列之软件模型设计与实现(三)

简介: http://blog.csdn.net/morixinguan/article/details/77758206 http://blog.csdn.net/morixinguan/article/details/77783311 在前面两篇文章中,可能考虑到后面需要设计复杂的工作队列,所以加入了线程机制。

http://blog.csdn.net/morixinguan/article/details/77758206

http://blog.csdn.net/morixinguan/article/details/77783311

在前面两篇文章中,可能考虑到后面需要设计复杂的工作队列,所以加入了线程机制。但由于设计的是一条简单的等待工作队列,却用到了线程,其实没有必要,线程在这个地方反倒是有点浪费资源,干脆可以不使用它,而将实现出队的操作如下,这样也可以实现同样的效果。

//逐个出队 
//出队 
queue_list *De_queue(queue_list *header)
{
	int ret ;
	int count = 0;
	int queue_length = 0;
	queue_list *p = header ;
	queue_list *prev  = NULL ;
	//如果当前节点的下一个节点为空,则返回空 
	if(header->next == NULL){
		free(header);
		header = NULL ;
		printf("header mem:0x%p\n",header);
		return header ;
	}
	prev = p ;
	p = p->next ;
	//执行工作 
	p->work_queue.queue_st(p);
	//延迟放在这里,一个工作执行完,有可能要等待一下,延迟可以放在这里 
	p->work_queue.work_sleep(p);
	//获取队列的长度 
	queue_length = Get_queue_Length(header);
	queue_length = queue_length - 1;
	header->queue_length = queue_length ;
	printf("当前队列的长度:%d  %d\n",queue_length,header->queue_length);
	prev->next = p->next ;
	free(p);
	return prev ;
}
//执行工作 
p->work_queue.queue_st(p);
//延迟放在这里,一个工作执行完,有可能要等待一下,延迟可以放在这里 
p->work_queue.work_sleep(p);

如果该任务没有产生延迟,则在创建任务结构体初始化的时候,将工作者结构体中的sec初始化为0即可,这样,在入队操作的时候,注册工作者结构体:

New->work_queue.sec = workArray->sec ;
New->work_queue.work_sleep = workArray->work_sleep ;

此时将sec注册为0,则work_sleep最终调用的sleep为0,即相当于不产生延迟,也可以判断sec,如果注册的sec为0,则不调用work_sleep()中的:

sleep(header->work_queue.sec);函数进行传参了,直接返回即可,这样就少调用sleep函数一次,提高了程序的效率:

//每一个工作所对应的时间 
void work_sleep(queue_list *header)
{
	if(0 == header->work_queue.sec)
		return ;
	sleep(header->work_queue.sec);
}
如果后面的队列设计得更加复杂,可能考虑到队列会产生阻塞,休眠的结果,则到时候需要设计一个唤醒队列的机制,就需要进程间通信的知识支持了。




版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

分享:
云计算
使用钉钉扫一扫加入圈子
+ 订阅

时时分享云计算技术内容,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。

其他文章