完成量机制是基于等待队列的,内核使用该机制等待某一操作的完成。其有两个参与者:一是等待某操作完成;另一是在操作完成时发出声明。当然可以有“任意数目”个进程等待操作完成。
完成量的数据描述如下:
struct completion { unsigned int done; /* 用于处理“在进程开始等待之前,事件或操作已经完成” */ wait_queue_head_t wait; /* 地等待队列 */ };一、完成量的初始化
初始化一个动态分配的completion完成量结构体,
static inline void init_completion(struct completion *x) { x->done = 0; init_waitqueue_head(&x->wait); }初始化一个静态completion完成量结构体。
#define DECLARE_COMPLETION(work) \ struct completion work = COMPLETION_INITIALIZER(work)二、添加到等待队列
进程可以通用一下函数添加到等待队列
void __sched wait_for_completion(struct completion *x) unsigned long __sched wait_for_completion_timeout(struct completion *x, unsigned long timeout) int __sched wait_for_completion_interruptible(struct completion *x) long __sched wait_for_completion_interruptible_timeout(struct completion *x, unsigned long timeout) int __sched wait_for_completion_killable(struct completion *x) long __sched wait_for_completion_killable_timeout(struct completion *x, unsigned long timeout)(1) 进程在等待完成时处于不可中断状态,若使用wait_for_completion_interruptible表示可中断,如果进程被中断,则返回-ERESTARTSYS,否则返回0;
(2) wait_for_completion_timeout表示等待事件的发生,并且提供超时设置,如果超过了这一设置,则取消等待,可防止无限等待;如果在超时之前完成则返回剩余时间,否则返回0。
(3) wait_for_completion_killable表示可以由kill信号中断。
其他函数均是这三者的变种。
三、唤醒进程
进程唤醒,可以通过以下函数实现:
extern void complete(struct completion *); extern void complete_all(struct completion *);(1) complete调用每次只能从等待队列中移除一个进程。如果等待队列有N个进程,则需要执行N次、
(2) complete_all唤醒所有的等待线程。
done的解释:
每次调用complete,done计数器都会+1,仅当done=0时,wait_for系列函数才会使得调用进程睡眠。
后续会进行complete编程练习......