什么是等待队列
在 Linux驱动程序中，阻塞进程可以使用等待队列来实现。等待队列是实现阻塞和唤醒的
内核机制，等待队列以双循环链表为基础结构，其中链表头和链表项两部分别表示等待队列头
和等待队列元素，如图所示。
等待队列使用方法
步骤一：初始化等待队列头，并将条件置成假(condition=0)。
步骤二：在需要阻塞的地方调用wait_event()，使进程进入休眠状态。
步骤三：当条件满足时，需要解除休眠，先将条件设置成真(condition=1)，然后调用wake_up()
函数唤醒等待队列中的休眠进程。
实验代码wq.c
#include <linux/cdev.h> #include <linux/fs.h> #include <linux/init.h> #include <linux/io.h> #include <linux/kdev_t.h> #include <linux/module.h> #include <linux/uaccess.h> #include <linux/wait.h> struct device_test { dev_t dev_num; // 设备号 int major; // 主设备号 int minor; // 次设备号 struct cdev cdev_test; // cdev struct class *class; // 类 struct device *device; // 设备 char kbuf[32]; int flag; // 标志位 }; struct device_test dev1; DECLARE_WAIT_QUEUE_HEAD(read_wq); // 声明等待队列头 /*打开设备函数*/ static int cdev_test_open(struct inode *inode, struct file *file) { file->private_data = &dev1; // 设置私有数据 printk("This is cdev_test_open\r\n"); return 0; } /*向设备写入数据函数*/ static ssize_t cdev_test_write(struct file *file, const char __user *buf, size_t size, loff_t *off) { struct device_test *test_dev = (struct device_test *)file->private_data; if (copy_from_user(test_dev->kbuf, buf, size) != 0) { printk("copy_from_user error\r\n"); return -1; } test_dev->flag = 1; // 将条件置 1 wake_up_interruptible(&read_wq); // 唤醒等待队列中的休眠进程 return size; } /*从设备读取数据*/ static ssize_t cdev_test_read(struct file *file, char __user *buf, size_t size, loff_t *off) { struct device_test *test_dev = (struct device_test *)file->private_data; // 可中断的阻塞等待，使进程进入休眠态 wait_event_interruptible(read_wq, test_dev->flag); if (copy_to_user(buf, test_dev->kbuf, size) != 0) { printk("copy_to_user error\r\n"); return -1; } test_dev->flag = 0; // 重置标志位 return size; } static int cdev_test_release(struct inode *inode, struct file *file) { return 0; } /*设备操作函数*/ struct file_operations cdev_test_fops = { .owner = THIS_MODULE, .open = cdev_test_open, .read = cdev_test_read, .write = cdev_test_write, .release = cdev_test_release, }; static int __init chr_fops_init(void) // 驱动入口函数 { int ret; /*1 创建设备号*/ ret = alloc_chrdev_region(&dev1.dev_num, 0, 1, "alloc_name"); if (ret < 0) { goto err_chrdev; } printk("alloc_chrdev_region is ok\n"); dev1.major = MAJOR(dev1.dev_num); // 获取主设备号 dev1.minor = MINOR(dev1.dev_num); // 获取次设备号 printk("major is %d \r\n", dev1.major); printk("minor is %d \r\n", dev1.minor); /*2 初始化 cdev*/ dev1.cdev_test.owner = THIS_MODULE; cdev_init(&dev1.cdev_test, &cdev_test_fops); /*3 添加一个 cdev,完成字符设备注册到内核*/ ret = cdev_add(&dev1.cdev_test, dev1.dev_num, 1); if (ret < 0) { goto err_chr_add; } /*4 创建类*/ dev1.class = class_create(THIS_MODULE, "test"); if (IS_ERR(dev1.class)) { ret = PTR_ERR(dev1.class); goto err_class_create; } /*5 创建设备*/ dev1.device = device_create(dev1.class, NULL, dev1.dev_num, NULL, "test"); if (IS_ERR(dev1.device)) { ret = PTR_ERR(dev1.device); goto err_device_create; } return 0; err_device_create: class_destroy(dev1.class); err_class_create: cdev_del(&dev1.cdev_test); err_chr_add: unregister_chrdev_region(dev1.dev_num, 1); err_chrdev: return ret; } static void __exit chr_fops_exit(void) // 驱动出口函数 { device_destroy(dev1.class, dev1.dev_num); class_destroy(dev1.class); cdev_del(&dev1.cdev_test); unregister_chrdev_region(dev1.dev_num, 1); } module_init(chr_fops_init); module_exit(chr_fops_exit); MODULE_LICENSE("GPL v2"); MODULE_AUTHOR("topeet");编写应用程序read.c
#include <stdio.h> #include <sys/types.h> #include <sys/stat.h> #include <fcntl.h> #include <unistd.h> #include <stdlib.h> int main(int argc, char *argv[]) { int fd; char buf1[32] = {0}; char buf2[32] = {0}; fd = open("/dev/test", O_RDWR); // 打开 led 驱动 if (fd < 0) { perror("open error \n"); return fd; } printf("read before \n"); read(fd, buf1, sizeof(buf1)); // 从/dev/test 文件读取数据 printf("buf is %s \n", buf1); printf("read after \n"); close(fd); // 关闭文件 return 0; }编写应用程序write.c
#include <stdio.h> #include <sys/types.h> #include <sys/stat.h> #include <fcntl.h> #include <unistd.h> #include <stdlib.h> #include <string.h> int main(int argc, char *argv[]) { int fd; char buf1[32] = {0}; char buf2[32] = "nihao"; fd = open("/dev/test", O_RDWR); // 打开 led 驱动 if (fd < 0) { perror("open error \n"); return fd; } printf("write before \n"); write(fd, buf2, sizeof(buf2)); // 向/dev/test 文件写入数据 printf("write after\n"); close(fd); // 关闭文件 return 0; }Makefile
export ARCH=arm64#设置平台架构 export CROSS_COMPILE=/home/alientek/rk3568_linux5.10_sdk/buildroot/output/rockchip_atk_dlrk3568/host/bin/aarch64-buildroot-linux-gnu-#交叉编译器前缀 obj-m += wq.o #此处要和你的驱动源文件同名 KDIR :=/home/alientek/rk3568_linux5.10_sdk/kernel #这里是你的内核目录 PWD ?= $(shell pwd) all: make -C $(KDIR) M=$(PWD) modules #make 操作 clean: make -C $(KDIR) M=$(PWD) cleanread应用程序进程阻塞
然后输入./write命令运行write可执行文件，如上图所示，使用write()函数向设备写入
数据，唤醒等待队列中的休眠进程。
