package main

import "time"

func testThread(){
    i:=3
    go func(a int){
        println(a)
        println("this is go func！")
    }(i)

    time.Sleep(1*time.Second)
    println("hello main thread!")
}

func testChannel(){
    //read write channel
    ch:=make(chan int,1)
    ch<-3
    go func(){
        v:=<-ch
        println(v)
    }()
    time.Sleep(1*time.Second)
    println("finish chan!")
}

func producer(p chan<-int){
    for i:=0;i<10;i++{
        p<-i
        println("into chan:",i)
    }
    println("finish the producer!")

}

func consumers(c <-chan int){
    for i:=0;i<10;i++{
        v:=<-c
        println("get from channel:",v)

    }
    println("finish the consumers!!")
}

//test producer and consumer
func testProducerConsumer(){
    ch:=make(chan int,1)
    go consumers(ch)
    go producer(ch)
    time.Sleep(2*time.Second)
    println("finish all the consumer and producer!!")
}

func main() {
    //testThread()
    //testChannel()
    testProducerConsumer()
}