阻塞chan中的写操作有多少个？

一分耕耘，一分收获！既然打开了这篇文章《阻塞chan中的写操作有多少个？》，就坚持看下去吧！文中内容包含等等知识点...希望你能在阅读本文后，能真真实实学到知识或者帮你解决心中的疑惑，也欢迎大佬或者新人朋友们多留言评论，多给建议！谢谢！

我使用 chan 来进行 goroutine 的写入/读取，如果 chan 已满，则写入 goroutine 将被阻塞，直到另一个 goroutine 从 chan 读取。

我知道chan中有一个recvq和sendq双链表来记录被阻塞的goroutine。我的问题是，如果不读取 chan ，总共可以阻止多少个 goroutine？这取决于内存大小吗？

正确答案

tldr：只要您的应用程序可以装入内存并可以运行，就不会遇到任何频道等待队列问题。

语言规范不限制通道等待 goroutine 的数量，因此没有实际限制。

运行时实现可能会将等待的 goroutine 限制为一个微不足道的高值（例如，由于指针大小、整数计数器大小等），但要达到这样的实现限制，您会更快地耗尽内存。

goroutines 是轻量级线程，但它们确实需要较小的内存。它们从一个大约 kb 的小堆栈开始，因此即使您估计为 1 kb，如果您有 100 万个 goroutines，那至少已经是 1 gb 内存，如果您有 10 亿个 goroutine，那就是 1 tb。例如，十亿远不及 int64 的最大值。

在遇到实现特定的等待队列限制之前，您的 cpu 和 go 运行时将无法管理数十亿个 goroutine。

是的，这取决于内存。这取决于文档中提到的通道长度，一旦 chan 已满，缓冲通道就会被阻塞，而当另一个值添加到 chan 时，缓冲通道就会被解除阻塞。 channels

文档中的代码片段：

var sem = make(chan int, MaxOutstanding)

func handle(r *Request) {
    sem <- 1    // Wait for active queue to drain.
    process(r)  // May take a long time.
    <-sem       // Done; enable next request to run.
}

func Serve(queue chan *Request) {
    for {
        req := <-queue
        go handle(req)  // Don't wait for handle to finish.
    }
}

一旦 maxoutstanding 处理程序正在执行进程，更多的处理程序将阻止尝试发送到已填充的通道缓冲区，直到现有处理程序之一完成并从缓冲区接收。

今天带大家了解了的相关知识，希望对你有所帮助；关于Golang的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~