在goroutine中执行的IO回调
来到编程网的大家,相信都是编程学习爱好者,希望在这里学习Golang相关编程知识。下面本篇文章就来带大家聊聊《在goroutine中执行的IO回调》,介绍一下,希望对大家的知识积累有所帮助,助力实战开发!
问题内容我是 golang 的初学者。看看所有 golang 教程,看起来您应该为所有内容创建 goroutine。来自 C 中的 libuv 之类的东西,您可以在单个线程上定义套接字读/写的回调,这是在 golang 中为所需的任何 IO 任务创建嵌套 goroutine 实现这一目标的正确方法吗?
举个例子,以 nginx 为例,其中单个线程将处理多个连接。为了在 golang 中做类似的事情,我们需要为每个连接一个 goroutine?
解决方案
Go 在编写网络服务的工具领域脱颖而出,特别是因为它将 I/O 感知功能集成到运行时调度程序中,为任何正在运行的 GO 程序提供支持。
基本思想大致是这样的:goroutine 在套接字上执行正常的、顺序的、无回调的操作——即普通读取和普通写入——并且一旦下一个 I/O 操作阻塞(是的,类 Unix 内核上的相关系统调用返回 EWOULDBLOCK
),goroutine 被挂起,其套接字被分发到名为“netpoller”的运行时组件中,该组件是使用平台本机套接字 I/O 多路复用器(例如 epoll
)实现的、 kqueue
或 IOCP,并且该 goroutine 运行的操作系统线程被移交给另一个想要运行的 goroutine。一旦 netpoller 发出信号,导致该 goroutine 挂起的套接字上的 I/O 可以继续,调度程序就会将该 goroutine 排队等待执行,然后它会继续从它停止的地方运行。
因此,在 Go 中编写网络服务时采用的常用模型是每个套接字有一个 goroutine。当您编写普通 TCP 服务器时,您应该自己创建一个 goroutine(并在接受客户端连接后将侦听器返回的套接字交给它)。
net/http.Server
内置了这种行为,因为它创建一个 goroutine 来服务每个传入的客户端请求(实际上,对于 HTTP/1.x,每个连接创建两个甚至三个 goroutine,但它对 HTTP 请求处理程序不可见) .
现在,我们刚刚介绍了基础知识。当然,可能存在合理的理由需要额外的 goroutine 来处理完成请求所需执行的任务,这就是 @Volker 所提到的。
更多信息:
- "What color is your function?" — 一篇经典文章,讨论作为库实现的 I/O 复用与在核心中实现的 I/O 复用。
- "Go's work-stealing scheduler";另请参阅 this、this 和 this design doc。
- State threads library 其实现的方法与 Go 非常相似,只是级别要低得多。它的文档对 Go 中实现的方法非常有洞察力。
libtask
是最近的一次尝试 同样的问题,是由 Go 的一位创建者提出的。
到这里,我们也就讲完了《在goroutine中执行的IO回调》的内容了。个人认为,基础知识的学习和巩固,是为了更好的将其运用到项目中,欢迎关注编程网公众号,带你了解更多关于的知识点!
免责声明:
① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。
② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341