Go-并发模式1(Basic Examples)

2022-11-12 64

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： Go-并发模式1(Basic Examples)

一个无聊的函数

package main
import (
  "fmt"
  "time"
)
func main() {
  boring("boring!")
}
func boring(msg string) {
  for i := 0; ; i++ {
    fmt.Println(msg, i)
    time.Sleep(time.Second)
  }
}

过一秒输出一下boring! 加数字，结果如下：

稍微无聊的函数

package main
import (
  "fmt"
  "math/rand"
  "time"
)
func main() {
  boring("boring!")
}
// START OMIT
func boring(msg string) {
  for i := 0; ; i++ {
    fmt.Println(msg, i)
    time.Sleep(time.Duration(rand.Intn(1e3)) * time.Millisecond)
  }
}

不再等待一个固定的时间

使用goroutine

package main
import (
  "fmt"
  "math/rand"
  "time"
)
func main() {
  go boring("boring!")
}
func boring(msg string) {
  for i := 0; ; i++ {
    fmt.Println(msg, i)
    time.Sleep(time.Duration(rand.Intn(1e3)) * time.Millisecond)
  }
}

我们在main函数中使用goroutine来运行go函数，结果

是的，没有错，直接结束了程序，因为在go中不会默认等待goroutine结束

使用goroutine并等待一段时间

package main
import (
  "fmt"
  "math/rand"
  "time"
)
func main() {
  go boring("boring!")
  fmt.Println("I'm listening.")
  time.Sleep(2 * time.Second)
  fmt.Println("You're boring; I'm leaving.")
}
func boring(msg string) {
  for i := 0; ; i++ {
    fmt.Println(msg, i)
    time.Sleep(time.Duration(rand.Intn(1e3)) * time.Millisecond)
  }
}

在main函数中等待了2秒，然后结束

什么是goroutine呢？

goroutine是独立运行的函数。它有自己的调用栈，不是线程，可能成千上万个goroutine只有一个线程，根据需要将goroutine动态地多路复用到线程上，以保持所有goroutine的运行。

通信

前面的例子给了大家一个假象，仿佛知道goroutine在运行什么，输出什么。但实际上，我们无法得知goroutine应该运行多长时间。因此，我们需要通信来进行更好的程序衔接与合作，这就引出了channel。

使用通道channels

package main
import (
  "fmt"
  "math/rand"
  "time"
)
func main() {
  c := make(chan string)
  go boring("boring!", c)
  for i := 0; i < 5; i++ {
    fmt.Printf("You say: %q\n", <-c) // Receive expression is just a value.
  }
  fmt.Println("You're boring; I'm leaving.")
}
func boring(msg string, c chan string) {
  for i := 0; ; i++ {
    c <- fmt.Sprintf("%s %d", msg, i) // Expression to be sent can be any suitable value.
    time.Sleep(time.Duration(rand.Intn(1e3)) * time.Millisecond)
  }
}