带有 channel 的循环中的 goroutine

Question

已结束。此问题是 not reproducible or was caused by typos .它目前不接受答案。

---

此问题是由拼写错误或无法再重现的问题引起的。虽然类似的问题可能是 on-topic在这里，这个问题的解决方式不太可能帮助 future 的读者。

关闭 4 年前。

Improve this question

注意:GetTaskQueue() 返回一个全局变量，其结构为

type TaskQueue struct {
    ch   chan int
    wg   *sync.WaitGroup
}

channel用于限制goroutine的数量，goroutine的最大数量设置为3。

我的期望是所有 ts 都应该匹配 tasks。但是，Dominium 和 dApp Builder 没有显示在 t 中，而 EthicHub Twitter 和 Apollo重复。

输出如下所示。

Answer 1

正如上一个答案中提到的，任务循环变量的地址始终相同。所以这应该适合你:

for _, task := range tasks {
        t := task
        fmt.Println("task ", t.Name)
        time.Sleep(2 * time.Second)
        go func(t *DB.TaskLog) {
            defer GetTaskQueue().Done()
            fmt.Println("task ", t.Name)
            CrawlAirdrop(t.Link)
        }(&t)

        select {
        case <-ctx.Done():
            return
        default:
        }
}