标签：分享 限制 客户端 ges 主函数 logs duration 程序 不同
=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命令连接这个服务。
标签：分享 限制 客户端 ges 主函数 logs duration 程序 不同
原文地址：http://www.cnblogs.com/lemos/p/6872745.html
