
我正在阅读一些开源go项目,发现有很多代码实现如下:
for id, s := range subscribers {
go func(id string, s *hellosaidsubscriber) {
select {
case <-s.stop:
unsubscribe <- id
return
default:
}
select {
case <-s.stop:
unsubscribe <- id
case s.events <- e:
case <-time.after(time.second):
}
}(id, s)
}
在上面的代码中,内部函数 go func...(id, s) 看起来没有必要。换句话说,如果我编写如下代码会有什么不同:
for id, s := range subscribers {
select {
case <-s.stop:
unsubscribe <- id
return
default:
}
select {
case <-s.stop:
unsubscribe <- id
case s.events <- e:
case <-time.After(time.Second):
}
}
正确答案
在您的第一个示例中,这是一个匿名函数 go 关键字使其充当 goroutine,这是 Go 中的并发模式。因此匿名函数(goroutine)内的代码将同时处理。
在第二个示例中,排除 goroutine 意味着代码将按顺序运行。
本文档主要讲述的是用Apache Spark进行大数据处理——第一部分:入门介绍;Apache Spark是一个围绕速度、易用性和复杂分析构建的大数据处理框架。最初在2009年由加州大学伯克利分校的AMPLab开发,并于2010年成为Apache的开源项目之一。 在这个Apache Spark文章系列的第一部分中,我们将了解到什么是Spark,它与典型的MapReduce解决方案的比较以及它如何为大数据处理提供了一套完整的工具。希望本文档会给有需要的朋友带来帮助;感
立即学习“go语言免费学习笔记(深入)”;
匿名函数是不包含任何名称的函数。当您想要创建内联函数时经常使用它。它可以形成闭合。匿名函数也称为函数文字。









