转自：

头文件include/linux/kthread.h创建并启动/** * kthread_run - create and wake a thread. * @threadfn: the function to run until signal_pending(current). * @data: data ptr for @threadfn. * @namefmt: printf-style name for the thread. * * Description: Convenient wrapper for kthread_create() followed by * wake_up_process().  Returns the kthread or ERR_PTR(-ENOMEM). */#define kthread_run(threadfn, data, namefmt, ...)              \({                                              \     struct task_struct *__k                              \          = kthread_create(threadfn, data, namefmt, ## __VA_ARGS__); \     if (!IS_ERR(__k))                               \          wake_up_process(__k);                           \     __k;                                       \})创建/*** kthread_create - create a kthread.* @threadfn: the function to run until signal_pending(current).* @data: data ptr for @threadfn.* @namefmt: printf-style name for the thread.** Description: This helper function creates and names a kernel* thread. The thread will be stopped: use wake_up_process() to start* it. See also kthread_run(), kthread_create_on_cpu().** When woken, the thread will run @threadfn() with @data as its* argument. @threadfn can either call do_exit() directly if it is a* standalone thread for which noone will call kthread_stop(), or* return when 'kthread_should_stop()' is true (which means* kthread_stop() has been called). The return value should be zero* or a negative error number; it will be passed to kthread_stop().** Returns a task_struct or ERR_PTR(-ENOMEM).*/struct task_struct *kthread_create(int (*threadfn)(void *data),       void *data,       const char namefmt[],       ...){    struct kthread_create_info create;    DECLARE_WORK(work, keventd_create_kthread, &create);    create.threadfn = threadfn;    create.data = data;    init_completion(&create.started);    init_completion(&create.done);    /*    * The workqueue needs to start up first:    */    if (!helper_wq)       work.func(work.data);    else {       queue_work(helper_wq, &work);       wait_for_completion(&create.done);    }    if (!IS_ERR(create.result)) {       va_list args;       va_start(args, namefmt);       vsnprintf(create.result->comm, sizeof(create.result->comm),         namefmt, args);       va_end(args);    }    return create.result;}EXPORT_SYMBOL(kthread_create);结束int kthread_stop(struct task_struct *k);    1检测int kthread_should_stop(void);    1返回should_stop标志。它用于创建的线程检查结束标志，并决定是否退出举例static int hello_init(void)  {      printk(KERN_INFO "Hello, world!\n");      tsk = kthread_run(thread_function, NULL, "mythread%d", 1);      if (IS_ERR(tsk)) {          printk(KERN_INFO "create kthread failed!\n");      }      else {          printk(KERN_INFO "create ktrhead ok!\n");      }      return 0;  }  static void hello_exit(void)  {      printk(KERN_INFO "Hello, exit!\n");      if (!IS_ERR(tsk)){          int ret = kthread_stop(tsk);          printk(KERN_INFO "thread function has run %ds\n", ret);      }  }  module_init(hello_init);  module_exit(hello_exit);