基于內(nèi)核線程的創(chuàng)建、使用和退出以及延時(shí)宏的補(bǔ)充說(shuō)明介紹
相關(guān)函數(shù)：
kthread_create():創(chuàng)建內(nèi)核線程
struct task_struct *kthread_create(int (*threadfn)(void *data), void *data, const char namefmt[], ...); kernel thread可以用kernel_thread創(chuàng)建，但是在執(zhí)行函數(shù)里面必須用daemonize釋放資源并掛到init下，還需要用completion等待這一過(guò)程的完成。為了簡(jiǎn)化操作，定義了kthread_create。
線程創(chuàng)建后，不會(huì)馬上運(yùn)行，而是需要將kthread_create() 返回的task_struct指針傳給wake_up_process()，然后通過(guò)此函數(shù)運(yùn)行線程。
kthread_run()：創(chuàng)建并啟動(dòng)線程的函數(shù)。
struct task_struct *kthread_run(int (*threadfn)(void *data),void *data,const char *namefmt, ...);它實(shí)際上是個(gè)宏，由kthread_create()和wake_up_process()組成。
它實(shí)際上是個(gè)宏，由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()：通過(guò)發(fā)送信號(hào)給線程，使之退出。
int kthread_stop(struct task_struct *thread);
線程一旦啟動(dòng)起來(lái)后，會(huì)一直運(yùn)行，除非該線程主動(dòng)調(diào)用do_exit函數(shù)，或者其他的進(jìn)程調(diào)用kthread_stop函數(shù)，結(jié)束線程的運(yùn)行。
但如果線程函數(shù)正在處理一個(gè)非常重要的任務(wù)，它不會(huì)被中斷的。當(dāng)然如果線程函數(shù)永遠(yuǎn)不返回并且不檢查信號(hào)，它將永遠(yuǎn)都不會(huì)停止。
同時(shí)，在調(diào)用kthread_stop函數(shù)時(shí)，線程函數(shù)不能已經(jīng)運(yùn)行結(jié)束。否則，kthread_stop函數(shù)會(huì)一直進(jìn)行等待。
內(nèi)核線程的一般框架
int threadfunc(void *data){
…
while(1){
set_current_state(TASK_UNINTERRUPTIBLE);
if(kthread_should_stop()) break;
if(){//條件為真
//進(jìn)行業(yè)務(wù)處理
}
else{//條件為假
//讓出CPU運(yùn)行其他線程，并在指定的時(shí)間內(nèi)重新被調(diào)度
schedule_timeout(HZ);
}
}
…
return 0;
}
線程相關(guān)測(cè)試命令
可以使用top命令來(lái)查看線程（包括內(nèi)核線程）的CPU利用率。命令如下：
top –p 線程號(hào)
可以使用下面命令來(lái)查找線程號(hào)：
ps aux|grep 線程名
示例程序：使用模塊加載內(nèi)核線程，實(shí)現(xiàn)每1s在內(nèi)核中打印字符。
(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");
補(bǔ)充說(shuō)明：
這個(gè)延時(shí)宏在一些情況下會(huì)造成內(nèi)核線程CPU占用率過(guò)高的情況。根據(jù)對(duì)schedule_timeout()源碼的分析，它只是周期使線程成為TASK_RUNNING狀態(tài)，這個(gè)線程并沒有真正的睡眠。解決辦法：在while循環(huán)中的起始處加入set_current_state(TASK_INTERRUPTIBLE)即可。
相關(guān)文章
對(duì)于開發(fā)C++來(lái)說(shuō)，枚舉是一個(gè)幾乎必然用到的功能。當(dāng)然今天要講的枚舉肯定不是平常漫不經(jīng)心的使用，而是從里到外地深扒它。本文就來(lái)逐漸揭開它神秘地面紗，發(fā)現(xiàn)一些未曾注意到的東西吧2023-03-03
簡(jiǎn)單介紹C++編程中派生類的析構(gòu)函數(shù)
這篇文章主要介紹了C++編程中派生類的析構(gòu)函數(shù),析構(gòu)函數(shù)平時(shí)一般使用較少,需要的朋友可以參考下2015-09-09
這篇文章主要介紹了顯示內(nèi)存狀態(tài)示例，代碼簡(jiǎn)單，下面直接看代碼,需要的朋友可以參考下2014-02-02
assert?是一個(gè)非常有用的工具,可以幫助開發(fā)人員在早期發(fā)現(xiàn)和糾正程序中的邏輯錯(cuò)誤,在調(diào)試階段通過(guò)斷言可以驗(yàn)證程序中的假設(shè)條件是否成立,提高代碼的可靠性和可維護(hù)性,這篇文章主要介紹了C語(yǔ)言中的斷言函數(shù)assert,需要的朋友可以參考下2024-07-07
這篇文章主要為大家介紹了c++算法進(jìn)階刪除有序鏈表中的重復(fù)元素示例,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-12-12
今天小編就為大家分享一篇C++讀取帶空格字符串的方法，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2018-07-07
這篇文章主要介紹了C++編程中類模板的三種特化,需要的朋友可以參考下2016-01-01
這篇文章主要給大家介紹了關(guān)于C++模板非類型形參的相關(guān)資料,文中通過(guò)實(shí)例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作就有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2021-11-11
C# interface與delegate效能比較的深入解析
本篇文章是對(duì)C#中interface與delegate的效能比較進(jìn)行了詳細(xì)的分析介紹，需要的朋友參考下2013-05-05
tc編譯的dos程序和vc編譯的win32控制臺(tái)程序的異同
tc編譯的dos程序和vc編譯的win32控制臺(tái)程序的異同...2007-08-08