=Go 语言中的并发可以用两种方式实现:
第一种方式,支持顺序通信进程(communicating sequential processes),简称 CSP。CSP是一种现代的并发编程模型,在这种编程模型中值会在不同的运行实例(goroutine)中传递,尽管大多数情况下仍然是被限制在单一实例中。
第二种实现方式就是更为传统的并发模型:多线程共享内存。
在Go语言中,每一个并发的执行单元叫作一个goroutine。当一个程序启动时,其主函数即在一个单独的goroutine中运行,我们叫它main goroutine。新的goroutine会用go语句来创建。在语法上,go语句是一个普通的函数或方法调用前加上关键字go。go语句会使其语句中的函数在一个新创建的goroutine中运行。而go语句本身会迅速地完成。主goroutine 结束运行,则 后台goroutine结束执行。
示例1
主 goroutine和后台goroutine
func main() {
go spinner(100 * time.Millisecond)
const n = 45
fibN := fib(n) // slow
fmt.Printf("\rFibonacci(%d) = %d\n", n, fibN)
}
//旋转的动画
func spinner(delay time.Duration) {
for {
for _, r := range `-\|/` {
fmt.Printf("\r%c", r)
time.Sleep(delay)
}
}
}
//菲波那契数列
func fib(x int) int {
if x < 2 {
return x
}
return fib(x-1) + fib(x-2)
}
示例2
下面的例子是顺序执行的时钟服务器,它会每隔一秒钟将当前时间写到客户端
package main
import (
"log"
"net"
"time"
"io"
)
func main() {
listener, err := net.Listen("tcp", "localhost:8000")
if err != nil {
log.Fatal(err)
}
for {
conn, err := listener.Accept()
if err != nil {
log.Print(err) // e.g., connection aborted
continue
}
handleConn(conn) // handle one connection at a time
}
}
func handleConn(c net.Conn) {
defer c.Close()
for {
_, err := io.WriteString(c, time.Now().Format("15:04:05\n"))
if err != nil {
return // e.g., client disconnected
}
time.Sleep(1 * time.Second)
}
}
可以使用 talnet 或者 netcat命令连接这个服务。

原文:http://www.cnblogs.com/lemos/p/6872745.html