Linux驅(qū)動(dòng)等待隊(duì)列與poll機(jī)制

? 當(dāng)我們?cè)诓僮髟O(shè)備時(shí)，我們經(jīng)常遇到當(dāng)設(shè)備獲取不到資源時(shí)就會(huì)掛起進(jìn)程，當(dāng)設(shè)備資源滿足要求時(shí)再喚醒進(jìn)程(如read函數(shù)，當(dāng)讀不到數(shù)據(jù)時(shí)就會(huì)掛起，讀到了數(shù)據(jù)則可立刻返回)。這種通過(guò)阻塞方式訪問(wèn)設(shè)備，可以極大的減輕CPU負(fù)荷，在進(jìn)程掛起是可以讓CPU去執(zhí)行其它資源。而通過(guò)等待隊(duì)列的方式就可實(shí)現(xiàn)進(jìn)程阻塞，滿足要求時(shí)再喚醒進(jìn)程。

因?yàn)樽枞倪M(jìn)程會(huì)進(jìn)入休眠狀態(tài)， 因此， 必須確保有一個(gè)地方能夠喚醒休眠的進(jìn)程。 喚醒進(jìn)程的地方最大可能發(fā)生在中斷里面， 因?yàn)?a target="_blank">硬件資源獲得的同時(shí)往往伴隨著一個(gè)中斷。

在內(nèi)核中，等待隊(duì)列的合理應(yīng)用可以極大的提供CPU執(zhí)行效率，尤其是在中斷處理、進(jìn)程同步、定時(shí)等場(chǎng)合?？梢允褂玫却?duì)列實(shí)現(xiàn)阻塞進(jìn)程的喚醒。它以隊(duì)列為基礎(chǔ)數(shù)據(jù)結(jié)構(gòu)，與進(jìn)程調(diào)度機(jī)制緊密結(jié)合，能夠用于實(shí)現(xiàn)內(nèi)核中的異步事件通知機(jī)制，同步對(duì)系統(tǒng)資源的訪問(wèn)等。

等待隊(duì)列是一種基于資源狀態(tài)的線程管理的機(jī)制，它可以使線程在資源不滿足的情況下處于休眠狀態(tài)，讓出CPU資源，而資源狀態(tài)滿足時(shí)喚醒線程，使其繼續(xù)進(jìn)行業(yè)務(wù)的處理。

等待隊(duì)列（wait queue）用于使線程等待某一特定的事件發(fā)生而無(wú)需頻繁的輪詢，進(jìn)程在等待期間睡眠，在某件事發(fā)生時(shí)由內(nèi)核自動(dòng)喚醒。它是以雙循環(huán)鏈表為基礎(chǔ)數(shù)據(jù)結(jié)構(gòu)，與進(jìn)程的休眠喚醒機(jī)制緊密相聯(lián)，是實(shí)現(xiàn)異步事件通知、跨進(jìn)程通信、同步資源訪問(wèn)等技術(shù)的底層技術(shù)支撐。

1.等待隊(duì)列相關(guān)接口函數(shù)

??在Linux中，等待隊(duì)列是由等待隊(duì)列頭wait_queue_head_t *q進(jìn)行管理，結(jié)構(gòu)體信息如下：

struct __wait_queue_head {
	spinlock_t lock;
	struct list_head task_list;
};

1.1 等待隊(duì)列頭初始化

??初始化等待隊(duì)列頭可以靜態(tài)初始化或者動(dòng)態(tài)初始化

#define DECLARE_WAIT_QUEUE_HEAD(name)
功能： 靜態(tài)初始化等待隊(duì)列頭
參數(shù)： name --等待隊(duì)列頭結(jié)構(gòu)體變量名

#define init_waitqueue_head(q)
功能： 靜態(tài)初始化等待隊(duì)列頭
參數(shù)： q–等待隊(duì)列頭結(jié)構(gòu)體指針變量

??注意：動(dòng)態(tài)初始化時(shí)需要手動(dòng)創(chuàng)建一個(gè)等待隊(duì)列頭結(jié)構(gòu)體變量，而靜態(tài)初始化只需要填入等待隊(duì)列頭變量名即可。即：
??DECLARE_WAIT_QUEUE_HEAD(q)等價(jià)于下面兩行代碼：

