Golang Classic Mistakes

var batchGroups [][]*FileInfo = BatchGroup(fileInfos, batchSize)
group := new(errgroup.Group)
for batchId, batchFiles := range batchGroups {
    // 这里进入 go 协程并发执行 
    group.Go(func() error {
        ...
        // 这里直接读取 for 循环中的变量 batchFiles
        for _, file := range batchFiles {
            if !file.IsDir() && file.Size() > 0 {
                ...
                // 将文件同步写入到另一个地方
                syncFileToAnothorPlace(file)
                ...
            }
        }
        ...
    })
}
// for 循环执行完后，预期是同步 100 个文件，结果只同步成功了部分文件，而且出现了文件写锁冲突异常
if err := group.Wait(); err != nil {
    return err
}

import (
	"sync"
	"testing"
)

func TestCommon(t *testing.T) {
	elems := []string{"A", "B", "C"}
	wg := sync.WaitGroup{}
	wg.Add(len(elems) * 2)
	
	// 循环输出，期待输出 A, B, C
	for i, e := range elems {
		// 闭包
		tmp := e
		t.Logf("Common - i_%v: %v, e_%v:, %v, tmp_%v: %v", i, &i, e, &e, tmp, &tmp)
		go func() {
		    // 闭包 = 函数 + 环境(引用函数外的相关变量..)
			t.Logf("GoClosure - i_%v: %v, e_%v:, %v, tmp_%v: %v", i, &i, e, &e, tmp, &tmp)
			wg.Done()
		}()
		
		// 形参
		go func(param string) {
			// Parameter 是形参，在函数定义时放在小括号里，占位使用
			// Argument 是实参，在函数调用时放在小括号里
			// 其实，形参的原本英文是 Formal Parameter, 实参的原本英文是 Actual Argument
			t.Logf("GoParam - i_%v: %v, e_%v:, %v, param_%v: %v", i, &i, e, &e, param, &param)
			wg.Done()
		}(e)
	}
	
	wg.Wait()
}

type Person struct {
	Name string
}

func TestCommonPtr(t *testing.T) {
	a := &Person{Name: "A"}
	t.Logf("Person_A - arg_loc(实参地址): %p, var_loc(变量地址): %p", a, &a)
	b := &Person{Name: "B"}
	t.Logf("Person_B - arg_loc(实参地址): %p, var_loc(变量地址): %p", b, &b)
	c := &Person{Name: "C"}
	t.Logf("Person_C - arg_loc(实参地址): %p, var_loc(变量地址): %p", c, &c)

	elems := []*Person{a, b, c}
	wg := sync.WaitGroup{}
	wg.Add(len(elems))
	for i, e := range elems {
		// 形参
		go func(param *Person) {
			// Parameter 是形参，在函数定义时放在小括号里，占位使用
			// Argument 是实参，在函数调用时放在小括号里
			// 其实，形参的原本英文是 Formal Parameter, 实参的原本英文是 Actual Argument
			t.Logf("GoParam - i_%v: %v, e_%v: %v, value: %v arg_loc(实参地址): %p, param_loc(形参地址): %v", i, &i, e, &e, param, param, &param)
			wg.Done()
		}(e)
	}
	wg.Wait()
}

var batchGroups [][]*FileInfo = BatchGroup(fileInfos, batchSize)
group := new(errgroup.Group)
for batchId, batchFiles := range batchGroups {
    // fix GO loop variable captured by go func literal
    tmpBatchFiles := batchFiles
    group.Go(func() error {
        ...
        // 这里改为读取临时变量 tmpBatchFiles
        for _, file := range tmpBatchFiles {
            if !file.IsDir() && file.Size() > 0 {
                ...
                // 将文件同步写入到另一个地方
                syncFileToAnothorPlace(file)
                ...
            }
        }
        ...
    })
}
if err := group.Wait(); err != nil {
    return err
}