package main
import (
	"fmt"
	"time"
)
// 需求：
// 要求統(tǒng)計(jì)1-200000的數(shù)字，哪些是素?cái)?shù)？這個(gè)問題在本章開篇就提出了，現(xiàn)在我們有g(shù)oroutine和channel的知識(shí)后，就可以完成了【測(cè)試數(shù)據(jù)：80000】
// 分析思路：
// 傳統(tǒng)的方法，就是使用一個(gè)循環(huán)，循環(huán)的判斷各個(gè)數(shù)是不是素?cái)?shù)【ok】
// 使用并發(fā)/并行的方式，將統(tǒng)計(jì)素?cái)?shù)的任務(wù)分配給多個(gè)（x個(gè)）goroutine去完成，完成任務(wù)時(shí)間短
 
// 1. 向intChan放入1-8000的數(shù)字
func putNum(intChan chan int) {
	for i := 1; i <= 20000; i++ {
		intChan <- i
	}
	// 關(guān)閉intChan
	close(intChan)
}
 
// 從intChan中取出數(shù)據(jù)，并判斷是否為素?cái)?shù)，如果是，就放入到primeChan
func primeNum1(intChan chan int, primeChan chan int, exitChan chan bool) {
	// 使用for循環(huán)
	var flag bool
	for {
		time.Sleep(time.Millisecond * 10)
		num, ok := <- intChan
 
		if !ok { //intChan取不到，且關(guān)閉了管道
			break
		}
		flag = true // 假設(shè)是素?cái)?shù)
		// 判斷num是不是素?cái)?shù)
		for i := 2; i < num; i++ {
			if num % i == 0 { // 說明該num不是素?cái)?shù)
				flag = false
				break
			}
		}
		if flag {
			// 將這個(gè)數(shù)放到primeChan
			primeChan<- num
		}
	}
	fmt.Println("有一個(gè)prieNum 協(xié)程因?yàn)槿〔坏綌?shù)據(jù)，退出")
	// 這里我們還不能關(guān)閉primeChan
	// 向exitChan寫入true
	exitChan <- true
}
func main() {
	var intChan chan int = make(chan int, 1000)
	var primeChan chan int = make(chan int,2000)
	// 標(biāo)識(shí)退出的管道
	exitChan := make(chan bool,4)
	// 開啟一個(gè)協(xié)程，向intChan放入 1-8000個(gè)數(shù)
	go putNum(intChan)
	// 開啟4個(gè)協(xié)程，從 intChan中取出數(shù)據(jù)，并判斷是否為素?cái)?shù)，如果是就放入到primeChan
	for i := 0; i < 10000; i++ {
		go primeNum1(intChan,primeChan,exitChan)
	}
	// 這里我們主線程，進(jìn)行處理
	go func() {
		for i := 0; i < 4; i++ {
			<-exitChan
		}
		// 當(dāng)我們從exitChan中取出了4個(gè)結(jié)果，就可以放心的關(guān)閉primeChan
		close(primeChan)
	}()
	// 遍歷我們的primeChan，把結(jié)果取出
	for {
		res, ok := <- primeChan
		if !ok {
			break
		}
		// 將結(jié)果取出
		fmt.Printf("素?cái)?shù)=%d\n",res)
	}
	fmt.Println("main線程退出")
}