转自:http://blog.csdn.net/sudolee/article/details/6885634
1>work_queue:<linux/workqueue.h> __3.0.4
2>description:
中断下半部,在内核线程的进程上下文中执行推后的工作.
它是唯一能在进程上下文运行的中断下半部实现机制,也只有它才可以睡眠.
3>创建推后的工作:
- DECLARE_WORK(const char *name, void (*func)(struct work_struct *work));
- INIT_WORK(struct work_struct *work, void (*func)(struct work_struct *work));
- struct work_struct {
- atomic_long_t data;
- struct list_head entry;
- work_func_t func;
- #ifdef CONFIG_LOCKDEP
- struct lockdep_map lockdep_map;
- #endif
- };
- typedef void (*work_func_t)(struct work_struct *work);
4>工作队列处理函数:
- /* 除了不能访问用户空间,它的确比软中断和tasklet方便不少.
- * 只有系统调用陷入内核,用户空间的内存才会被映射.
- */
- void *func(struct work_struct *work);
5>调度(提交)工作:
- /* 把创建好的工作提交到缺省的worker线程(每个cpu一个,event/cpuno.).
- * 有时把这种工作队列也叫共享队列,因为很多驱动程序都将推后执行的工作提交到默认worker线程.
- */
- int schedule_work(struct work_struct *work);
- int schedule_delayed_work(struct delayed_work *work, unsigned long delay);
- int schedule_on_each_cpu(work_func_t func);
6>刷新工作队列:
- /* 实际上,它只是等待(睡眠),直到缺省工作队列上的工作被执行.
- * complete()实现.
- */
- void flush_scheduled_work(void);
- /*等待指定的工作被执行*/
- bool flush_work(struct work_struct *work);
- bool flush_delayed_work(struct delayed_work *dwork);
7>取消工作:
- bool cancel_delayed_work(struct delayed_work *work);
- bool cancel_work_sync(struct work_struct *work);
- bool cancel_delayed_work_sync(struct delayed_work *dwork);
8>创建一个新的workqueue和对应的worker线程(每个cpu一个).
- /* 如果一个任务是处理器密集型和性能要求严格的
- * 那么可以选择创建自己的worker(工作者)线程
- * 当然,每个处理器一个.
- */
- struct workqueue_struct *create_workqueue(const char *name);
- /* struct workqueue_struct *alloc_workqueue(const char *name, unsigned int flags, int max_active);
- * the maximum number of execution contexts per cpu, up to 512.
- */
9>调度(提交)队列
- int queue_work(struct workqueue_struct *wq, struct work_struct *work);
- int queue_delayed_work(struct workqueue_struct *wq, struct delayed_work *work, unsigned long delay);
10>刷新一个工作队列:
- /* 等待(睡眠),直到指定队列上的工作被执行.
- * 事实上除了指定工作队列,它和flush_scheduled_work()没有区别.
- */
- void flush_workqueue(struct workqueue_struct *wq);
11>释放一个工作队列:
- void destroy_workqueue(struct workqueue_struct *wq);