刚刚写了个包，觉得值得出来分享下：

文档: 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)

项目主页：http://www.open-open.com/lib/view/home/1421056418875