Go语言入门14(channel通道01)

channel(一)

​ channel用于goroutines之间的通信,让它们之间可以进行数据交换。像管道一样,一个goroutine_A向channel_A中放数据,另一个goroutine_B从channel_A取数据

channel 基本语法

// 因为channel是指针类型的数据类型,所以通过make来分配内存
// 使用make声明一个channel,里面可以存放string类型的数据
channel := make(chan string)
// 将tmp送到channel中
channel <- tmp
// 从channel中接受数据给tmp
tmp := <- channel
// 从channel中接受数据给tmp,如果没有接受到则ok值为false
tmp,ok := <- channel
// 关闭通道channel
close(channel)

无缓冲的通道

​ 没有缓冲的通道,如果routine A向通道中发送了一个数据,那么必须等到这个数据被其他routine 取出之后,才能继续往通道里发送,严格遵循”一进一出“原则,这也就要求两个routine 在同时对同一个通道进行写操作和取操作

  • sender端向channel中send一个数据,然后阻塞,直到receiver端将此数据receive
  • receiver端一直阻塞,直到sender端向channel发送了一个数据
// 两个routine分别对一个通道进行取放操作,并且对里面的数据+1,到2000截至
// 严格遵循“一进一出”
func Routine01(wg *sync.WaitGroup, count chan int) {
	defer wg.Done()
	for {
        // 从通道中拿取数据
		res, ok := <-count
		if !ok {
            // 说明通道中已经没有数据,或者已被关闭
			fmt.Println("finish!")
			break
		}
		fmt.Println(res)
		if res == 2000 {
			close(count)
			break
		}
		count <- res + 1
	}
}

func main() {
	var wg sync.WaitGroup
    // 新建一个无缓冲的通道count
	count := make(chan int)
	wg.Add(2)
    // 创建两个协程
	for i := 0; i < 2; i++ {
		go Routine01(&wg, count)
	}
    // 给管道里送一个数据,来开始操作
	count <- 1
	wg.Wait()
}

有缓冲的通道

​ 有缓冲的通道,可以控制里面的缓冲区大小,可以借助通道实现异步的取放操作

  • 容量:表示buffered channel最多可以缓冲多少个数据
  • 长度:表示buffered channel当前已缓冲多少个数据
  • 创建buffered channel的方式为make(chan TYPE,CAP)
// 新建Routine来模拟机器人工作
func Routine02(wg *sync.WaitGroup, count chan string) {
	defer wg.Done()
	for {
        // 从通道中分配工作
		tmp, ok := <-count
		if !ok {
            // 代表通道已经空了,或者已被关闭
			fmt.Println("No task else!")
			break
		}
		fmt.Println(tmp + " start!")
		time.Sleep(200 * time.Millisecond)
		fmt.Println(tmp + " done!")
	}
}

func main() {
	var wg sync.WaitGroup
    // 新建一个缓冲区大小为5的通道,来管理工作
	count := make(chan string, 5)
	wg.Add(2)
	fmt.Println("Work start!")
    // 往缓冲区中放一系列待完成的工作
	for i := 0; i < 5; i++ {
		tmp := fmt.Sprintf("Task %d", i)
		count <- tmp
		fmt.Println(tmp + " in!")
	}
	for i := 0; i < 2; i++ {
		go functions.Routine(&wg, count)
	}
    // 关闭通道
	close(count)
	wg.Wait()
}

热门相关:斗神战帝   学霸女神超给力   名门天后:重生国民千金   重生之至尊千金   夫人,你马甲又掉了!