completion使用方法

Linux系统提供了一种比信号量更好的同步机制，即completion，它用于一个执行单元等待另一个执行单元执行完某事。Linux系统中与completion相关的操作主要有以下4种:
    (1) 定义completion

1. struct completion my_completion;

    (2) 初始化completion

1. init_completion(&my_completion);

        对my_completion的定义和初始化可以通过如下快捷方式实现
        DECLEARE_COMPLETION(my_completion);
    (3) 等待completion

1. void wait_for_completion(struct completion *c);

    (4) 唤醒completion

1. void complete(struct completion *c);
   
2. void complete_all(struct completion *c);

        前者只唤醒一个等待的执行单元，后者唤醒所有等待同一completion的执行单元。


     执行单元A                                                    执行单元B
    struct completion com;
    init_completion(&com);
                                                          wake up
    wait_for_completion(&com);

1. kernel_thread.c
   
2. ---------------------------------------
   
3. #include <linux/kernel.h>
   
4. #include <linux/module.h>
   
5. #include <linux/init.h>
   
6. #include <linux/param.h>
   
7. #include <linux/jiffies.h>
   
8. #include <asm/system.h>
   
9. #include <asm/processor.h>
   
10. #include <asm/signal.h>
    
11. #include <linux/completion.h> // for DECLARE_COMPLETION()
    
12. #include <linux/sched.h> // for daemonize() and set_current_state()
    
13. #include <linux/delay.h> // mdelay()
    
14. 
    
15. static pid_t thread_id;
    
16. static DECLARE_COMPLETION(my_completion);
    
17. 
    
18. int my_fuction(void *arg)
    
19. {
    
20.     printk(" in %s()\n", __FUNCTION__);
    
21.     daemonize("demo-thread");
    
22.     allow_signal(SIGKILL);
    
23.     mdelay(2000);
    
24.     printk(" my_function complete()\n");
    
25.     complete(&my_completion); // wake up wait_for_completion
    
26. 
    
27.     while (!signal_pending(current)) { /* 等待处理信号，没有信号将进入循环体 */
    
28.         printk(" jiffies is %lu\n", jiffies);
    
29.         set_current_state(TASK_INTERRUPTIBLE);
    
30.         schedule_timeout(HZ * 5);
    
31.     }
    
32. 
    
33.     return 0;
    
34. }
    
35. 
    
36. static int __init init(void)
    
37. {
    
38.     thread_id = kernel_thread(my_fuction, NULL, CLONE_FS | CLONE_FILES);
    
39.     printk(" init wait_for_completion()\n");
    
40.     wait_for_completion(&my_completion);
    
41.     return 0;
    
42. }
    
43. 
    
44. static void __exit finish(void)
    
45. {
    
46.     kill_proc(thread_id, SIGKILL, 1);/* 结束内核线程、杀死内核线程 */
    
47.     printk(" Goodbye\n");
    
48. }
    
49. 
    
50. module_init(init);
    
51. module_exit(finish);
    
52. MODULE_LICENSE("GPL");