基于內核線程的創(chuàng)建、使用和退出以及延時宏的補充說明介紹
相關函數：
kthread_create():創(chuàng)建內核線程
struct task_struct *kthread_create(int (*threadfn)(void *data), void *data, const char namefmt[], ...); kernel thread可以用kernel_thread創(chuàng)建，但是在執(zhí)行函數里面必須用daemonize釋放資源并掛到init下，還需要用completion等待這一過程的完成。為了簡化操作，定義了kthread_create。
線程創(chuàng)建后，不會馬上運行，而是需要將kthread_create() 返回的task_struct指針傳給wake_up_process()，然后通過此函數運行線程。
kthread_run()：創(chuàng)建并啟動線程的函數。
struct task_struct *kthread_run(int (*threadfn)(void *data),void *data,const char *namefmt, ...);它實際上是個宏，由kthread_create()和wake_up_process()組成。
它實際上是個宏，由kthread_create()和wake_up_process()組成。
#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_stop()：通過發(fā)送信號給線程，使之退出。
int kthread_stop(struct task_struct *thread);
線程一旦啟動起來后，會一直運行，除非該線程主動調用do_exit函數，或者其他的進程調用kthread_stop函數，結束線程的運行。
但如果線程函數正在處理一個非常重要的任務，它不會被中斷的。當然如果線程函數永遠不返回并且不檢查信號，它將永遠都不會停止。
同時，在調用kthread_stop函數時，線程函數不能已經運行結束。否則，kthread_stop函數會一直進行等待。
內核線程的一般框架
int threadfunc(void *data){
…
while(1){
set_current_state(TASK_UNINTERRUPTIBLE);
if(kthread_should_stop()) break;
if(){//條件為真
//進行業(yè)務處理
}
else{//條件為假
//讓出CPU運行其他線程，并在指定的時間內重新被調度
schedule_timeout(HZ);
}
}
…
return 0;
}
線程相關測試命令
可以使用top命令來查看線程（包括內核線程）的CPU利用率。命令如下：
top –p 線程號
可以使用下面命令來查找線程號：
ps aux|grep 線程名
示例程序：使用模塊加載內核線程，實現每1s在內核中打印字符。
(makefile略去，和以前一篇博文一樣的寫法。)
#include <linux/init.h>
#include <linux/module.h>
#include <linux/kernel.h>
#include <linux/sched.h> //wake_up_process()
#include <linux/kthread.h> //kthread_create(),kthread_run()
#include <linux/err.h> //IS_ERR(),PTR_ERR()
#ifndef SLEEP_MILLI_SEC
#define SLEEP_MILLI_SEC(nMilliSec)\
do { \
long timeout = (nMilliSec) * HZ / 1000; \
while(timeout > 0) \
{ \
timeout = schedule_timeout(timeout); \
} \
}while(0);
#endif
static struct task_struct *my_task = NULL;
static int my_kthread(void *data)
{
char *mydata = kmalloc(strlen(data)+1,GFP_KERNEL);
memset(mydata,'\0',strlen(data)+1);
strncpy(mydata,data,strlen(data));
while(!kthread_should_stop())
{
SLEEP_MILLI_SEC(1000);
printk("%s\n",mydata);
}
kfree(mydata);
return 0;
}
static int __init kernel_thread_init(void)
{
int err;
printk(KERN_ALERT "Kernel thread initalizing...\n");
my_task = kthread_create(my_kthread,"hello world","mythread");
if(IS_ERR(my_task)){
printk("Unable to start kernel thread./n");
err = PTR_ERR(my_task);
my_task = NULL;
return err;
}
wake_up_process(my_task);
return 0;#include <linux/init.h>
#include <linux/module.h>
#include <linux/kernel.h>
#include <linux/sched.h> //wake_up_process()
#include <linux/kthread.h> //kthread_create(),kthread_run()
#include <linux/err.h> //IS_ERR(),PTR_ERR()
#ifndef SLEEP_MILLI_SEC
#define SLEEP_MILLI_SEC(nMilliSec)\
do { \
long timeout = (nMilliSec) * HZ / 1000; \
while(timeout > 0) \
{ \
timeout = schedule_timeout(timeout); \
} \
}while(0);
#endif
static struct task_struct *my_task = NULL;
static int my_kthread(void *data)
{
char *mydata = kmalloc(strlen(data)+1,GFP_KERNEL);
memset(mydata,'\0',strlen(data)+1);
strncpy(mydata,data,strlen(data));
while(!kthread_should_stop())
{
SLEEP_MILLI_SEC(1000);
printk("%s\n",mydata);
}
kfree(mydata);
return 0;
}
static int __init kernel_thread_init(void)
{
int err;
printk(KERN_ALERT "Kernel thread initalizing...\n");
my_task = kthread_create(my_kthread,"hello world","mythread");
if(IS_ERR(my_task)){
printk("Unable to start kernel thread./n");
err = PTR_ERR(my_task);
my_task = NULL;
return err;
}
static void __exit kernel_thread_exit(void)
{
if(my_task){
printk(KERN_ALERT "Cancel this kernel thread.\n");
kthread_stop(my_task);
printk(KERN_ALERT "Canceled.\n");
}
}
module_init(kernel_thread_init);
module_exit(kernel_thread_exit);
MODULE_LICENSE("GPL");
MODULE_AUTHOR("anonymous");
補充說明：
這個延時宏在一些情況下會造成內核線程CPU占用率過高的情況。根據對schedule_timeout()源碼的分析，它只是周期使線程成為TASK_RUNNING狀態(tài)，這個線程并沒有真正的睡眠。解決辦法：在while循環(huán)中的起始處加入set_current_state(TASK_INTERRUPTIBLE)即可。
相關文章
這個三子棋游戲是在學習C語言的過程中自己編寫的一個小游戲，現在將自己的思路（主要以流程圖形式和代碼中的注釋表達）和具體代碼以及運行結果分享出來以供大家學習參考，希望對大家有所幫助2022-11-11
今天小編就為大家分享一篇關于C/C++中的sizeof運算符和size_t類型的詳解，小編覺得內容挺不錯的，現在分享給大家，具有很好的參考價值，需要的朋友一起跟隨小編來看看吧2018-10-10
Qt利用QSortFilterProxyModel代理實現自定義排序與聯合過濾
QsortFilterProxyModel類用來為model和view之間提供強大的排序和過濾支持。這篇文章將利用QSortFilterProxyModel代理實現自定義排序與聯合過濾，需要的可以參考一下2022-11-11
c++如何控制對象的創(chuàng)建方式（禁止創(chuàng)建棧對象or堆對象）和創(chuàng)建的數量
這篇文章主要介紹了c++如何控制對象的創(chuàng)建方式和創(chuàng)建的數量，幫助大家更好的理解和學習，感興趣的朋友可以了解下2020-08-08
這篇文章主要介紹了C++中string與int的相互轉換實現代碼,需要的朋友可以參考下2017-05-05
本篇文章是對使用C++實現基數排序的方法進行了詳細的分析介紹，需要的朋友參考下2013-05-05
這篇文章介紹了C++中的函數知識點，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2022-04-04
這篇文章主要為大家詳細介紹了利用C語言實現三子棋游戲，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2021-02-02
這篇文章主要為大家詳細介紹了Qt中QListWidget控件的使用教程，文中的示例代碼講解詳細，對我們學習Qt有一定的幫助，需要的可以參考一下2022-12-12
Visual?Studio2022配置ReSharper?C++?常用設置方法
這篇文章主要介紹了Visual?Studio2022配置ReSharper?C++?常用設置,本文通過圖文并茂的形式給大家介紹的非常詳細,文中介紹了卸載Resharper的方法及Resharper激活碼,感興趣的朋友參考下吧2024-01-01