## 统计1-8000哪些是素数
```
package main
import (
"fmt"
"time"
)
func putNum(intChan chan int) {
for i := 1; i <= 8000; i++ {
intChan <- i
}
close(intChan)
}
func primeNum(intChan chan int, primeChan chan int, exitChan chan bool) {
for {
time.Sleep(time.Millisecond) //由于输出流的问题,不加sleep有可能导致退出提前输出,实际执行顺序是对的
num, ok := <-intChan
if !ok {
break //取不到了
}
flag := true
//判断num是否为素数
for i := 2; i < num; i++ {
if num%i == 0 {
//num不是素数
flag = false
break
}
if flag {
primeChan <- num
}
}
fmt.Println("有一个primeNum协程因为取不到数据,退出")
//向exitchan写入退出标识
exitChan <- true
}
func main() {
intChan := make(chan int, 1000)
primeChan := make(chan int, 2000) //存放结果
exitChan := make(chan bool, 4) //退出标识
//开启一个协程,向intChan放入 1-8000
go putNum(intChan)
//开启4个协程,从intChan取出数据并判断是否为素数,如果是就放入到primechan
for i := 0; i < 4; i++ {
go primeNum(intChan, primeChan, exitChan)
}
//主线程进行处理
go func() {
for i := 0; i < 4; i++ {
<-exitChan
}
//当exitchan取出4个结果时,就可以关闭primeChan
close(primeChan)
}()
//遍历结果
for {
v, ok := <-primeChan
if !ok {
break
}
fmt.Printf("素数=%d\\n", v)
}
fmt.Printf("主线程退出\\n")
}
```
- 数据类型
- 数组array
- 切片slice
- 字符串string
- map
- 结构体struct
- 方法func
- 匿名结构体(继承)
- 字段别名
- 接口interface
- 常量
- 基础语法
- 循环for
- 遍历
- 函数func
- defer
- 异常处理error
- 访问范围
- 包
- 类型断言
- 文件
- 打开文件
- 读取文件
- 写文件
- 判断是否存在
- 拷贝文件
- JSON
- 序列化
- 反序列化
- 命令行
- 杂项
- Windows下配置加速
- 相关链接
- 占位符
- 随机数rand
- 单元测试
- goroutine
- 并发和并行
- 协程和主线程
- MPG模式
- 设置CPU数量
- 全局互斥锁
- 管道
- 示例1
- 示例2
- select
- 异常捕获
- 反射
- 示例
- 示例-改变值
- 网络编程
- TCP编程
- 示例一
- redis