package main
import (
	"fmt"
)

func main() {

	//演示一下管道的使用
	//1. 創(chuàng)建一個(gè)可以存放3個(gè)int類型的管道
	var intChan chan int
	intChan = make(chan int, 3)

	//2. 看看intChan是什么
	fmt.Printf("intChan 的值=%v intChan本身的地址=%p\n", intChan, &intChan)


	//3. 向管道寫(xiě)入數(shù)據(jù)
	intChan<- 10
	num := 211
	intChan<- num
	intChan<- 50
	// //如果從channel取出數(shù)據(jù)后，可以繼續(xù)放入
	<-intChan
	intChan<- 98//注意點(diǎn), 當(dāng)我們給管寫(xiě)入數(shù)據(jù)時(shí)，不能超過(guò)其容量


	//4. 看看管道的長(zhǎng)度和cap(容量)
	fmt.Printf("channel len= %v cap=%v \n", len(intChan), cap(intChan)) // 3, 3

	//5. 從管道中讀取數(shù)據(jù)

	var num2 int
	num2 = <-intChan 
	fmt.Println("num2=", num2)
	fmt.Printf("channel len= %v cap=%v \n", len(intChan), cap(intChan))  // 2, 3

	//6. 在沒(méi)有使用協(xié)程的情況下，如果我們的管道數(shù)據(jù)已經(jīng)全部取出，再取就會(huì)報(bào)告 deadlock

	num3 := <-intChan
	num4 := <-intChan

	//num5 := <-intChan

	fmt.Println("num3=", num3, "num4=", num4/*, "num5=", num5*/)
}

fmt.Printf("intChan 的值=%v intChan本身的地址=%p\n", intChan, &intChan)

package main
import (
	"fmt"
)

type Cat struct {
	Name string
	Age int
}

func main() {

	//定義一個(gè)存放任意數(shù)據(jù)類型的管道 3個(gè)數(shù)據(jù)
	//var allChan chan interface{}
	allChan := make(chan interface{}, 3)

	allChan<- 10
	allChan<- "tom jack"
	cat := Cat{"小花貓", 4}
	allChan<- cat

	//我們希望獲得到管道中的第三個(gè)元素，則先將前2個(gè)推出
	<-allChan
	<-allChan

	newCat := <-allChan //從管道中取出的Cat是什么?

	fmt.Printf("newCat=%T , newCat=%v\n", newCat, newCat)
	//下面的寫(xiě)法是錯(cuò)誤的!編譯不通過(guò)
	//fmt.Printf("newCat.Name=%v", newCat.Name)
	//使用類型斷言
	a := newCat.(Cat) 
	fmt.Printf("newCat.Name=%v", a.Name)
}

data := <-ch

data, ok := <-ch

<-ch

package main

import (
    "fmt"
)

func main() {

    // 構(gòu)建一個(gè)通道
    ch := make(chan int)

    // 開(kāi)啟一個(gè)并發(fā)匿名函數(shù)
    go func() {

        fmt.Println("start goroutine")

        // 通過(guò)通道通知main的goroutine
        ch <- 0

        fmt.Println("exit goroutine")

    }()

    fmt.Println("wait goroutine")

    // 等待匿名goroutine
    <-ch

    fmt.Println("all done")

}

for data := range ch {
}

package main
import (
	"fmt"
)

func main() {

	intChan := make(chan int, 3)
	intChan<- 100
	intChan<- 200
	close(intChan) // close
	//這時(shí)不能夠再寫(xiě)入數(shù)到channel
	//intChan<- 300
	fmt.Println("okook~")
	//當(dāng)管道關(guān)閉后，讀取數(shù)據(jù)是可以的
	n1 := <-intChan
	fmt.Println("n1=", n1)


	//遍歷管道
	intChan2 := make(chan int, 100)
	for i := 0; i < 100; i++ {
		intChan2<- i * 2  //放入100個(gè)數(shù)據(jù)到管道
	}

	//遍歷管道不能使用普通的 for 循環(huán)
	// for i := 0; i < len(intChan2); i++ {

	// }
	//在遍歷時(shí)，如果channel沒(méi)有關(guān)閉，則會(huì)出現(xiàn)deadlock的錯(cuò)誤
	//在遍歷時(shí)，如果channel已經(jīng)關(guān)閉，則會(huì)正常遍歷數(shù)據(jù)，遍歷完后，就會(huì)退出遍歷
	close(intChan2)
	for v := range intChan2 { //沒(méi)有下標(biāo)
		fmt.Println("v=", v)
	}
}

