面试题答案
一键面试package main
import (
"fmt"
"sync"
"time"
)
func task(id int, semaphore chan struct{}, wg *sync.WaitGroup) {
defer wg.Done()
semaphore <- struct{}{} // 获取信号量
defer func() { <-semaphore }() // 释放信号量
fmt.Printf("Task %d is running\n", id)
time.Sleep(time.Second)
fmt.Printf("Task %d is done\n", id)
}
func main() {
var wg sync.WaitGroup
semaphore := make(chan struct{}, 5) // 初始化信号量,最多允许5个协程同时执行
for i := 1; i <= 10; i++ {
wg.Add(1)
go task(i, semaphore, &wg)
}
wg.Wait()
}