wait_queue_head_t q;
init_waitqueue_head(&q);//動(dòng)態(tài)初始化等待隊(duì)列頭

1.2 休眠進(jìn)程

??休眠進(jìn)程由兩類函數(shù)：可中斷休眠 和 不可中斷休眠?？芍袛嘈菝呖芍袛嘈菝呤强梢酝ㄟ^(guò)信號(hào)方式喚醒；不可中斷休眠則在休眠期間無(wú)法收到信號(hào)(如CTRL+C、CTRL+)，信號(hào)將會(huì)被阻塞，必須等待進(jìn)程喚醒后才能響應(yīng)信號(hào)。

• 可中斷休眠函數(shù)

#define wait_event_interruptible(wq, condition)				
({									
	int __ret = 0;							
	if (!(condition))						
		__wait_event_interruptible(wq, condition, __ret);	
	__ret;								
})
//不可中斷休眠，但可以指定超時(shí)時(shí)間
#define __wait_event_timeout(wq, condition, ret)			
do {									
	DEFINE_WAIT(__wait);						
									
	for (;;) {							
		prepare_to_wait(&wq, &__wait, TASK_UNINTERRUPTIBLE);	
		if (condition)						
			break;						
		ret = schedule_timeout(ret);				
		if (!ret)						
			break;						
	}								
	finish_wait(&wq, &__wait);					
} while (0)

??wq為等待隊(duì)列頭；
??condition為喚醒標(biāo)志，condition為真喚醒進(jìn)程，為假則為休眠狀態(tài)；
??ret為要指定的超時(shí)時(shí)間，單位為時(shí)鐘節(jié)拍jiffies

• 不可中斷休眠函數(shù)

#define wait_event(wq, condition) 					
do {									
	if (condition)	 						
		break;							
	__wait_event(wq, condition);					
} while (0)
//可中斷休眠，但可以指定超時(shí)時(shí)間
#define __wait_event_interruptible_timeout(wq, condition, ret)		
do {									
	DEFINE_WAIT(__wait);						
									
	for (;;) {							
		prepare_to_wait(&wq, &__wait, TASK_INTERRUPTIBLE);	
		if (condition)						
			break;						
		if (!signal_pending(current)) {				
			ret = schedule_timeout(ret);			
			if (!ret)					
				break;					
			continue;					
		}							
		ret = -ERESTARTSYS;					
		break;							
	}								
	finish_wait(&wq, &__wait);					
} while (0)

??wq為等待隊(duì)列頭；
??condition為喚醒標(biāo)志，condition為真喚醒進(jìn)程，為假則為休眠狀態(tài)。
??ret為要指定的超時(shí)時(shí)間，單位為時(shí)鐘節(jié)拍jiffies

1.3 喚醒進(jìn)程

??喚醒休眠進(jìn)程函數(shù)分為兩類：一是可喚醒可中斷和不可中斷休眠進(jìn)程；二是只能喚醒可中斷休眠進(jìn)程。
??喚醒進(jìn)程函數(shù)一般是在設(shè)備獲取到資源時(shí)調(diào)用，調(diào)用位置常處于中斷處理函數(shù)中。

//可喚醒可中斷和不可中斷休眠進(jìn)程
#define wake_up(x)			__wake_up(x, TASK_NORMAL, 1, NULL)  //隨機(jī)喚醒一個(gè)休眠進(jìn)程
#define wake_up_nr(x, nr)		__wake_up(x, TASK_NORMAL, nr, NULL)  //喚醒多個(gè)休眠進(jìn)程
#define wake_up_all(x)			__wake_up(x, TASK_NORMAL, 0, NULL)  //喚醒所有休眠進(jìn)程
//只能喚醒可中斷休眠進(jìn)程
#define wake_up_interruptible(x)	__wake_up(x, TASK_INTERRUPTIBLE, 1, NULL) //隨機(jī)喚醒一個(gè)休眠進(jìn)程
#define wake_up_interruptible_nr(x, nr)	__wake_up(x, TASK_INTERRUPTIBLE, nr, NULL) //喚醒多個(gè)休眠進(jìn)程
#define wake_up_interruptible_all(x)	__wake_up(x, TASK_INTERRUPTIBLE, 0, NULL) //喚醒所有休眠進(jìn)程