package main

import (
	"fmt"
)

//write Data
func writeData(intChan chan int) {
	for i := 1; i <= 50; i++ {
		//放入數(shù)據(jù)
		intChan <- i //
		fmt.Println("writeData ", i)
		//time.Sleep(time.Second)
	}
	close(intChan) //關(guān)閉
}

//read data
func readData(intChan chan int, exitChan chan bool) {

	for {
		v, ok := <-intChan
		if !ok {
			break
		}
		// time.Sleep(time.Second)
		fmt.Printf("readData 讀到數(shù)據(jù)=%v\n", v)
	}
	//readData 讀取完數(shù)據(jù)后，即任務(wù)完成
	exitChan <- true
	close(exitChan)

}

func main() {

	//創(chuàng)建兩個(gè)管道
	intChan := make(chan int, 10)
	exitChan := make(chan bool, 1)

	go writeData(intChan)
	go readData(intChan, exitChan)

	//time.Sleep(time.Second * 10)
	for {
		_, ok := <-exitChan
		if !ok {
			break
		}
	}

}

package main

import (
	"fmt"
	"time"
)

//向 intChan放入 1-8000個(gè)數(shù)
func putNum(intChan chan int) {

	for i := 1; i <= 80000; i++ {
		intChan <- i
	}

	//關(guān)閉intChan
	close(intChan)
}

// 從 intChan取出數(shù)據(jù)，并判斷是否為素?cái)?shù),如果是，就
// 	//放入到primeChan
func primeNum(intChan chan int, primeChan chan int, exitChan chan bool) {

	//使用for 循環(huán)
	// var num int
	var flag bool //
	for {
		//time.Sleep(time.Millisecond * 10)
		num, ok := <-intChan //intChan 取不到..

		if !ok {
			break
		}
		flag = true //假設(shè)是素?cái)?shù)
		//判斷num是不是素?cái)?shù)
		for i := 2; i < num; i++ {
			if num%i == 0 { //說(shuō)明該num不是素?cái)?shù)
				flag = false
				break
			}
		}

		if flag {
			//將這個(gè)數(shù)就放入到primeChan
			primeChan <- num
		}
	}

	fmt.Println("有一個(gè)primeNum 協(xié)程因?yàn)槿〔坏綌?shù)據(jù)，退出")
	//這里我們還不能關(guān)閉 primeChan
	//向 exitChan 寫(xiě)入true
	exitChan <- true

}

func main() {

	intChan := make(chan int, 1000)
	primeChan := make(chan int, 20000) //放入結(jié)果
	//標(biāo)識(shí)退出的管道
	exitChan := make(chan bool, 4) // 4個(gè)

	start := time.Now().Unix()

	//開(kāi)啟一個(gè)協(xié)程，向 intChan放入 1-8000個(gè)數(shù)
	go putNum(intChan)
	//開(kāi)啟4個(gè)協(xié)程，從 intChan取出數(shù)據(jù)，并判斷是否為素?cái)?shù),如果是，就
	//放入到primeChan
	for i := 0; i < 4; i++ {
		go primeNum(intChan, primeChan, exitChan)
	}

	//這里我們主線程，進(jìn)行處理
	//直接
	go func() {
		for i := 0; i < 4; i++ {
			<-exitChan
		}

		end := time.Now().Unix()
		fmt.Println("使用協(xié)程耗時(shí)=", end-start)

		//當(dāng)我們從exitChan 取出了4個(gè)結(jié)果，就可以放心的關(guān)閉 prprimeChan
		close(primeChan)
	}()

	//遍歷我們的 primeChan ,把結(jié)果取出
	for {
		res, ok := <-primeChan
		if !ok {
			break
		}
		//將結(jié)果輸出
		fmt.Printf("素?cái)?shù)=%d\n", res)
	}

	fmt.Println("main線程退出")

}

go func() {
		for i := 0; i < 4; i++ {
			<-exitChan
		}

		end := time.Now().Unix()
		fmt.Println("使用協(xié)程耗時(shí)=", end-start)

		//當(dāng)我們從exitChan 取出了4個(gè)結(jié)果，就可以放心的關(guān)閉 prprimeChan
		close(primeChan)
	}()