Fanout - 更容易的写并发代码

atong · · 3875 次点击 · 开始浏览    置顶
这是一个创建于 的主题,其中的信息可能已经有所发展或是发生改变。

不用管理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.word, outr.domain, outr.summary) } if err != nil { fmt.Println("Error: ", err) } return outr, nil }, inputs) fmt.Println("Finished ", len(results), ", Error:", err2) 一图来说明。 ![image](http://sunfmin.com/images/sunfmin_fanout.png)

有疑问加站长微信联系(非本文作者)

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

3875 次点击  
加入收藏 微博
3 回复  |  直到 2015-01-11 08:49:01
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传