kthread_stop引發的OOP

1 使用kthread_create建立線程：
    struct task_struct *kthread_create(int (*threadfn)(void *data),

                                                                  void *data,
                                                                   const char *namefmt, ...);
這個函數能夠像printk同樣傳入某種格式的線程名
線程建立後，不會立刻運行，而是須要將kthread_create() 返回的task_struct指針傳給wake_up_process()，而後經過此函數運行線程。
2. 固然，還有一個建立並啓動線程的函數：kthread_run
   struct task_struct *kthread_run(int (*threadfn)(void *data),
                                    void *data,
                                    const char *namefmt, ...);
3. 線程一旦啓動起來後，會一直運行，除非該線程主動調用do_exit函數，或者其餘的進程調用kthread_stop函數，結束線程的運行。
    int kthread_stop(struct task_struct *thread);
kthread_stop() 經過發送信號給線程。
若是線程函數正在處理一個很是重要的任務，它不會被中斷的。固然若是線程函數永遠不返回而且不檢查信號，它將永遠都不會中止。
參考：Kernel threads made easy

--

#include <linux/kthread.h>
static struct task_struct * _task;
static struct task_struct * _task2;
static struct task_struct * _task3;
static int thread_func(void *data)
{
        int j,k;
        int timeout;
        wait_queue_head_t timeout_wq;
        static int i = 0;
        i++;
        j = 0;
        k = i;
        printk("thread_func %d started/n", i);
        init_waitqueue_head(&timeout_wq);
        while(!kthread_should_stop())
        {
                interruptible_sleep_on_timeout(&timeout_wq, HZ);
                printk("[%d]sleeping..%d/n", k, j++);
        }
        return 0;
}
void my_start_thread(void)
{

        //_task = kthread_create(thread_func, NULL, "thread_func2");
        //wake_up_process(_task);
        _task = kthread_run(thread_func, NULL, "thread_func2");
        _task2 = kthread_run(thread_func, NULL, "thread_func2");
        _task3 = kthread_run(thread_func, NULL, "thread_func2");
        if (!IS_ERR(_task))
        {
                printk("kthread_create done/n");
        }
        else
        {
                printk("kthread_create error/n");
        }
}
void my_end_thread(void)
{
        int ret = 0;
        ret = kthread_stop(_task);
        printk("end thread. ret = %d/n" , ret);
        ret = kthread_stop(_task2);
        printk("end thread. ret = %d/n" , ret);
        ret = kthread_stop(_task3);
        printk("end thread. ret = %d/n" , ret);
}

 

 

在執行kthread_stop的時候，目標線程必須沒有退出，不然會Oops。緣由很容易理解，當目標線程退出的時候，其對應的task結構也變得無效，kthread_stop引用該無效task結構就會出錯。

 

爲了不這種狀況，須要確保線程沒有退出，其方法如代碼中所示：

thread_func()

{

    // do your work here

 

    // wait to exit

    while(!thread_could_stop())

    {

           wait();

    }

}

 

exit_code()

{

     kthread_stop(_task);   //發信號給task，通知其能夠退出了

}

 

這種退出機制很溫和，一切盡在thread_func()的掌控之中，線程在退出時能夠從容地釋放資源，而不是莫名其妙地被人「暗殺」。