## 統計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