一、用法
struct cpu_workqueue_struct ____cacheline_aligned;
/* * the externally visible workqueue abstraction is an array of
* per-cpu workqueues:
*/ struct workqueue_struct ;
工作佇列的使用很簡單。
1.首先是建立乙個工作佇列：
struct workqueue_struct *keventd_wq;
keventd_wq = create_workqueue("events");
2.然後就是在這個佇列中insert你所要做的「工作」：
declare_work(work, func, data)
queue_work(keventd_wq, work);
struct work_struct ;
初始化有兩種方法。
一種為靜態方法：
#define __work_initializer(n, f, d) , \
.func = (f), \
.data = (d), \
.timer = timer_initializer(null, 0, 0), \
} #define declare_work(n, f, d) \
struct work_struct n = __work_initializer(n, f, d)
另一種為動態方法：
/* * initialize all of a work-struct:
*/ #define init_work(_work, _func, _data) \
do while (0)
二、執行過程
create_workqueue() -> __create_workqueue()
struct workqueue_struct *__create_workqueue(const char *name,
int singlethread)
else else
destroy = 1;
} }
mutex_unlock(&workqueue_mutex);
...
return wq;
} create_workqueue() -> __create_workqueue() -> create_workqueue_thread()
static struct task_struct *create_workqueue_thread(struct workqueue_struct *wq,
int cpu)
create_workqueue() -> __create_workqueue() -> create_workqueue_thread() -> worker_thread()
//本函式在乙個死迴圈等待工作的到來，這一般在睡眠狀態中，等待被喚醒執行工作
//當有工作到來時queue_work()會將這個執行緒喚醒
static int worker_thread(void *__cwq)
__set_current_state(task_running);
return 0;
} create_workqueue() -> __create_workqueue() -> create_workqueue_thread()
-> worker_thread() -> run_workqueue()
//該函式執行真正的工作
static void run_workqueue(struct cpu_workqueue_struct *cwq)
cwq->run_depth--;
spin_unlock_irqrestore(&cwq->lock, flags);
} 三、工作執行緒建立的詳細過程
create_workqueue() -> __create_workqueue() -> create_workqueue_thread()
-> kthread_create()
struct task_struct *kthread_create(int (*threadfn)(void *data),
void *data,
const char namefmt,
...)
...
return create.result;
} create_workqueue() -> __create_workqueue() -> create_workqueue_thread()
-> kthread_create()-> keventd_create_kthread()
//最終會呼叫kernel_thread為每個工作佇列建立乙個執行緒
//這樣，被建立的執行緒會以create為資料執行kthread(如下),而kthread中則執行create中的threadfn(data)，
//即為create_workqueue_thread中的worker_thread(cwq)，即為我們工作佇列要執行的函式了。
static void keventd_create_kthread(void *_create)
else
complete(&create->done);
} static int kthread(void *_create)
四、插入「工作」
/* preempt must be disabled. */
static void __queue_work(struct cpu_workqueue_struct *cwq,
struct work_struct *work)
int fastcall queue_work(struct workqueue_struct *wq, struct work_struct *work)
put_cpu();
return ret;
}
工作佇列分析 queue work
一 用法 struct cpu workqueue struct cacheline aligned the externally visible workqueue abstraction is an array of per cpu workqueues struct workqueue str...
工作佇列分析
一 用法 struct cpu workqueue struct cacheline aligned the externally visible workqueue abstraction is an array of per cpu workqueues struct workqueue str...
工作佇列分析
一 用法 struct cpu workqueue struct cacheline aligned the externally visible workqueue abstraction is an array of per cpu workqueues struct workqueue str...