Chinaunix首页 | 论坛 | 博客
  • 博客访问: 216874
  • 博文数量: 32
  • 博客积分: 410
  • 博客等级: 一等列兵
  • 技术积分: 396
  • 用 户 组: 普通用户
  • 注册时间: 2012-04-03 16:58
文章分类

全部博文(32)

文章存档

2013年(17)

2012年(15)

我的朋友

分类: LINUX

2013-03-27 12:57:43

今天看usb接口驱动碰到了:INIT_WORK(&intf->reset_ws, __usb_queue_reset_device);随便再温习一下啦;
整个说明部分应该属于工作队列的范畴(workqueue);

1:工作队列(work queue)
是Linux kernel中将工作推后执行的一种机制。这种机制和BH或Tasklets不同之处在于工作队列是把推后的工作交由一个内核线程去执行,因此工作队列的优势就在于它允许重新调度甚至睡眠。
 整理流程:先初始化一项工作,然后想办法将此工作添加到一个内核线程关联的队列中;内核线程执行时,FIFO的方式执行队列中的“工作”
本例中的工作线程追溯:
INIT_WORK(&intf->reset_ws, __usb_queue_reset_device);()初始化工作

void usb_queue_reset_device(struct usb_interface *iface)//想必此函数被调用
{
    schedule_work(&iface->reset_ws);
}

int schedule_work(struct work_struct *work)
{
    return queue_work(keventd_wq, work);
}
最终:queue_work_on添加到内核线程里面了;
/**
 * queue_work - queue work on a workqueue
 * @wq: workqueue to use
 * @work: work to queue
 * Returns 0 if @work was already on a queue, non-zero otherwise.
 * We queue the work to the CPU on which it was submitted, but if the CPU dies
 * it can be processed by another CPU.
 */
int queue_work(struct workqueue_struct *wq, struct work_struct *work)
{
    int ret;

    ret = queue_work_on(get_cpu(), wq, work);
    put_cpu();

    return ret;
}

2:workqueue的基本操作:

    
1: INIT_WORK(struct work_struct *work, work_func_t func);
//初始化指定工作,目的是把用户指定的函数_func及_func。
2: INIT_DELAYED_WORK(struct delayed_work *work, work_func_t func);
3: int schedule_work(struct work_struct *work);
//对工作进行调度,即把给定工作的处理函数提交给缺省的工作队列和工作者线程。工作者线程本质上是一个普通的内核线程,在默认情况下,每个CPU均有一个类型为“events”的工作者线程,当调用schedule_work时,这个工作者线程会被唤醒去执行工作链表上的所有工作。
4: int schedule_delayed_work(struct delayed_work *work, unsigned long delay);
//延迟执行工作,与schedule_work类似。
5: struct workqueue_struct *create_workqueue(const char *name);
//自定义工作队列,创建新的工作队列和相应的工作者线程,name用于该内核线程的命名。
6: int queue_work(struct workqueue_struct *wq, struct work_struct *work);
//类似于schedule_work,区别在于queue_work把给定工作提交给创建的工作队列wq而不是缺省队列。
7: int queue_delayed_work(struct workqueue_struct *wq, struct delayed_work *work, unsigned long delay);
//延迟执行工作。
8: void flush_scheduled_work(void);
//刷新缺省工作队列。此函数会一直等待,直到队列中的所有工作都被执行。
9: void flush_workqueue(struct workqueue_struct *wq);
//刷新指定工作队列。
10: int cancel_delayed_work(struct delayed_work *work);
//flush_scheduled_work并不取消任何延迟执行的工作,因此,如果要取消延迟工作,应该调用cancel_delayed_work。
11: void destroy_workqueue(struct workqueue_struct *wq);
//释放创建的工作队列。

3:网络范例抄录
struct my_struct_t {
    char *name;
    struct work_struct my_work;
};
 
void my_func(struct work_struct *work)
{
    struct my_struct_t *my_name = container_of(work, struct my_struct_t, my_work);
    printk(KERN_INFO “Hello world, my name is %s!\n”, my_name->name);
}
 
struct workqueue_struct *my_wq = create_workqueue(“my wq”);
struct my_struct_t my_name;
 
my_name.name = “Jack”;
 
INIT_WORK(&(my_name.my_work), my_func);
queue_work(my_wq, &(my_name.my_work));
 
destroy_workqueue(my_wq);
阅读(10413) | 评论(0) | 转发(2) |
给主人留下些什么吧!~~