首页 > 代码库 > Goroutines

Goroutines

2024-09-23 03:48:34   209人阅读

=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命令连接这个服务。

技术分享

 

Goroutines


联系
我们