7

Go 的缓冲通道本质上是一个线程安全的 FIFO 队列。(参见Is it possible to use Go's buffered channel as a thread-safe queue?

我想知道它是如何实现的。它是否像Is there a 这样的事情,例如用于多个读取或写入线程的无锁队列中描述的那样无锁??

Go 的 src 目录 ( ) 中的 grepinggrep -r Lock .|grep chan给出以下输出:

./pkg/runtime/chan.c:   Lock;
./pkg/runtime/chan_test.go: m.Lock()
./pkg/runtime/chan_test.go: m.Lock() // wait
./pkg/sync/cond.go: L Locker // held while observing or changing the condition

不过,不要锁定我的机器(MacOS,intel x86_64)。是否有任何官方资源来验证这一点?

4

2 回答 2

8

如果您阅读chan.cruntime·chansend中的函数,您会看到它在检查通道是否被缓冲之前被调用。runtime·lockif(c->dataqsiz > 0)

换句话说,缓冲通道(以及一般的所有通道)使用锁。

您的搜索没有找到它的原因是您正在寻找带有大写 L 的“Lock”。用于通道的锁定函数是运行时中的非导出 C 函数。

于 2012-10-27T18:51:50.777 回答
7

你可以为你喜欢的一切编写无锁(甚至是无等待!)实现。像 CMPXCHG 这样的现代硬件原语足以普遍使用。但是编写和验证这样的算法并不是最简单的任务之一。除此之外,可能存在更快的算法:无锁算法通常只是算法的一个很小的子集。

据我记得,Dmitry Vyukov 过去曾为 Go 编写过无锁 MPMC(多生产者/多消费者)通道实现,但由于 Go 的 select 语句存在一些问题,该补丁被放弃了。有效地支持这一说法似乎真的很难。

然而,Go 的通道类型的主要目标是提供一个高级并发原语,该原语易于用于广泛的问题。即使不是并发编程专家的开发人员也应该能够编写可以在大型软件项目中轻松查看和维护的正确程序。如果您有兴趣挤出最后一点性能,则必须编写适合您需求的专用队列实现。

于 2012-10-28T00:10:07.417 回答