`
bachmozart
  • 浏览: 111687 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

Linux queue.h之TAILQ队列分析

阅读更多
这两天想看看memcached的实现,所以先学习了libevent,使用起来还是比较简单的,其实是对select/poll/kqueue等的封装,学习libevent过程中又遇到了linux下队列的使用,简单分析如下,权当做记录:

libevent中的例子中使用的是FreeBSD下的queue.h,在linux的/usr/include/sys/queue.h也有该头文件,但是是一个缩减版本,而且没有看到queue 的access method,不知道是不是跟我们的linux服务器版本有关,没办法google了一下,找到了FreeBSD 下queue.h的定义,我们看一下tail queue的定义

#define TAILQ_HEAD(name, type)				\
struct name {						\
	struct type *tqh_first;	/* first element */	\
	struct type **tqh_last;	/* addr of last next element */\
}

#define TAILQ_ENTRY(type)					\
struct {							\
	struct type *tqe_next;	/* next element */		\
	struct type **tqe_prev;/* addr of previous next element*/ \
}                                                                

#define	TAILQ_INIT(head) do {				\
	(head)->tqh_first = NULL;				\
	(head)->tqh_last = &(head)->tqh_first;		\
} while (0)

#define TAILQ_INSERT_TAIL(head, elm, field) do {		\
	(elm)->field.tqe_next = NULL;			\
	(elm)->field.tqe_prev = (head)->tqh_last;		\
	*(head)->tqh_last = (elm);				\
	(head)->tqh_last = &(elm)->field.tqe_next;		\
} while (0)

#define	TAILQ_INSERT_BEFORE(listelm, elm, field) do {		\
	(elm)->field.tqe_prev = (listelm)->field.tqe_prev;	\
	(elm)->field.tqe_next = (listelm);			\
	*(listelm)->field.tqe_prev = (elm);			\
	(listelm)->field.tqe_prev = &(elm)->field.tqe_next;	\
} while (0)
#define	TAILQ_FIRST(head)		((head)->tqh_first)

#define	TAILQ_NEXT(elm, field)		((elm)->field.tqe_next)
....


我们就先分析上面的这些定义,先看个应用的例子

#include <stdio.h>
#include <stdlib.h>
#include "queue.h"

struct QUEUE_ITEM{
	int value;
	TAILQ_ENTRY(QUEUE_ITEM) entries;
};
TAILQ_HEAD(,QUEUE_ITEM) queue_head;
int main(int argc,char **argv){
	struct QUEUE_ITEM *item;
	struct QUEUE_ITEM *tmp_item;

	TAILQ_INIT(&queue_head);
	int i=0;
	for(i=5;i<10;i+=2){
		item=malloc(sizeof(item));
		item->value=i;
		TAILQ_INSERT_TAIL(&queue_head, item, entries);
	}
	
	struct QUEUE_ITEM *ins_item;
	ins_item=malloc(sizeof(ins_item));

	ins_item->value=100;
	TAILQ_INSERT_BEFORE(item,ins_item,entries);


	tmp_item=TAILQ_FIRST(&queue_head);
	printf("first element is %d\n",tmp_item->value);

	tmp_item=TAILQ_NEXT(tmp_item,entries);
	printf("next element is %d\n",tmp_item->value);

	tmp_item=TAILQ_NEXT(tmp_item,entries);
	printf("next element is %d\n",tmp_item->value);

	tmp_item=TAILQ_NEXT(tmp_item,entries);
	printf("next element is %d\n",tmp_item->value);

}


结果:
first element is 5
next element is 7
next element is 100
next element is 9


分析:
QUEUE_ITEM 是我们定义的存放在队列里的东东,简单起见只包括一个int值
TAILQ_ENTRY(QUEUE_ITEM) entries 主要是存放下一个对象和前一个对象的指针,具体见 header
 
根据头文件进行宏替换后,实际我们声明的是这样的结构:

 struct QUEUE_ITEM{
	int value;
        struct {			
            struct QUEUE_ITEM *tqe_next;	
	    struct QUEUE_ITEM **tqe_prev;
        }entries;
};
 


TAILQ_HEAD(,QUEUE_ITEM) queue_head; 实际是
struct {				
	struct QUEUE_ITEM *tqh_first;	
	struct QUEUE_ITEM **tqh_last;	
}queue_head;


接着我们定义了QUEUE_ITEM的两个指针变量item和tmp_item

TAILQ_INIT(&queue_head); 相当于是
do {
	(&queue_head)->tqh_first = NULL;				
	(&queue_head)->tqh_last = &(&queue_head)->tqh_first;		
} while (0);

head的初始化如 下图1

接着我们通过循环分配了几个元素,并赋值
TAILQ_INSERT_TAIL(&queue_head, item, entries); 相当于执行

do {
	(item)->entries.tqe_next = NULL;	
	(item)->entries.tqe_prev = (&queue_head)->tqh_last;			
	*(&queue_head)->tqh_last = (item);					
	(&queue_head)->tqh_last = &(item)->entries.tqe_next;			
} while (0);

也就是我们的循环执行下面代码段,结果分析见图2,3
for(i=5;i<10;i+=2){
	item=malloc(sizeof(item));
	item->value=i;
	do {
		(item)->entries.tqe_next = NULL;
		//首次执行相当于item->entries.tqe_prev=&(&queue_head)->tqh_first
		//以后执行相当于是(item)->entries.tqe_prev=&(前一个item)->entries.tqe_next;
		(item)->entries.tqe_prev = (&queue_head)->tqh_last;
		//首次执行相当于(&queue_head)->tqh_first=item
		//以后执行相当于是(前一个item)->entries.tqe_next=当前item
		*(&queue_head)->tqh_last = (item);
		(&queue_head)->tqh_last = &(item)->entries.tqe_next;
	} while (0);
}


最终建立的链表结构如图,下面看一下insert操作,经过宏替换后代码如下

struct QUEUE_ITEM *ins_item;
ins_item=malloc(sizeof(ins_item));
ins_item->value=100;

do {
	(ins_item)->entries.tqe_prev = (item)->entries.tqe_prev;
	(ins_item)->entries.tqe_next = (item);
	//这句话体现了TAILQ的特色,tqe_prev是前一个元素的下个元素地址,
	//所以正好应该是当前插入item的地址
	*(item)->entries.tqe_prev = (ins_item);
	(item)->entries.tqe_prev = &(ins_item)->entries.tqe_next;
} while (0);





总结:TAILQ的最大特点就是每个entry的二级指针tqe_prev其存放的是前一个元素的下个元素地址,呵呵,听起来都很拗口
我现在就是不知道为什么linux的queue.h只有建立tailq的宏定义而缺少所有的access method,初涉linux c编程,请大家指教

附经过宏替换后的所有代码
#include "stdio.h"
#include "stdlib.h"
struct QUEUE_ITEM{
	int value;
	struct {
		struct QUEUE_ITEM *tqe_next;
		struct QUEUE_ITEM **tqe_prev;
	}entries;
};
struct {
	struct QUEUE_ITEM *tqh_first;
	struct QUEUE_ITEM **tqh_last;
}queue_head;

int main(int argc,char **argv){
	struct QUEUE_ITEM *item;
	struct QUEUE_ITEM *tmp_item;

	do {
		(&queue_head)->tqh_first = NULL;
		(&queue_head)->tqh_last = &(&queue_head)->tqh_first;
	} while (0);

	int i=0;
	for(i=5;i<10;i+=2){
		item=malloc(sizeof(item));
		item->value=i;
		do {
			(item)->entries.tqe_next = NULL;
			//首次执行相当于item->entries.tqe_prev=&(&queue_head)->tqh_first
			//以后执行相当于是(item)->entries.tqe_prev=&(前一个item)->entries.tqe_next;
			(item)->entries.tqe_prev = (&queue_head)->tqh_last;
			//首次执行相当于(&queue_head)->tqh_first=item
			//以后执行相当于是(前一个item)->entries.tqe_next=当前item
			*(&queue_head)->tqh_last = (item);
			(&queue_head)->tqh_last = &(item)->entries.tqe_next;
		} while (0);
	}

	struct QUEUE_ITEM *ins_item;
	ins_item=malloc(sizeof(ins_item));

	ins_item->value=100;
	do {
		(ins_item)->entries.tqe_prev = (item)->entries.tqe_prev;
		(ins_item)->entries.tqe_next = (item);
		*(item)->entries.tqe_prev = (ins_item);
		(item)->entries.tqe_prev = &(ins_item)->entries.tqe_next;
	} while (0);

	tmp_item=((&queue_head)->tqh_first);
	printf("first element is %d\n",tmp_item->value);

	tmp_item=((tmp_item)->entries.tqe_next);
	printf("next element is %d\n",tmp_item->value);

	tmp_item=((tmp_item)->entries.tqe_next);
	printf("next element is %d\n",tmp_item->value);

	tmp_item=((tmp_item)->entries.tqe_next);
	printf("next element is %d\n",tmp_item->value);

}

  • 大小: 33.1 KB
分享到:
评论
2 楼 bachmozart 2008-12-15  
rubynroll 写道
>> 不知道为什么linux的queue.h只有建立tailq的宏定义而缺少所有的access method ....

Linux有更好用的list(see: include/linux/list.h), 请看右上角。

看到了,是有一个doubly linked list,多谢指点,呵呵
1 楼 rubynroll 2008-12-15  
>> 不知道为什么linux的queue.h只有建立tailq的宏定义而缺少所有的access method ....

Linux有更好用的list(see: include/linux/list.h), 请看右上角。

相关推荐

    linux上queue.h 队列的实现

    linux上queue.h,可用于一直实现双向链表.亲测非常好用 linux上queue.h,可用于一直实现双向链表.亲测非常好用 linux上queue.h,可用于一直实现双向链表.亲测非常好用

    C语言头文件 QUEUE.H

    C语言头文件 QUEUE.HC语言头文件 QUEUE.HC语言头文件 QUEUE.HC语言头文件 QUEUE.HC语言头文件 QUEUE.HC语言头文件 QUEUE.HC语言头文件 QUEUE.HC语言头文件 QUEUE.HC语言头文件 QUEUE.HC语言头文件 QUEUE.HC语言...

    Arduino-Arduino-Queue.h.zip

    Arduino-Arduino-Queue.h.zip,用于ARDUIO嵌入式项目的通用C 循环队列,Arduino是一家开源软硬件公司和制造商社区。Arduino始于21世纪初,深受电子制造商的欢迎,Arduino通过开源系统提供了很多灵活性。

    queue.h队列的定义以及一些说明

    队列的声明---这个是 c prime plus 17章的学习内容,这部分代码是队列的声明 biubiu

    Using_Java_Queue.zip_java队列

    System.out.println("\nAfter poll, queue is empty: " + queue.isEmpty()); } } ``` 在这个例子中,我们创建了一个LinkedList队列,并使用offer()方法添加了三个元素。然后通过peek()和poll()方法遍历并移除队列...

    queue.h ---- TAILQ_FOREACH_SAFE

    改进了linux tailq队列下在遍历时删除多个元素的问题。可以使用TAILQ_FOREACH_SAFE下面进行节点删除操作。不会出现野指针问题

    解决Can't locate ThreadQueue.pm

    标题 "解决Can't locate ThreadQueue.pm" 指出的问题是,在尝试运行一个Perl脚本时,系统无法找到模块“ThreadQueue”。这个问题通常出现在你试图使用一个依赖于ThreadQueue模块的Perl程序,但该模块尚未在你的Perl...

    Basic_Operations_queue.rar_c 队列_队列

    if ((rear + 1) % QUEUE_SIZE == front) { // 队列满 printf("Queue is full.\n"); return; } queue[rear] = data; // 添加元素 rear = (rear + 1) % QUEUE_SIZE; // 更新队尾指针 } ``` 3. **出队**:出队...

    CircularQueue.h

    CircularQueue.h

    stackqueue.h

    stackqueue.h

    lock_free_queue.rar

    3. `lf_queue.h`:这是无锁队列的头文件,定义了无锁队列的接口,包括结构体定义、函数原型等。开发人员可以包含这个头文件来在其他模块中使用无锁队列。 4. `makefile`:这是一个构建脚本,用于编译和链接上述...

    uvc_queue.zip_usb uvc

    这个压缩包包含的文件`uvc_queue.c`、`uvc.h`和`uvc_queue.h`与UVC驱动程序中的缓冲器管理密切相关,这是理解UVC驱动工作原理的关键部分。 1. **UVC驱动架构**: UVC驱动通常由几个关键部分组成:设备识别、设备...

    T_Queue_Malloc.rar_环形队列

    `mainT2.c`是主程序文件,它导入了`circular_queue.h`并实现了测试用例,通过实际操作环形队列来验证其正确性。这个文件可能包含了创建环形队列、入队、出队、显示队列状态等操作的示例。 最后,`T2.exe`是编译后的...

    队列函数 Queue.zip

    这个"Queue.zip"压缩包包含了一个精心编写的C语言程序,供学习者深入理解队列的实现细节。 首先,让我们了解队列的基本概念。队列是一种线性数据结构,它的主要操作包括入队(enqueue)和出队(dequeue)。入队是在...

    PHP消息队列服务php-queue.zip

    php-queue 是 PHP开发的磁盘存储消息队列服务,基于leveldb和swoole ,在4核机器上处理能力可以达到2.5W/s 。leveldb: ...

    PHP队列系统

    (主要提供思路) 简单的队列系统执行队列端 队列服务器采用HTTPSQS 管理: 帮助:php Kernel/bin/queue.php help 启动所有队列:php Kernel/bin/queue.php start...停止指定队列:php Kernel/bin/queue.php stop xxxx

    uvc_queue.rar_uvc

    这个"uvc_queue.rar_uvc"的文件可能是与UVC设备驱动程序相关的源代码压缩包,其中包含了"uvc_queue.c"和"uvc_queue.h"两个文件。这些文件通常用于处理UVC设备的数据队列操作。 `uvc_queue.c`可能包含实现UVC设备...

    ThreadQueue.zip

    标题“ThreadQueue.zip”表明这是一个关于`Qt`线程任务队列的示例项目,可能包含了实现代码和详细的解释。`Qt`线程任务队列主要利用了`QThread`和`Qt`的异步事件驱动模型,它允许开发者将耗时的任务放入队列,由后台...

    Queue.h

    Queue.h

    Circular_Queue.rar

    首先,让我们从`circular_queue.h`这个头文件开始。这个文件通常会定义循环队列的数据结构和相关的函数声明。在C语言中,循环队列通常通过数组实现,数组的首尾相连形成一个环状结构。队列的头部是元素出队的位置,...

Global site tag (gtag.js) - Google Analytics