workqueue

workqueueでは、遅延処理をオブジェクト(work_struct)として管理する。

必要な遅延処理ごとにwork_structを用意し、これをキューに格納して順次実行することになる。

workqueueはカーネルスレッドを作って処理するため、他のカーネルスレッドへの影響がない。

独自に作る方法と、システム共有のものを使う方法とがある。

なお、このカーネルスレッドは、キューに遅延処理がプッシュされてくるまではスリープしている。

次のような関数が用意されている。

• create_workqueue() … 独自のworkqueueを作成する(CPU数ぶんのスレッド)
• create_singlethread_workqueue() … 独自のworkqueueを作成する(一つだけ)
• queue_work() … キューにオブジェクト(work_struct)をプッシュ
• destroy_workqueue() … workqueueを削除

• schedule_work() … キューにオブジェクト(work_struct)をプッシュ

すぐに実行するのではなく、暫く経ってから実行することも可能。これら関数にはdelayedと付けられている。

よう使うもの。

• schedule_delayed_work() … キューにオブジェクト(work_struct)をプッシュ
• cancel_delayed_work_sync() … オブジェクト(work_struct)を取り消す

delayed付きも同様だが、時間指定が可能である。

#define DELAY_TIME 2000  /* ms */
schedule_delayed_work(&work, msecs_to_jiffies(DELAY_TIME));

単位がjiffiesなので、ここではミリ秒をjiffiesに変換するinline関数を用いている。

取り消し方法は次の通り。

cancel_delayed_work_sync(&work);