golang协程池模拟实现群发邮件功能

package pool

import "log"
//具体任务,可以传参可以自定义操作
type task struct {
    args interface{}
    do func(interface{})error
}
//协程的个数
var nums int
//任务通道
var jobchannels =make(chan task)
//入口的任务通道
var jobs =make(chan task)
//执行
func run(){
    for i:=0;i<nums;i++{
        go worker(i)
    }
    for task:=range jobs{
        jobchannels<-task
    }
    close(jobchannels)
}
//实际的工作协程worker
func worker(workid int){
    for task:=range jobchannels{
        ret:=task.do(task.args)
        log.printf("worker_id:%d , worker_ret:%v\n",workid,ret)
    }
}

package test
import (
    "errors"
    "gofly/pool"
    "log"
    "testing"
    "time"
)
//真正的模拟发送邮件
func sendemail(email interface{})error{
    log.println(email," start..")
    //模拟耗时
    time.sleep(time.second*10)
    return errors.new(email.(string)+" end..")
}
//获取邮箱并发送
func getemails(){
    //如果数据量比较大分页获取
    page:=1;
    for{
        //模拟每页获取的邮箱
        emails:=[]string{
            "1@qq.com",
            "2@qq.com",
            "3@qq.com",
            "4@qq.com",
            "5@qq.com",
            "6@qq.com",
            "7@qq.com",
        }
        for _,email:=range emails{
            var sendemailtask=pool.task{
                args: email,
                do: sendemail,
            }
            //每个邮箱任务塞入任务通道
            pool.jobs <- sendemailtask
        }
        log.printf("page %d done!\n",page)
        page++
    }
}
func testpool(t *testing.t) {
    //定义5个协程
    pool.nums = 5
    //开个子协程去不停的获取邮箱
    go getemails()
    //执行
    pool.run()
}