队列是c中经常需要使用的数据结构,写一个0bug的队列header对于将来的代码复用很有用。
我选择使用bsd实现的队列结构,一是因为它实现简单,一个头文件里全是宏定义,二是因为它是BSD协议,代码可以随便用。
在linux下,在<sys/queue.h>里定义了五个数据结构,分别是simple linked list, list, simple queue, tail queue和circuled queue
这里介绍使用simple queue,因为simple可以支持在队头队尾分别进行插入和删除,足够简单,基本足够我日常使用。(我基本上用无优先级的队列)
下面这段代码定义task_t的队列,分别赋值0, 1, 2, 3, 4。然后删除3,最后循环打印这个队列
#include <stdio.h>
#include <stdlib.h>
#include <sys/queue.h>
struct task_t {
int data;
SIMPLEQ_ENTRY(task_t) entries;
};
// declare type
SIMPLEQ_HEAD(taskqueue_t, task_t);
// define variant
struct taskqueue_t task_head;
int main(int argc, const char *argv[])
{
struct task_t t[5];
int i;
SIMPLEQ_INIT(&task_head);
for (i = 0; i < 5; i++)
{
memset(&t[i], 0, sizeof(t[i]));
t[i].data = i;
SIMPLEQ_INSERT_TAIL(&task_head, &t[i], entries);
}
// delete one element in the queue
SIMPLEQ_REMOVE(&task_head, &t[3], task_t, entries);
struct task_t *item;
SIMPLEQ_FOREACH(item, &task_head, entries) {
printf("data: %i\n", item->data);
}
return 0;
}
- 我不喜欢把变量声明和定义写一起,分开比较好。
- queue.h里面大多是使用指针的宏,所以在写宏的时候注意传指针就不容易错。
- SIMPLEQ_ENTRY(task_t)定义了每个元素与其它前后元素相联系的结构体,可以通过它找到前后元素,至于这个结构体叫什么名字,都无所谓。(所以是否可以把这个结构体写进宏里更能精简代码呢?我觉得完全是可以的)
- 如果queue.h可以有pop的宏就好了,查询节点再删除这样的操作显得很麻烦
又想了一下,觉得后面两个问题实在很麻烦,我还是琢磨自己写一个更方便的header好了= =
分享到:
相关推荐
传统的队列实现通常采用链表或动态数组,但这里我们关注的是一个特别的实现——aqueue-noptr,它使用静态数组作为基础,旨在提供更高效的内存管理和性能优化。 首先,让我们理解“就地”(in-place)这一概念。在...
18. 基本数据结构:compat/sys下的两个源文件queue.h和_libevent_time.h是Libevent基本数据结构的实现,包括链表、双向链表、队列等。 19. 实用网络库:http和evdns是基于Libevent实现的http服务器和异步dns查询库...
C语言中处理时间主要使用`time.h`头文件提供的接口,如`time()`、`localtime()`、`strftime()`等。例如,获取当前时间并格式化输出的代码如下: ```c #include <time.h> #include <stdio.h> int main() { time_t ...
堆是一种特殊的树形数据结构,通常用于实现优先队列(Priority Queue)。在计算机科学中,优先队列允许插入元素并快速删除具有最高优先级的元素。堆优先队列的实现通常基于二叉堆,它是一个近似完全二叉树的结构,...
最后,了解和掌握套接字API(如BSD Sockets)是实现Socket异步通信的基础。这些API提供了创建Socket、绑定、监听、连接、发送、接收等基本操作,是构建网络应用的核心工具。 总的来说,Socket异步通信结合线程和...
为了使用libdispatch,开发者通常会导入`#import <dispatch/dispatch.h>`头文件,然后使用如`dispatch_queue_create()`、`dispatch_async()`和`dispatch_sync()`等API。对于更高级的用例,如自定义调度策略或监控...
通过实验,可以加深对这些通信机制的理解,如创建管道并实现简单数据传递,设置和使用信号量以控制共享资源,创建和操作消息队列,以及在多个进程中利用共享内存共享数据等。 总的来说,熟练掌握Linux进程间通信的...
可以通过dispatch_queue_create函数创建自定义的串行队列,使用dispatch_get_main_queue()函数获得主队列,而主队列中的任务应保证与UI操作相关。此外,还可以通过dispatch_get_global_queue函数获得全局并发队列,...
3. **消息队列(Message Queue)**: - 消息队列是消息的链表,分为POSIX和System V两种类型。进程可以向队列添加或读取消息,提供了一种结构化的数据交换方式,避免了管道的无格式字节流和信号的低信息承载能力。 ...
其中sk_buff含义为套接字缓冲区,定义在/include/linux/skbuff.h中。 5. 数据包发送和接收 要从协议层向设备发送数据,需要使用dev_queue_xmit函数。这个函数对数据进行排队,并交由底层设备驱动程序发送数据包。...
| sock_queue_rcv_skbinclude/net/sock.h // 队列中接收数据报 | | udp_queue_rcv_skbnet/ipv4/udp.c // UDP层接收数据报 | | udp_rcvnet/ipv4/udp.c // UDP层处理接收到的数据报 | | ip_local_deliver_finishnet/...
#include<stdio.h> #include<stdlib.h> #include<unistd.h> #include<errno.h> #include<string.h> #define MAX 4096 int main(int argc, char *argv[]) { int pipefd[2], recvBytes, sendBytes; pid_t pid; ...
在TCP包的处理中,`netif_rx`会将数据包加入队列,`skb_queue_tail`负责将数据包插入队列,同时更新队列长度。`cpu_raise_softirq`设置软中断标志位,以便稍后处理。当`NET_RX_SOFTIRQ`被激活时,`net_rx_action`...
在Linux中,常见的进程间通信(IPC)机制包括管道(Pipe)、消息队列(Message Queue)、信号量(Semaphore)和共享内存(Shared Memory)。"pmsg"可能是一个具体实现或解释了这些机制之一的代码示例。 在这个源码...
1. BSD Socket层:这是用户空间应用程序与内核网络接口交互的起点。`struct socket`结构体在内核中代表了一个socket。主要处理如socket创建、绑定、监听、接受等操作,相关代码位于`/net/socket.c`和`/...
在工作队列系统上部署Dask 轻松部署Dask在诸如PBS,Slurm或SGE之类的工作排队系统上分发。 请参阅以获取更多信息。 执照 新的BSD。 请参阅。
消息队列(Message Queue) - **消息队列** 是一种更灵活的进程间通信方式,可以存储任意长度的消息。每个消息队列都有一个标识符,进程可以通过这个标识符向队列发送消息,也可以从中读取消息。 ##### 4. 共享...