Go语言入门学习之Channel通道详解

var channel_name chan channel_types 

var str chan string 

channel_name = make(chan channel_type) 

str = make(chan string) 

str := make(chan string) 

channel_name <- data 

value := <- channel_name 

func PrintFunc(c chan string) {
   c <- "往通道里面传数据"
}

func main() {
   str := make(chan string)
   fmt.Println("start")
   go PrintFunc(str)
   result := <-str
   fmt.Println(result)
   fmt.Println("end")
}

close(channel_name) 

value, ok := <- channel_name 

ch := make(chan int, 100)

func main() {
   // 创建一个通道
   c := make(chan int, 5)
   fmt.Println("初始化：")
   fmt.Println("cap：", cap(c))
   fmt.Println("len：", len(c))
   c <- 1
   c <- 2
   c <- 3
   fmt.Println("传入数据：")
   fmt.Println("cap：", cap(c))
   fmt.Println("len：", len(c))
   <-c
   fmt.Println("取出一个数：")
   fmt.Println("cap：", cap(c))
   fmt.Println("len：", len(c))
}

c := make(chan int) 
// 或者 
c := make(chan int, 0) 

c := make(chan int, 3) 

func main() {
   // 创建一个通道
   c := make(chan int)

   // 发送数据
   go func() {
      fmt.Println("send: 1")
      c <- 1
   }()

   // 接收数据
   go func() {
      n := <-c
      fmt.Println("receive:", n)
   }()

   // 主协程休眠
   time.Sleep(time.Millisecond)
}

// 定义只读通道
c := make(chan string)
// 定义类型
type Receiver = <-chan string
var receiver Receiver = c

// 或者简单写成下面的形式
type Receiver = <-chan int
receiver := make(Receiver)

// 定义只写通道
c := make(chan int)
// 定义类型
type Sender = chan<- int
var sender Sender = c

// 或者简单写成下面的形式
type Sender = chan<- int
sender := make(Sender)

package main

import (
   "fmt"
   "time"
)

// Sender 只写通道类型
type Sender = chan<- string

// Receiver 只读通道类型
type Receiver = <-chan string

func main() {
   // 创建一个双向通道
   var ch = make(chan string)

   // 开启一个协程
   go func() {
      // 只写通道
      var sender Sender = ch
      fmt.Println("write only start:")
      sender <- "Go"
   }()

   // 开启一个协程
   go func() {
      // 只读通道
      var receiver Receiver = ch
      message := <-receiver
      fmt.Println("readonly start: ", message)
   }()

   time.Sleep(time.Millisecond)
}

package main

import (
   "fmt"
)

func loopPrint(c chan int) {
   for i := 0; i < 10; i++ {
      c <- i
   }
   // 记得要关闭通道
   // 否则主协程遍历完不会结束，而会阻塞
   close(c)
}

func main() {
   // 创建一个通道
   var ch2 = make(chan int, 5)
   go loopPrint(ch2)
   for v := range ch2 {
      fmt.Println(v)
   }
}

package main

import (
   "fmt"
)

func fibonacci(n int, c chan int) {
   x, y := 0, 1
   for i := 0; i < n; i++ {
      c <- x
      x, y = y, x+y
   }
   close(c)
}

func main() {
   c := make(chan int, 10)
   go fibonacci(cap(c), c)
   // range 函数遍历每个从通道接收到的数据，因为 c 在发送完 10 个
   // 数据之后就关闭了通道，所以这里我们 range 函数在接收到 10 个数据
   // 之后就结束了。如果上面的 c 通道不关闭，那么 range 函数就不
   // 会结束，从而在接收第 11 个数据的时候就阻塞了。
   for i := range c {
      fmt.Println(i)
   }
}