美文网首页
kernel 等待队列

kernel 等待队列

作者: 分享放大价值 | 来源:发表于2020-11-06 22:00 被阅读0次

Linux内核的sleep/wakeup机制非常重要,几乎贯穿了所有的内核子系统,值得注意的是,这里的sleep/wakeup依然采用了OO的思想,并没有限制睡眠的entry一定要是一个task,而是将睡眠的entry做了一层抽象,即:

struct __wait_queue {
    unsigned int flags;
    // 至于这个private到底是什么,内核并不限制,它可以是task,也可以是别的。
    void *private;
    wait_queue_func_t func;
    struct list_head task_list; //挂在链表__wait_queue_head
};
typedef struct __wait_queue wait_queue_t;

以上的这个entry,最终要睡眠在下面的数据结构实例化的一个链表上:

struct __wait_queue_head {
    spinlock_t lock;
    struct list_head task_list;
};
typedef struct __wait_queue_head wait_queue_head_t;

被等待的事件会提供链表wait_queue_head_t,等待事件的进程会初始化wait_queue_t,然后插入被等待事件的链表wait_queue_head_t后开始睡眠等待。
当事件发生后,会遍历链表wait_queue_head_t上的wait_queue_t,执行其func函数default_wake_function将等待进程唤醒。

entry初始化

//调用此函数的一般是需要将调用进程睡眠等待事件发生
//事件发生时调用default_wake_function来唤醒调用进程

static inline void init_waitqueue_entry(wait_queue_t *q, struct task_struct *p)
{
    q->flags    = 0;
    q->private  = p;
    q->func     = default_wake_function;
}

//调用此函数的一般不会是打算唤醒进程,而是事件发生时,调用func来做其他事情,比如epoll_ctl添加监听目标

static inline void
init_waitqueue_func_entry(wait_queue_t *q, wait_queue_func_t func)
{
    q->flags    = 0;
    q->private  = NULL;
    q->func     = func;
}

将entry添加到等待队列

有四个版本的添加函数用来将wait_queue_t添加到链表wait_queue_head_t
a. 直接添加到队列头部

static inline void __add_wait_queue(wait_queue_head_t *head, wait_queue_t *new)
{
    list_add(&new->task_list, &head->task_list);
}

b. 设置exclusive标志,并添加到队列头部 //epoll_wait使用此函数

/*
 * Used for wake-one threads:
 */
static inline void
__add_wait_queue_exclusive(wait_queue_head_t *q, wait_queue_t *wait)
{
    wait->flags |= WQ_FLAG_EXCLUSIVE;
    __add_wait_queue(q, wait);
}

c. 直接添加到队列尾部

static inline void __add_wait_queue_tail(wait_queue_head_t *head,
                     wait_queue_t *new)
{
    list_add_tail(&new->task_list, &head->task_list);
}

d. 设置exclusive标志,并添加到队列尾部 //accept使用此函数

static inline void
__add_wait_queue_tail_exclusive(wait_queue_head_t *q, wait_queue_t *wait)
{
    wait->flags |= WQ_FLAG_EXCLUSIVE;
    __add_wait_queue_tail(q, wait);
}

删除entry

//将old entry从链表中删除

static inline void
__remove_wait_queue(wait_queue_head_t *head, wait_queue_t *old)
{
    list_del(&old->task_list);
}

唤醒任务

//将wait_queue_head_t 上的任务唤醒

void __wake_up(wait_queue_head_t *q, unsigned int mode,
            int nr_exclusive, void *key)
{
    unsigned long flags;

    spin_lock_irqsave(&q->lock, flags);
    __wake_up_common(q, mode, nr_exclusive, 0, key);
    spin_unlock_irqrestore(&q->lock, flags);
}
static void __wake_up_common(wait_queue_head_t *q, unsigned int mode,
            int nr_exclusive, int wake_flags, void *key)
{
    wait_queue_t *curr, *next;

    list_for_each_entry_safe(curr, next, &q->task_list, task_list) {
        unsigned flags = curr->flags;
        //调用__pollwake或者default_wake_function将进程唤醒
        //如果设置了WQ_FLAG_EXCLUSIVE,则只唤醒nr_exclusive个任务
        if (curr->func(curr, mode, wake_flags, key) &&
                (flags & WQ_FLAG_EXCLUSIVE) && !--nr_exclusive)
            break;
    }
}

相关文章

  • kernel 等待队列

    Linux内核的sleep/wakeup机制非常重要,几乎贯穿了所有的内核子系统,值得注意的是,这里的sleep/...

  • INIT_WORK

    kernel 使用了很多工作队列。了解历史更好的理解INIT_WORK 参数 1- old kernel(2.6 ...

  • Select & Epoll原理

    预备知识 等待队列 等待队列有一个等待队列头,其他加入这个等待队列的需要加在这个头上。 需要加入等待队列的话,可以...

  • Linux内核设计与实现 进程调度2: 调度算法

    运行队列 进程调度的最基本数据结构就是运行队列(struct runqueue 定义在

  • AQS源码解析

    等待队列中线程出队列时机 总的来说,一个线程获取锁失败了,被放入等待队列,acquireQueued会把放入队列中...

  • 等待队列

    工作队列和等待队列的区别 1.work queue 是一种bottom half,中断处理的后半程,强调的是动态的...

  • 等待队列

    等待队列 表示一组睡眠的进程,当某一条件为真时,由内核唤醒他们 在 Linux 中, 一个等待队列由一个"等待队列...

  • 等待队列

    等待队列概念以及使用 一、概述等待队列在内核中有很多用途,尤其在中断处理、进程同步及定时。等待队列实现事件上的条件...

  • Day30

    AQS 同步等待队列 & 条件等待队列 ReentrantLock同步执行,类似synchronized可重入 s...

  • 5、阻塞队列(BlockingQueue)和同步队列(Synch

    队列:FIFO(先进先出)阻塞: 写入:如果队列满了,就必须阻塞等待 读取:如果队列为空,必须阻塞等待生产。160...

网友评论

      本文标题:kernel 等待队列

      本文链接:https://www.haomeiwen.com/subject/ofuxbktx.html