5

私はカーネル モジュール プログラミングは初めてで、仕事のためにマルチスレッド カーネル モジュールを作成する必要があります。そこで、カーネルスレッドの主な用途をいくつか試しました。以下を書きました。あるスレッドで 1 を、別のスレッドで 2 を、両方とも 10 回印刷することになっています。

#include <linux/module.h>
#include <linux/moduleparam.h>
#include <linux/kernel.h>
#include <linux/udp.h>
#include <linux/mm.h>
#include <linux/init.h>
#include <linux/kthread.h>

struct task_struct *task1;
struct task_struct *task2;


static void thread_func(void* data)
{   
    int *n;
    n = (int *)data;
    int i = 0;
    while(i < 10){
        printk("%d\n", *n);
        i++;
    }
    //do_exit();
}

static int t_start(void)
{
    printk("Module starting ... ... ..\n");
    int *p1, *p2;
    int one = 1, two = 2;
    p1 = &one;
    p2 = &two;
    task1 = kthread_run(&thread_func, (void*)p1, "thread_func_1");
    task2 = kthread_run(&thread_func, (void*)p2, "thread_func_2");
    return 0;
}

static void t_end (void)
{
    printk("Module terminating ... ... ...\n");
    kthread_stop(task1);
    kthread_stop(task2);
}

module_init(t_start);
module_exit(t_end);

MODULE_AUTHOR("Md. Taufique Hussain");
MODULE_DESCRIPTION("Testing kernel threads");
MODULE_LICENSE("GPL");

しかし、私は次の問題に直面しています。-

  1. 最初のスレッドが 10 個すべての 1 を出力し、次に 2 番目のスレッドが実行されます。これら2つを交互に実行したかったのです。
  2. 最初のスレッドはすべて 1 を正常に出力していますが、2 番目のスレッドは 2 を出力していません。0を印刷しています。おそらく、パラメーターが 2 番目のスレッドに正しく渡されていません。
  3. モジュールを挿入すると実行されますが、モジュールを削除するとマシンがハングします

問題は何ですか？どうすれば解決できますか。

4

3 に答える 3

3
  1. プリエンプティブルカーネルがなく、スリープが発生しない限り、schedule（）が必要です。
  2. スタックからデータポインタを渡しているため、カーネルメモリが破損しています。それらのintをグローバル変数にします。
于 2012-10-19T12:51:38.697 に答える
3

1.これらのコードは使用せず、削除してください

// kthread_stop(task1);
// kthread_stop(task2);

スレッドの終了後、タスクが null に設定され、kthread_stop() を呼び出すと null ポインター エラーが発生するようです。

2.ローカル変数をスレッドに渡さず、代わりにグローバル変数を使用します。

3.2 つのスレッドを相互に切り替えたい場合は、"wait_event" と "wake_up" 関数を使用します。これが私のコードです。

#include <linux/init.h>
#include <linux/module.h>
#include <linux/kernel.h>
#include <linux/sched.h>
#include <linux/kthread.h>
#include <linux/wait.h>

MODULE_LICENSE("GPL");


int pid1 = 1;
int pid2 = 2;

DECLARE_WAIT_QUEUE_HEAD(wq);

int condition;

struct task_struct *task1;
struct task_struct *task2;

static int thread_function(void *data){

    int *thread_id = (int*)data;
    int i = 0;
    while(i < 10){
       printk(KERN_INFO "install kernel thread: %d\n", *thread_id);
       i++;

       if(*thread_id == 1)
       {
            wait_event(wq, condition == 0xA);

            condition = 0xB;
            wake_up(&wq);
       }
       else{
            wait_event(wq, condition == 0xB);

            condition = 0xA;
            wake_up(&wq);
       }
   }
   return 0;
}


static int kernel_init(void)
{
     condition = 0xA;

     task1 = kthread_create(&thread_function, (void *)&pid1, "pradeep");
     task2 = kthread_create(&thread_function, (void *)&pid2, "pradeep"); 

     //printk(KERN_INFO "After create kernel thread\n");
     wake_up_process(task1);
     wake_up_process(task2);
     return 0;
}

int init_module(void)
{
    kernel_init();
    return 0;
}

void cleanup_module(void)
{
    return;
}

‍</p>

于 2015-01-27T19:18:59.563 に答える
2

scheduleスレッド スケジューリングを強制する呼び出しを追加します。

static void thread_func(void* data)
{   
    int *n;
    n = (int *)data;
    int i = 0;
    while(i < 10){
        printk("%d\n", *n);

        schedule();

        i++;
    }
    //do_exit();
}
于 2012-10-19T12:27:31.200 に答える