如何使用Go的并行做更多事情

+8613426109659

webmaster@21cto.com

登录注册

如何使用Go的并行做更多事情

行动的大雄

编程语言 0 20 1天前

计算机擅长快速完成很多事情。非常多的事情，而且速度也非常快。

例如，这里有一个Go的函数，它会休眠一秒钟：

func doSomething(){    time.Sleep(time.Second)}

做很多事情

当你想做某事时，你可以这样做：

func doManyThings(n int){    for range n{            do Something()    } }  func main(){     doManyThings(10) }

但是做这件事需要多长时间呢？比如说十次？

$ time go run main.goreal    0m10.256s

果然不出所料，大约10秒……如果我们想重复一百万次怎么办？那至少需要一百万秒，也就是将近十几天才行。

等等，这是怎么回事？计算机应该很快才对啊！

快速完成许多事情

但是，我们可以通过编程让它们并发执行任务，而不是像上面那样顺序执行（一个接一个的），从而提高它们的速度。

如果你有多个 CPU（现在可以肯定都有），这些任务就会并行执行（这绝对是人类不应该尝试模拟的——想了解更多，你可以阅读约翰·哈里（Johann Hari ）的《丢失焦点（Lost Focus）》一书）！

你可以通过以下这样生成新的goroutines，来同时运行 Go 中的许多事情：

func doManyThings(n int){  var wgsync.WaitGroup// create concurrency-safe counter  for range n{wg.Add(1)// increment counter by one    gofunc(){// launch function on new goroutine and continuedefer     wg.Done()// decrement counter on return from function     do Something()  }()}wg.Wait()// wait till counter is 0 (all functions are done)}func main(){do ManyThings(1e6)}

那么，现在需要多长时间才能完成一百万次只执行一秒钟的事情呢？它在我的笔记本电脑上，不到三秒钟：

$ time go run main.goreal    0m2.667s

看到了没，这可比原来的十二天快多了！

做很多事情，快速产生输出

在执行某件事时，我们经常希望看到一些输出。至少，我们想知道任务是否顺利完成：

// Now doSomething returns an error value. It's nil when all is good.func doSomething()error{    time.Sleep(time.Second)    if rand.Intn(100)==0{// circa one percent of tasks will fail        return errors.New("we got a problem")    }    return nil}

那么，我们如何获取在 goroutine 上并发执行的任务的输出呢？为此可以使用Channels：

func doManyThings(n int)[]error{    ch:=make(chanerror,n)// create channel of errors that can hold n items        for range n{    gofunc(){           ch<-doSomething()// send function's output to channel}()}var errs[]error for range n{    err:=<-ch// receive value from channel and assign it to err        if err!=nil{            errs=append(errs,err)        }}return errs}func main(){    n:=1_000_000    errs:=doManyThings(n)    fmt.Printf("Doing %d things there where %d errors.\n",n,len(errs))}