使用 Goroutine 进行数据处理
在 Go 中,goroutine 是一种轻量级线程,可以实现任务的并发执行。使用 goroutine 时,在处理后正确收集结果以避免死锁非常重要。
问题陈述
考虑以下代码片段:
此代码尝试使用 goroutine 处理列表中的项目并将结果收集到切片中。然而,它遇到了死锁错误,因为在收集结果之前通道已关闭。
解决方案
要解决这个问题,我们可以异步关闭通道工人们已经完成加工。下面是更正后的代码:
此代码启动处理项目并将结果发送到sampleChan 的goroutines。同时,它还启动另一个 goroutine,等待所有工作线程完成,然后关闭通道。这可以确保在通道关闭之前收集所有结果。
替代解决方案
为了更好的代码可读性和可测试性,建议使用同步 newSample 函数和句柄主 Goroutine 中的并发性。
这种方法使并发原语保持本地化,简化代码维护并降低错误风险。
以上是从 Goroutine 收集结果时如何避免死锁?的详细内容。更多信息请关注PHP中文网其他相关文章!