初识goroutine
初识goroutine
秋风醉了 发表于1年前
初识goroutine
  • 发表于 1年前
  • 阅读 10
  • 收藏 0
  • 点赞 0
  • 评论 0

腾讯云 学生专属云服务套餐 10元起购>>>   

摘要: 初识goroutine

初识goroutine

Go语言通过goroutine提供了目前为止所有语言里对于并发编程的最清晰最直接的支持。

  1. **goroutine是Go语言运行库的功能,不是操作系统提供的功能,goroutine不是用线程实现的。**具体可参见Go语言源码里的pkg/runtime/proc.c
  2. **goroutine就是一段代码,一个函数入口,以及在堆上为其分配的一个堆栈。**所以它非常廉价,我们可以很轻松的创建上万个goroutine,但它们并不是被操作系统所调度执行
  3. 除了被系统调用阻塞的线程外,Go运行库最多会启动$GOMAXPROCS个线程来运行goroutine

goroutine从上面总结来看,其不是用线程实现的,只是一段代码,一个函数的入口,以及在堆上为其分配的一个堆栈。 goroutine是一个并发执行的单元。当一个程序启动时,其主函数即在一个单独的goroutine中运行,我们叫它main goroutine。新的goroutine会用go语句来创建。在语法上,go语句是一个普通的函数或方法调用前加上关键字go。go语句会使其语句中的函数在一个新创建的goroutine中运行。而go语句本身会迅速地完成。如下示例,

package main

import (
	"fmt"
)

func loop() {
	for i := 0; i < 10; i++ {
		fmt.Printf("%d ", i)
	}
}

func main() {
	go loop() //create a new goroutine that calls loop(); don't wait
	loop()    //call loop(); wait for it to return
}

运行结果,

[ `go  run  goroutine.go` | done: 336.67264ms ]
	0 1 2 3 4 5 6 7 8 9

可以看到,只输出了一个loop,其实是goroutine执行的loop没有输出,这是因为当main goroutine退出的时候,所有的goroutine都会被直接打断,程序退出。除了从主函数退出或者直接终止程序之外,没有其它的编程方法能够让一个goroutine来打断另一个的执行。 有什么办法能让goroutine 执行完成后让程序退出,简单的方法就是让main goroutine阻塞一会,如下,

package main

import (
	"fmt"
	"time"
)

func loop() {
	for i := 0; i < 10; i++ {
		fmt.Printf("%d ", i)
	}
}

func main() {
	go loop() //create a new goroutine that calls loop(); don't wait
	loop()    //call loop(); wait for it to return

	time.Sleep(time.Second) //让主函数阻塞

}

goroutine case 1

使用goroutine实现并发的Clock服务,如下代码,

package main

import (
	"fmt"
	"io"
	"log"
	"net"
	"time"
)

// handleConn函数会处理一个完整的客户端连接
// 会执行循环,而不会退出,那么就会阻碍后面的连接
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)
	}
}

func main() {

	listener, err := net.Listen("tcp", "127.0.0.1:9090")

	if err != nil {
		log.Fatal(err)
	}

	for {
		conn, err := listener.Accept() //istener对象的Accept方法会直接阻塞,直到一个新的连接被创建,然后会返回一个net.Conn对象来表示这个连接。
		fmt.Println("accept...")
		if err != nil {
			log.Print(err)
			continue
		}

		handleConn(conn) // handle one connection at a time
	}

}

如程序注释描述的一样,一次只能处理一个连接,怎么样才能并发的处理多个连接呢?使用goroutine,只需简单的在 handleConn()方法前面加一个go 关键字。

==========END==========

共有 人打赏支持
粉丝 215
博文 608
码字总数 434545
×
秋风醉了
如果觉得我的文章对您有用,请随意打赏。您的支持将鼓励我继续创作!
* 金额(元)
¥1 ¥5 ¥10 ¥20 其他金额
打赏人
留言
* 支付类型
微信扫码支付
打赏金额:
已支付成功
打赏金额: