Chinaunix

标题: 关于内核线程的问题，请教高人 [打印本页]

---

作者: wuzhao    时间: 2009-10-05 16:40
标题: 关于内核线程的问题，请教高人
用kernel_thread创建一个线程后，在该线程的中能否再次创建子进程？能否使用sys_wait4等待子线程的退出？

---

作者: wuzhao    时间: 2009-10-05 18:14
测试程序如下， 主要想实现的功能是：主线程创建三个子线程，等待子线程处理完后退出。
但是发现主线程在创建完第一个子线程后就不继续执行了，不知道具体是什么原因，请高人给讲讲。

1. #include <linux/config.h>
   
2. #include <linux/init.h>
   
3. #include <linux/module.h>
   
4. #include <linux/kernel.h>
   
5. #include <linux/sched.h>
   
6. #include <asm/system.h>
   
7. #include <asm/processor.h>
   
8. #include <asm/signal.h>
   
9. 
   
10. #define TIME   (10 * HZ)
    
11. 
    
12. DECLARE_WAIT_QUEUE_HEAD(test_wait);
    
13. 
    
14. static int parent_id = 0;        
    
15. 
    
16. int test1(void *data)
    
17. {
    
18.     struct task_struct *tsk = current;
    
19. 
    
20.     int a = 0;
    
21. 
    
22.     DECLARE_WAITQUEUE(wait1, current);
    
23. 
    
24.     strcpy(tsk->comm, "test");
    
25. 
    
26.     for (;;){
    
27.         add_wait_queue(&test_wait, &wait1);
    
28.         set_current_state(TASK_INTERRUPTIBLE);
    
29.         printk(KERN_ERR"kptest1 running.....\n");
    
30.         if (a == 2)
    
31.             return 0;
    
32.         a++;
    
33.         schedule_timeout(TIME);
    
34.     }
    
35. 
    
36.     return 0;
    
37. }
    
38. 
    
39. int parent_thread(void *data)
    
40. {
    
41.     int i = 0;
    
42.     int g_pid[3];
    
43.     struct task_struct *tsk = current;
    
44. 
    
45.     int pid;
    
46. 
    
47.     DECLARE_WAITQUEUE(wait, current);
    
48. 
    
49.     strcpy(tsk->comm, "parent");
    
50. 
    
51.     daemonize(); /*without attached user resources*/
    
52. 
    
53.     reparent_to_init();
    
54. 
    
55.     unblock_all_signals();
    
56. 
    
57. 
    
58.        add_wait_queue(&test_wait, &wait);
    
59.        set_current_state(TASK_INTERRUPTIBLE);
    
60. 
    
61.        for (i=0; i<3; i++)
    
62.        {
    
63.            g_pid[i] = kernel_thread(test1, NULL,
    
64.                     CLONE_FS | CLONE_FILES | CLONE_SIGHAND | SIGCHLD);
    
65.            if (g_pid[i] > 0)
    
66.       }
    
67.       printk("g_pid[] = %d,%d,%d\n", g_pid[0], g_pid[1], g_pid[2]);
    
68. 
    
69.       i = 3;
    
70.        while(i != 0)
    
71.        {
    
72.            int index;
    
73.            pid = sys_wait4(-1, NULL, 0, NULL);
    
74.            for(index=0; index < 3; index++)
    
75.            {
    
76.                if(pid == g_pid[index])
    
77.                {
    
78.                    printk("g_pid[%d]...exit\n", index);
    
79.                    i--;
    
80.                }
    
81.            }
    
82.        }
    
83.    return 0;
    
84. }
    
85. 
    
86. static int __init test_init(void)
    
87. {
    
88.     int pid;
    
89. 
    
90.     printk("Starting test multi_threaded...\n");
    
91.     pid = kernel_thread(parent_thread, NULL, CLONE_FS | CLONE_FILES | CLONE_SIGHAND | SIGCHLD );
    
92.     if (pid > 0) {
    
93.         parent_id = pid;
    
94.     }
    
95.     return 0;
    
96. }
    
97. module_init(test_init);
    
98. 
    
99. static void __exit test_exit(void)
    
100. {
     
101.     int ret;
     
102. 
     
103.     /* Kill the thread */
     
104.     ret = kill_proc(parent_id, SIGKILL, 1);
     
105. 
     
106.     printk("test multi_threaded exit.\n");
     
107. }
     
108. 
     
109. module_exit(test_exit);

复制代码

---

作者: wuzhao    时间: 2009-10-08 00:10
自己来结贴吧，创建线程中加上CLONE_VFORK参数，一切OK～

1.        for (i=0; i<3; i++)
   
2. 
   
3.        {
   
4. 
   
5.            g_pid[i] = kernel_thread(test1, NULL,
   
6. 
   
7.                     CLONE_FS | CLONE_FILES | CLONE_SIGHAND | SIGCHLD ｜CLONE_VFORK );
   
8. 
   
9.       }

复制代码

---

作者: ryan3216    时间: 2009-10-09 21:24
提示: 作者被禁止或删除 内容自动屏蔽

---

作者: wuzhao    时间: 2009-10-10 13:28
内核是2.4.20版本，头文件是从别的地方直接复制的，没多考虑。呵呵
弱弱地问一句，从config.h怎么就看出版本低了呢？

---

欢迎光临 Chinaunix (http://bbs.chinaunix.net/)

Powered by Discuz! X3.2