Golang中goroutines使用遇到的问题

Golang中goroutines使用遇到的问题 大家好， 我是新手，仍在学习Go语言。 我有一个用于下载多个git仓库的脚本。为了加速这个过程，我使用了goroutine。我创建了另一个简短的脚本来模拟我的问题。

以下脚本在等待每个goroutine中的随机时间的同时创建多个文件夹和子文件夹。

package main

import (
	"fmt"
	"math/rand"
	"os"
	"strconv"
	"sync"
	"time"
)

const (
	xthreads    = 5  // 要使用的线程总数，不包括 main() 线程
	folderCount = 50 // 需要创建的最大文件夹数
)

func doSomething1(a int) {
	fmt.Println("doSomething1:", a)

	if err := os.Mkdir("testDir"+strconv.Itoa(a), 0755); err != nil {
		fmt.Println(err)
	}
}

func doSomething2(a int) {
	fmt.Println("doSomething2:", a)

	if err := os.Chdir("testDir" + strconv.Itoa(a)); err != nil {
		fmt.Println(err)
	}

	if err := os.Mkdir("anotherDir", 0755); err != nil {
		fmt.Println(err)
	}

	if err := os.Chdir(".."); err != nil {
		fmt.Println(err)
	}
}

func main() {
	var ch = make(chan int)
	var wg sync.WaitGroup
	var dir string
	var err error

	if dir, err = os.MkdirTemp(os.TempDir(), "test-"); err != nil {
		fmt.Println(err)
	}
	if err = os.Chdir(dir); err != nil {
		fmt.Println(err)
	}

	// 这启动了 xthreads 个 goroutine，等待执行任务
	wg.Add(xthreads)
	for i := 0; i < xthreads; i++ {
		go func() {
			for {
				a, ok := <-ch
				if !ok { // 如果无事可做且通道已关闭，则结束 goroutine
					wg.Done()
					return
				}

				doSomething1(a)
				doSomething2(a)
				rand.Seed(time.Now().UnixNano())
				randomSleep := time.Duration(rand.Intn(10))
				time.Sleep(randomSleep * time.Second)
				fmt.Printf("Sleep for %d second...\n", randomSleep)
			}
		}()
	}

	// 现在可以将任务添加到通道中，该通道用作队列
	for i := 0; i < folderCount; i++ {
		ch <- i // 将 i 添加到队列
	}

	close(ch) // 这告诉 goroutines 没有其他事情可做
	wg.Wait() // 等待线程完成
}

我想要实现的目标是：

1. 例如，同一时间只应执行5个goroutine xthreads
2. 当其中一个完成后，另一个必须启动，这样我就可以一直有5个goroutine同时运行，直到达到 folderCount 值
3. 文件夹结构应如下所示：

/tmp/test-2325124430
├── testDir0
│   └── anotherDir
├── testDir1
│   └── anotherDir
├── testDir2
│   └── anotherDir
├── testDir3
│   └── anotherDir
└── testDir4
    └── anotherDir
...................
...................
└── testDir50
    └── anotherDir

等等…

但问题是，当我启动脚本时，它创建的文件夹如下：

/tmp/test-2325124430
├── anotherDir
├── testDir0
│   └── anotherDir
├── testDir1
├── testDir2
│   └── anotherDir
├── testDir3
│   └── anotherDir
└── testDir4
    └── anotherDir
...................
/tmp
├── testDir16
├── anotherDir
│   └── testDir17
...................
/
├── testDir18
├── testDir19
│   └── testDir20
...................

控制台输出是：

go run -race test.go
doSomething1: 3
doSomething1: 1
doSomething2: 3
doSomething2: 1
doSomething1: 4
doSomething1: 0
doSomething2: 0
doSomething1: 2
doSomething2: 2
doSomething2: 4
chdir testDir1: no such file or directory
Sleep for 1 second...
doSomething1: 5
doSomething2: 5
Sleep for 0 second...
doSomething1: 6
doSomething2: 6
Sleep for 4 second...
doSomething1: 7
doSomething2: 7
Sleep for 5 second...
doSomething1: 8
doSomething2: 8
Sleep for 7 second...
doSomething1: 9
doSomething2: 9
Sleep for 3 second...
doSomething1: 10
doSomething2: 10
Sleep for 1 second...
doSomething1: 11
doSomething2: 11
Sleep for 9 second...
doSomething1: 12
doSomething2: 12
Sleep for 9 second...
doSomething1: 13
doSomething2: 13
Sleep for 9 second...
doSomething1: 14
doSomething2: 14
Sleep for 7 second...
doSomething1: 15
doSomething2: 15
Sleep for 7 second...
doSomething1: 16
Sleep for 6 second...
doSomething2: 16
doSomething1: 17
doSomething2: 17
chdir testDir17: no such file or directory
Sleep for 8 second...
doSomething1: 18
doSomething2: 18
Sleep for 6 second...
doSomething1: 19
doSomething2: 19
Sleep for 6 second...
Sleep for 7 second...
Sleep for 6 second...
Sleep for 7 second...
Sleep for 8 second...