Fanout - 更容易得写并发代码

前端之家收集整理的这篇文章主要介绍了Fanout - 更容易得写并发代码前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。

不用管理 grouting 和 channel 了。 以下为转发 golangtc.com 原文:


刚刚写了个包,觉得值得出来分享下:

文档: https://github.com/sunfmin/fanout

用来简化并发程序(goroutine,channel)的编写,这个包直接改写自Go Concurrency Patterns: Pipelines博客的最后一个样例程序。

平时写带goroutine和channel的程序,总是时不时的爆"fatal error: all goroutines are asleep - deadlock!",检查起来又很难找原因。

例子程序 - 用60个goroutine一起跑whois来查看域名是不是还在:

inputs := []interface{}{}


for _,word:= range domainWords {
    inputs = append(inputs,word)
}

results,err2 := fanout.ParallelRun(60,func(input interface{})
(interface{},error) {
    word := input.(string)
    if strings.TrimSpace(word) == "" {
        return nil,nil
    }

    py := pinyin.Convert(word)
    pydowncase := strings.ToLower(py)
    domain := pydowncase + ".com"
    outr,err := domainAvailable(word,domain)

    if outr.available {
        fmt.Printf("[Ohh Yeah] %s %s\n",outr.word,outr.domain)
    } else {
        fmt.Printf("\t\t\t %s %s %s\n",outr.domain,outr.summary)
    }

    if err != nil {
        fmt.Println("Error: ",err)
    }

    return outr,nil
},inputs)

fmt.Println("Finished ",len(results),",Error:",err2)

一图来说明:

原文链接:https://www.f2er.com/go/190609.html

猜你在找的Go相关文章