如何優雅地終止 Go 中的 Goroutine 並處理錯誤？

Idiomatic Goroutine Termination and Error Handling

In the realm of Go concurrency, handling the termination of goroutines and errors seamlessly is crucial. Consider a simple use case where we aim to retrieve data from multiple remote servers concurrently, returning the first encountered error.

Leaking Goroutines

An initial attempt may involve leaking goroutines, as highlighted in the following code snippet:

func fetchAll() error {
  wg := sync.WaitGroup{}
  errs := make(chan error)
  leaks := make(map[int]struct{})
  //...
}

To address this issue, we can either employ context or utilize the errgroup package:

Error Group Solution

The errgroup package offers a convenient way to manage goroutine termination and errors. It automatically awaits the completion of all provided goroutines, or cancels remaining ones in case of any error.

func fetchAll(ctx context.Context) error {
  errs, ctx := errgroup.WithContext(ctx)
  //...
  return errs.Wait()
}

This code elegantly handles goroutine termination and returns the first error encountered.

以上是如何優雅地終止 Go 中的 Goroutine 並處理錯誤？的詳細內容。更多資訊請關注PHP中文網其他相關文章！