go开启多进程——拆分多个进程同时处理（分而治之）

　　使用了goroutine实现了多线程，使用chan来控制多线程。
runtime.GOMAXPROCS(3)来设置最大的原生线程。
runtime.Gosched() 显式地让出CPU时间给其他goroutine

代码如下：

package main

import (
    "fmt"
    "runtime"
)

var quit chan int = make(chan int)

func print10to19( split_index int) {
    fmt.Println("Start******print10to19 ")
    for i := 0; i <= split_index; i++ {
        // 显式地让出CPU时间给其他goroutine
        runtime.Gosched()
        fmt.Println("******10to19: ", i)
    }
    fmt.Println("End******print10to19 ")
    quit <- 1
}

func print20to29(split_index int ) {
    fmt.Println("Start======print20to29 ")
    for i := split_index ; i <= 43; i++ {
        // 显式地让出CPU时间给其他goroutine
        runtime.Gosched()
        fmt.Println("======20to29: ", i)
    }
    fmt.Println("End======print20to29 ")
    quit <- 2
}

func print30to39() {
    fmt.Println("Start######print30to39 ")
    for i := 30; i < 40; i++ {
        // 显式地让出CPU时间给其他goroutine
        runtime.Gosched()
        fmt.Println("######30to39: ", i)
    }
    fmt.Println("End######print30to39 ")
    quit <- 0
}

func main() {
    // 设置最大开n个原生线程
    runtime.GOMAXPROCS(3)

    fmt.Println("start ---")

    split_index := split_token() 

    go print10to19(split_index)
    go print20to29(split_index + 1)
   // go print30to39() 
   
   //  go print10to19(begin1,end1)
   //  go print20to29(begin2,end2)  
    fmt.Println("start ===")
    for i := 0; i < 2; i++ {
        sc := <-quit
        fmt.Println("sc:", sc)
    }

    fmt.Println("end")
}


 // 拆分设备组
func split_token() int{

    // redisMaster := midware.NewPRedis(config.Config.GetString("REDIS_MASTER"))
    // group_len, err := redisMaster.ZCard(str.GID)        // 获取redis组的设备总数

    // 测试：拆分成2个协程
    // split_task(2,0,group_len)
   res := split_task(2,0,43)
   return res
}


func split_task(N int, WholeBegin int, WholeEnd int) int{

res := (WholeEnd - WholeBegin) / N

switch res { 
case 0: 
fmt.Printf("0....%s",WholeEnd) 
default: 
fmt.Printf("Default012", res) 
}

return res 
}

运行程序：

　　可以看出，进程1跑的是0——21，进程2跑的是22——43，

这里拆分成2个进程。可根据自己的需求，拆分成多个进程处理。多个进程同时跑拆分一个大的group组的数据。

这种场景是：一个很大的数据表，若M个亿的数据，要是开启单进程执行的话，可能需要时间T；

但要是开启多N个进程，拆分这个M个亿的数据，相当于每个进程同时在处理M/N 的数据，分而治之的处理一个很大的数据量。