go 使用管道

1. 管道声明

type Job51 struct {
    KeyWord        string
    OriginUrlModel string
    OriginUrl      string
    OriginContent  string
    PageNum        int
// 声明一个类型为 string 的双向管道
    EachPageUrls   chan string
}

2. 初始化管道
   注意管道是有容量的，如果管道不声明容量，则默认为1，即存入一个数据就会阻塞，直到管道内的数据消费后才能继续塞入数据

func (j *Job51) setEachPageUrls(){
// 初始化管道，声明管道的容量
    j.EachPageUrls = make(chan string, j.PageNum)
    for num := 1; num <= j.PageNum; num++{
        url := fmt.Sprintf(j.OriginUrlModel, j.KeyWord, strconv.Itoa(num))
        j.EachPageUrls <- url
        log.Println("[setEachPageUrls]",url," is appended chan")
                if j.EachPageUrls == j.PageNum{
                  // 数据发送完毕后需要关闭管道，否则就会hang住
                  defer close(j.EachPageUrls)
          }
    }
}