哈希字符串的有限并行性[重复]

Question

尝试解决从文件中读取电话号码的问题（逐行）并在 go 中并发散列（md5），最大并发进程数为 100，创建固定数量的 goroutine。尝试使用 go pipeline 和有界并行，但没有奏效。请问有什么指导吗？

这是我试过的，https://play.golang.org/p/vp7s512l8w4

Answer 1

package main

import (
    "bufio"
    "fmt"
    "os"
    "sync"
)

func hashPhoneNumers(phoneNO string, ch chan struct{}, group *sync.WaitGroup) {
    do_hash(phoneNO)
    <-ch
    group.Done()
}

func do_hash(s string) {
    fmt.Println("do hash: ", s)
}

func main() {
    c := make(chan struct{}, 100)
    file, err := os.Open("file.txt")
    if err != nil {
        fmt.Println(err)
        os.Exit(-1)
    }
    defer file.Close()
    line := bufio.NewScanner(file)

    wg := sync.WaitGroup{}
    for line.Scan() {
        // with a maximum of 100 concurrent process maximum
        c <- struct{}{}
        wg.Add(1)
        go hashPhoneNumers(line.Text(), c, &wg)
    }

    // wait all goroutines done
    wg.Wait()
    close(c)
}

这很好用