1.4 等待隊(duì)列應(yīng)用示例
下面以按鍵為例，實(shí)現(xiàn)中斷方式按鍵檢測(cè)，通過(guò)工作隊(duì)列處理底半部分代碼，雜項(xiàng)設(shè)備框架實(shí)現(xiàn)設(shè)備注冊(cè)。在按鍵的工作函數(shù)中喚醒休眠進(jìn)程。在位獲取到按鍵信息時(shí)將進(jìn)程休眠。
Linux中斷編程參考：https://blog.csdn.net/weixin_44453694/article/details/126812705

#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 

#include 
#include 
#include 
#define KEY_CNT sizeof(key_info)/sizeof(struct key_info)  //按鍵個(gè)數(shù)

//static wait_queue_head_t key_q;/*等待隊(duì)列頭(動(dòng)態(tài)初始化時(shí)需要定義)*/
DECLARE_WAIT_QUEUE_HEAD(key_q);//靜態(tài)初始化等待隊(duì)列頭
struct key_info
{
	unsigned int gpio;//gpio口
	int irq;//中斷號(hào)
	char key_name[20];//注冊(cè)中斷名字
	int key_num;//按鍵編號(hào)
};
//按鍵信息保存
static struct key_info key_info[]=
{
	{EXYNOS4_GPX3(2),0,"key1",1},
	{EXYNOS4_GPX3(3),0,"key2",2},
	{EXYNOS4_GPX3(4),0,"key3",3},
	{EXYNOS4_GPX3(5),0,"key4",4}
};
static struct key_info *key_p;
static struct work_struct key_work;/*工作結(jié)構(gòu)體*/
static int key_val;
static int condition=0;/*喚醒標(biāo)志*/
/*工作處理函數(shù)*/
void work_func(struct work_struct *work)
{
	msleep(10);//按鍵消抖
	if(gpio_get_value(key_p->gpio)==0)
	{
		//printk("KEY %d 按下n",key_p->key_num);
		key_val=key_p->key_num;
	}
	condition=1;//將喚醒標(biāo)志置位
	wake_up(&key_q);
	
}
/*中斷服務(wù)函數(shù)*/
static irqreturn_t key_exit_work(int irq, void *dev)
{
	key_p=(struct key_info *)dev;
	schedule_work(&key_work);//工作調(diào)度
	return IRQ_HANDLED;
}

static int key_open(struct inode *inode, struct file *file)
{
	printk("設(shè)備打開(kāi)成功n");
	return 0;
}
static ssize_t key_read(struct file *file, char __user *data, size_t size, loff_t *offset)
{
	int ret;
	int key;
	//wait_event(key_q, condition);//休眠進(jìn)程(不可中斷休眠)
	wait_event_interruptible(key_q, condition);//休眠進(jìn)程(可中斷休眠)
	key=key_val;
	condition=0;//清除喚醒標(biāo)志
	ret=copy_to_user(data,&key,sizeof(key));
	return sizeof(key)-ret;
}
static int key_release(struct inode *inode, struct file *file)
{
	printk("設(shè)備關(guān)閉成功n");
	return 0;
}
/*文件操早集合*/
static struct file_operations key_fops=
{
	.open=		key_open,
	.read=		key_read,
	.release=	key_release
};


/*雜項(xiàng)設(shè)備結(jié)構(gòu)體*/
static struct miscdevice key_misc=
{
	.minor=MISC_DYNAMIC_MINOR,//次設(shè)備號(hào)，255，有內(nèi)核分配
	.name="key_exit",//在/dev下生成的設(shè)備節(jié)點(diǎn)名字
	.fops=&key_fops
};
static int __init wbyq_key_exit_init(void)
{
	int i=0;
	int ret;
	/*初始化等待隊(duì)列頭*/
	//init_waitqueue_head(&key_q);
	/*初始化工作*/
	INIT_WORK(&key_work, work_func);
	for(i=0;i;i++)>

• 執(zhí)行效果

審核編輯：湯梓紅