1#define ARGLEN 50
2
3 #define Test(ARG) if(ARG == NULL){
4 printf("Invalid arg.......
");
5 return -1;
6 }
7
8 //队列任务节点
9 typedef struct node
10 {
11 char arg[ARGLEN+1]; //任务参数
12 void (* pfun)(char *); //任务处理函数
13 struct node *next; //next结点指针
14 }Q_NODE;
15
16 //队列信息
17 typedef struct queue_info
18 {
19 int max; //当前排队任务个数
20 Q_NODE *head; //队列头指针
21 Q_NODE *tail; //队列尾指针
22 }QUEUE_INFO;
23
24
25
26 //创建任务结点
27 static Q_NODE *__Create_Node__(void (*pfun)(char *), char *arg)
28 {
29 Q_NODE *new_node = (Q_NODE *)malloc(sizeof(Q_NODE));
30 if(NULL == new_node)
31 {
32 perror("Create_Node");
33 return NULL;
34 }
35
36 new_node->pfun = pfun;
37 strncpy(new_node->arg, arg, ARGLEN);
38
39 return new_node;
40 }
41
42
43 /****************************************************
44 *Des: 创建队列
45 *Ret: 成功返回0，失败返回-1
46 *******************************************************/
47 int Create_Queue(QUEUE_INFO **plist)
48 {
49 Test(plist);//函数入口检测
50
51 *plist = (QUEUE_INFO *)malloc(sizeof(QUEUE_INFO));
52 if(NULL == *plist)
53 {
54 perror("Create_Queue");
55 return -1;
56 }
57
58 (*plist)->head = NULL;
59 (*plist)->tail = NULL;
60 (*plist)->max = 0;
61
62 return 0;
63 }
64
65
66 /****************************************************
67 *Des: 判断队列是否为空
68 *Ret: 成功返回1，失败返回0
69 *******************************************************/
70 int Is_empty_Queue(QUEUE_INFO *plist)
71 {
72 return (NULL == plist->head);
73 }
74
75
76 /****************************************************
77 *Des: 清空队列
78 *Ret: 成功返回0，失败返回-1
79 *******************************************************/
80 int Empty_Queue(QUEUE_INFO *plist)
81 {
82 Test(plist);//函数入口检测
83
84 if(Is_empty_Queue(plist))
85 {
86 printf("the queue is emtpy!
");
87 return -1;
88 }
89
90 Q_NODE *fnode = NULL, *pnode = plist->head;
91 while(NULL != pnode)
92 {
93 fnode = pnode;
94 pnode = pnode->next;
95 free(fnode);
96 }
97
98 plist->max = 0;
99 plist->head = plist->tail = NULL;
100
101 return 0;
102 }
103
104 /****************************************************
105 *Des: 入队队操作
106 *Ret: 成功返回0，失败返回-1
107 *******************************************************/
108 int Push_Queue(QUEUE_INFO *plist, void (*pfun)(char *), char *arg)
109 {
110 //函数入口检测
111 if(NULL == plist || NULL == pfun || NULL == arg)
112 {
113 printf("Invalid arg........
");
114 return -1;
115 }
116
117 //创建结点
118 Q_NODE *new_node = __Create_Node__(pfun, arg);
119 if(NULL == new_node)
120 {
121 return -1;
122 }
123
124 //判断队列是否为空
125 if(Is_empty_Queue(plist))
126 {
127 plist->head = plist->tail = new_node;
128 }
129 else
130 {
131 plist->tail->next = new_node;
132 plist->tail = new_node;
133 }
134
135 plist->max++;
136
137 return 0;
138 }
139
140 /****************************************************
141 *Des: 出队操作(并执行任务)
142 *Ret: 成功返回0，失败返回-1
143 *******************************************************/
144 int Pop_Queue(QUEUE_INFO *plist)
145 {
146 Test(plist);//函数入口检测
147
148 //判断队列是否为空
149 if(Is_empty_Queue(plist))
150 {
151 printf("The queue is empty!
");
152 return -1;
153 }
154
155 Q_NODE *pnode = plist->head;
156 if(plist->head->next == NULL)//只有一个节点
157 {
158 plist->head = plist->tail = NULL;
159 }
160 else
161 {
162 plist->head = pnode->next;
163 }
164
165 //执行任务函数
166 (pnode->pfun)(pnode->arg);
167
168 free(pnode);
169 plist->max--;
170
171 return 0;
172 }
173
174
175 /****************************************************
176 *Des: 获取当前任务节点个数
177 *Ret: 成功返回0，失败返回-1
178 *******************************************************/
179 int Get_count_Queue(QUEUE_INFO *plist)
180 {
181 return plist->max;
182 }
183
184 /****************************************************
185 *Des: 销毁队列
186 *Ret: 成功返回0，失败返回-1
187 *******************************************************/
188 int Destory_Queue(QUEUE_INFO **plist)
189 {
190 Test(plist); //函数入口检测
191
192 //清空链表
193 if(Empty_Queue(*plist) < 0)
194 return -1;
195
196 free(*plist);
197
198 *plist = NULL;
199
200 return 0;
201 }
