goroutine
是一个轻量级的执行线程。
假设有一个函数调用f(s)
。 下面是以通常的方式调用它,同步运行它。
要在goroutine
中调用此函数,请使用go f(s)
。 这个新的goroutine
将与调用同时执行。
也可以为匿名函数调用启动一个goroutine
。
两个函数调用现在在不同的goroutine
中异步运行,所以执行到这里。这个ScanIn代码要求我们在程序退出之前按一个键。
当我们运行这个程序时,首先看到阻塞调用的输出,然后是两个gouroutines
的交替输出。 这种交替反映了Go运行时并发运行的goroutine
。
接下来,我们来看看在并发Go程序中goroutines
的一个补充:channels
。
所有的示例代码,都放在
F:\worksp\golang
目录下。安装Go编程环境请参考:http://www.yiibai.com/go/go_environment.html
goroutines.go
的完整代码如下所示 -
package main
import "fmt"
func f(from string) {
for i := 0; i < 3; i++ {
fmt.Println(from, ":", i)
}
}
func main() {
// Suppose we have a function call `f(s)`. Here's how
// we'd call that in the usual way, running it
// synchronously.
f("direct")
// To invoke this function in a goroutine, use
// `go f(s)`. This new goroutine will execute
// concurrently with the calling one.
go f("goroutine")
// You can also start a goroutine for an anonymous
// function call.
go func(msg string) {
fmt.Println(msg)
}("going")
// Our two function calls are running asynchronously in
// separate goroutines now, so execution falls through
// to here. This `Scanln` code requires we press a key
// before the program exits.
var input string
fmt.Scanln(&input)
fmt.Println("done")
}
执行上面代码,将得到以下输出结果 -
F:\worksp\golang>go run goroutines.go
direct : 0
direct : 1
direct : 2
goroutine : 0
goroutine : 1
goroutine : 2
going
123456
done