标签：intChan goroutine chan 通信 int func go resultChan

示例demo52 package main
import ( 　　"fmt" )
func calc(taskChan chan int, resChan chan int, exitChan chan bool) { 　　for v := range taskChan { 　　　　flag := true 　　　　for i := 2; i < v; i++ { 　　　　　　if v%i == 0 { 　　　　　　　　flag = false 　　　　　　　　break 　　　　　　} 　　　　} 　　　　if flag {　　 　　　　　　//值放到resChan 通道里 　　　　　　resChan <- v 　　　　} 　　} 　　　　fmt.Println("exit") 　　　　exitChan <- true 　　}
func main() { 　　intChan := make(chan int, 1000) //初始化 intchan 通道 长度1000 　　resultChan := make(chan int, 1000) //初始化 resultChan通道 长度1000 　　closeChan := make(chan bool, 8) 　　go func() { //协程方式放进10000个数到intChan通道里 　　　　for i := 0; i < 100000; i++ { 　　　　　　intChan <- i 　　　　} 　　　　close(intChan) //关闭intChan通道 　　}()
　　//启8个协程 运行计算 传入intChan 和resultChan 　　for i := 0; i < 8; i++ { 　　　　go calc(intChan, resultChan, closeChan) 　　}
　　//等待所有计算的goroutine全部退出 　　go func() { 　　　　for i := 0; i < 8; i++ { 　　　　　　<-closeChan 　　　　} 　　　　close(closeChan) //关闭closeChan通道 　　　　close(resultChan) //关闭resultChan通道 　　}()
　　//循环 resultChan遍历数据 　　for v := range resultChan { 　　　　fmt.Println(v) 　　}
}

标签：intChan,goroutine,chan,通信,int,func,go,resultChan
来源： https://www.cnblogs.com/chenweihao/p/16611320.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。