一、工作队列传参
在 Linux 内核的工作队列中,可以通过使用工作项的方式向工作队列传递参数。工作项是一个抽象的结构,可以用于封装需要执行的工作及其相关的参数。
首先我们定义工作项结构,如下所示,在结构体 struct work_data 中定义了需要传递给工作项处理函数的参数 a 和 b,然后定义一个类型为 struct work_data 的变量test_workqueue_work。
struct work_data {
struct work_struct test_work;
int a;
int b;
};
struct work_data test_workqueue_work;
接下来在模块初始化函数 interrupt_irq_init 中创建了一个工作队列test_workqueue和一个工作项 test_workqueue_work。
test_workqueue = create_workqueue("test_workqueue"); // 创建工作队列INIT_WORK(&test_workqueue_work.test_work, test_work); // 初始化工作项
然后在模块初始化函数中,为工作项的参数 a 和 b 赋值。
test_workqueue_work.a = 1;
test_workqueue_work.b = 2;
当中断触发时,在中断处理函数 test_interrupt 中,通过调用queue_work 函数将工作项test_workqueue_work.test_work 提交到工作队列 test_workqueue 中。
queue_work(test_workqueue, &test_workqueue_work.test_work);
然后工作项处理函数 test_work 定义了一个指针 pdata,将工作项转换为struct work_data结构,并通过该结构访问参数 a 和 b。如下所示:
void test_work(struct work_struct *work)
{
struct work_data *pdata;
pdata = container_of(work, struct work_data, test_work);
printk("a is %d\n", pdata->a);
printk("b is %d\n", pdata->b);
}
这样,当工作队列被调度执行时,工作项处理函数 test_work 将能够访问到传递给工作项的参数 a 和 b,并在内核日志中打印他们的值
注意,工作项处理函数中的 container_of 宏用于从工作项结构的指针获取整个structwork_data 结构的指针。这样可以通过指针偏移来访问工作项结构中的其他字段,例如参数a和 b。
二、代码示例
#include <linux/module.h>
#include <linux/init.h>
#include <linux/interrupt.h>
#include <linux/gpio.h>
#include <linux/delay.h>
#include <linux/workqueue.h>
int irq;
struct work_data
{
struct work_struct test_work;
int a;
int b;
};
struct work_data test_workqueue_work;
struct workqueue_struct *test_workqueue;
// 工作项处理函数
void test_work(struct work_struct *work)
{
struct work_data *pdata;
pdata = container_of(work, struct work_data, test_work);
printk("a is %d", pdata->a);
printk("b is %d", pdata->b);
}
// 中断处理函数
irqreturn_t test_interrupt(int irq, void *args)
{
printk("This is test_interrupt\n");
// 提交工作项到工作队列
queue_work(test_workqueue, &test_workqueue_work.test_work);
return IRQ_RETVAL(IRQ_HANDLED);
}
static int interrupt_irq_init(void)
{
int ret;
irq = gpio_to_irq(101); // 将GPIO映射为中断号
printk("irq is %d\n", irq);
// 请求中断
ret = request_irq(irq, test_interrupt, IRQF_TRIGGER_RISING, "test", NULL);
if (ret < 0)
{
printk("request_irq is error\n");
return -1;
}
// 创建工作队列
test_workqueue = create_workqueue("test_workqueue");
// 初始化工作项
INIT_WORK(&test_workqueue_work.test_work, test_work);
test_workqueue_work.a = 1;
test_workqueue_work.b = 2;
return 0;
}
static void interrupt_irq_exit(void)
{
free_irq(irq, NULL); // 释放中断
cancel_work_sync(&test_workqueue_work.test_work); // 取消工作项
flush_workqueue(test_workqueue); // 刷新工作队列
destroy_workqueue(test_workqueue); // 销毁工作队列
printk("bye bye\n");
}
module_init(interrupt_irq_init);
module_exit(interrupt_irq_exit);