Go 管道

var chan int//双向管道
var chan<- int //只写管道
var <-chan int//只读管道
//上诉管道中的数据类型全部是int

package main

import(
	"fmt"
	"time"
)

func Insert(Chan chan int){
	for i := 0;i< 5;i++{
		fmt.Println("Insert value to chan=",i)
		Chan<- i
		time.Sleep(time.Second)
	}
	close(Chan)
	fmt.Println("Close chan..")
}

func main(){
	var intChan chan int
	//管道使用事前需要make
	//intChan = make(chan int,3)//有缓冲管道
	intChan = make(chan int)//无缓冲管道

	go Insert(intChan)

	time.Sleep(time.Second * 3)

	for{
		res,ok := <-intChan
		if !ok{
			break
		}
		fmt.Println("get value form chan=",res)
		time.Sleep(time.Second)
	}
}