function take(cb) {
if (closed && buffer.isEmpty()) {
cb(END)
} else if (!buffer.isEmpty()) {
cb(buffer.take())
} else {
takers.push(cb)
cb.cancel = () => remove(takers, cb)
}
}

上面是 channel.js 里的代码, 首先 dispatch() 或者 put() 会将消息放到 buffer 中, 当 buffer 为空, 则还没有任何消息到来, 这时候 take(channel) 或者 take('MESSAGE') 会存到 takers 中, 在下次消息到的时候, 取出来一个来执行:

function put(input) {
if (closed) {
return
}
if (!takers.length) {
return buffer.put(input)
}
const cb = takers[0]
takers.splice(0, 1)
cb(input)
}

如果阻塞时候 buffer 来了很多消息, 后来阻塞结束(比如例子中 while 的新一轮循环), 判断 `!buffer.isEmpty()` 会直接从 buffer 中取出一条消息来执行 cb(buffer.take())