解决Go语言开发中的并发异步问题的方法

func worker(id int, jobs <-chan int, results chan<- int) {
    for j := range jobs {
        // 处理任务
        results <- j*2
    }
}

func main() {
    numJobs := 10
    jobs := make(chan int, numJobs)
    results := make(chan int, numJobs)

    // 启动多个goroutine来处理任务
    for w := 1; w <= 3; w++ {
        go worker(w, jobs, results)
    }

    // 发送任务到通道中
    for j := 1; j <= numJobs; j++ {
        jobs <- j
    }
    close(jobs)

    // 获取处理结果
    for a := 1; a <= numJobs; a++ {
        <-results
    }
}

func worker(id int, wg *sync.WaitGroup) {
    defer wg.Done()

    // 执行任务
}

func main() {
    var wg sync.WaitGroup

    numWorkers := 10
    wg.Add(numWorkers)

    // 启动多个goroutine来处理任务
    for w := 1; w <= numWorkers; w++ {
        go worker(w, &wg)
    }

    // 等待所有goroutine执行完毕
    wg.Wait()
}

func main() {
    c1 := make(chan int)
    c2 := make(chan string)

    go func() {
        time.Sleep(time.Second)
        c1 <- 1
    }()
    go func() {
        time.Sleep(time.Second)
        c2 <- "hello"
    }()

    // 使用select同时等待多个通道的消息
    for i := 0; i < 2; i++ {
        select {
        case <-c1:
            fmt.Println("Received message from c1")
        case <-c2:
            fmt.Println("Received message from c2")
        }
    }
}