zoukankan      html  css  js  c++  java
  • 完成量基础知识 ( completion )

            完成量机制是基于等待队列的,内核使用该机制等待某一操作的完成。其有两个参与者:一是等待某操作完成;另一是在操作完成时发出声明。当然可以有“任意数目”个进程等待操作完成。

            完成量的数据描述如下:

    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编程练习......



  • 相关阅读:
    Flink Table环境配置、读取外部数据(File、Kafka)以及查询转换
    Flink之Table初探
    Flink之Watermarks
    Flink之ProcessFunction侧输出流
    Flink之ProcessFunction案例
    Flink之Mysql数据CDC
    Express ejs 模板做的 app.js 文件
    金额转换文章(100=>零佰)
    将 音频流(MP3流)并进行播放
    浅谈MySQL(一):存储引擎与索引
  • 原文地址:https://www.cnblogs.com/youngerchina/p/5624634.html
Copyright © 2011-2022 走看看