在Go语言中，waitio异常通常指的是在使用WaitGroup 时出现的错误。WaitGroup 是 Go 标准库sync 包中的一个结构体，用于等待一组 goroutine 完成执行，如果你遇到waitio 相关的异常报错，很可能是由于以下几种常见原因之一：

1、主函数提前退出：如果主函数比WaitGroup 中的 goroutine 更早退出，会导致未完成的 goroutine 被终止，从而引发异常。

2、Add 和Done 方法使用不当：如果在调用wg.Done() 之前没有正确调用wg.Add(n) 来增加计数，或者增加的计数与实际的 goroutine 数量不匹配，也会导致异常。

3、重复调用Add 或Done：对同一个WaitGroup 实例多次调用Add 或Done 方法，可能会导致计数错误，从而引发异常。

4、并发访问冲突：虽然WaitGroup 是线程安全的，但不正确使用可能导致竞态条件，从而引发异常。

常见问题及解决方案

问题一：主函数提前退出

现象：程序启动后立即崩溃，报错信息可能包含fatal error: all goroutines are asleep deadlock!。

原因：主函数执行结束前，WaitGroup 中的 goroutine 还没有执行完毕。

解决方案：在主函数中使用wg.Wait() 等待所有 goroutine 完成。

package main
import (
	"fmt"
	"sync"
)
func worker(id int, wg *sync.WaitGroup) {
	defer wg.Done()
	fmt.Printf("Worker %d is done
", id)
}
func main() {
	var wg sync.WaitGroup
	for i := 0; i < 5; i++ {
		wg.Add(1)
		go worker(i, &wg)
	}
	wg.Wait()
	fmt.Println("All workers are done")
}

问题二：Add 和Done 方法使用不当

现象：程序运行时报错，提示sync: negative WaitGroup counter。

原因：Add 方法的参数应为正整数，且需要与Done 方法的调用次数相匹配。

解决方案：确保Add 方法的参数为正整数，并且与Done 方法的调用次数一致。

package main
import (
	"fmt"
	"sync"
)
func worker(wg *sync.WaitGroup) {
	defer wg.Done()
	fmt.Println("Worker is done")
}
func main() {
	var wg sync.WaitGroup
	wg.Add(1) // 确保 Add 方法的参数为正整数
	go worker(&wg)
	wg.Wait()
	fmt.Println("All workers are done")
}

问题三：重复调用Add 或Done

现象：程序运行时可能会报sync: WaitGroup is reused before previous wait has finished。

原因：同一WaitGroup 实例被多次使用，而前一次的等待还未完成。

解决方案：确保每个WaitGroup 实例只用于一组特定的 goroutine，并在所有 goroutine 完成后再使用新的实例。

package main
import (
	"fmt"
	"sync"
)
func worker(wg *sync.WaitGroup) {
	defer wg.Done()
	fmt.Println("Worker is done")
}
func main() {
	var wg sync.WaitGroup
	for i := 0; i < 5; i++ {
		wg.Add(1)
		go worker(&wg)
	}
	wg.Wait()
	fmt.Println("All workers are done")
	// 重新使用新的 WaitGroup 实例
	newWG := &sync.WaitGroup{}
	newWG.Add(1)
	go worker(newWG)
	newWG.Wait()
	fmt.Println("New worker is done")
}

问题四：并发访问冲突

现象：程序运行不稳定，有时正常，有时崩溃。

原因：多个 goroutine 同时操作同一个WaitGroup 实例，导致计数错误。

解决方案：确保WaitGroup 的使用是线程安全的，避免多个 goroutine 同时操作同一个实例。

package main
import (
	"fmt"
	"sync"
)
func worker(wg *sync.WaitGroup) {
	defer wg.Done()
	fmt.Println("Worker is done")
}
func main() {
	var wg sync.WaitGroup
	for i := 0; i < 5; i++ {
		wg.Add(1)
		go worker(&wg)
	}
	wg.Wait()
	fmt.Println("All workers are done")
}

FAQs

Q1: 为什么sync.WaitGroup 会报fatal error: all goroutines are asleep deadlock!？

A1: 这个错误通常是因为主函数在WaitGroup 中的 goroutine 完成之前就退出了，解决方法是在主函数中使用wg.Wait() 等待所有 goroutine 完成。

Q2:sync: negative WaitGroup counter 是什么意思？

A2: 这个错误表示WaitGroup 的计数器变成了负数，通常是因为Add 方法的参数为负数，或者Done 方法的调用次数多于Add 方法的调用次数，解决方法是确保Add 方法的参数为正整数，并且与Done 方法的调用次数一致。