如何停止所有等待sync.Cond的goroutine？

停止所有等待sync.Cond的goroutine可以通过以下步骤实现：

使用一个互斥锁（sync.Mutex）来保护共享资源，该共享资源将用于与sync.Cond进行条件等待和通知。
创建一个sync.Cond对象，并将其与共享资源的互斥锁关联起来。

var cond = sync.NewCond(&sync.Mutex{})

在goroutine中，调用sync.Cond的Wait方法进行条件等待。在等待之前，需要获取互斥锁，并在等待完成后释放互斥锁。

cond.L.Lock()
cond.Wait()
cond.L.Unlock()

要停止所有等待的goroutine，需要在另一个goroutine中调用sync.Cond的Broadcast或Signal方法。Broadcast方法会通知所有等待的goroutine继续执行，而Signal方法只会通知其中一个等待的goroutine继续执行。

cond.Broadcast()

完整的示例代码如下：

package main

import (
    "fmt"
    "sync"
    "time"
)

var cond = sync.NewCond(&sync.Mutex{})
var wg sync.WaitGroup

func main() {
    for i := 0; i < 5; i++ {
        wg.Add(1)
        go worker(i)
    }

    time.Sleep(time.Second * 2) // 为了确保所有goroutine都开始等待

    fmt.Println("Stopping all goroutines...")
    cond.Broadcast() // 停止所有等待的goroutine
    wg.Wait()        // 等待所有goroutine完成
    fmt.Println("All goroutines stopped.")
}

func worker(id int) {
    defer wg.Done()

    fmt.Printf("Worker %d is waiting...\n", id)

    cond.L.Lock()
    cond.Wait()
    cond.L.Unlock()

    fmt.Printf("Worker %d resumed.\n", id)
}

在上面的示例中，我们创建了5个worker goroutine，并让它们等待条件。然后，在主goroutine中调用Broadcast方法，以停止所有等待的goroutine。最后，等待所有goroutine完成，并打印出相应的信息。

这种方法可以用于任何需要停止等待的goroutine的场景，例如在某个条件满足时停止等待，或者在特定的时间点停止等待等。

关于腾讯云的相关产品，由于不能直接提及品牌商，无法给出具体的产品和链接地址，但腾讯云提供了丰富的云计算产品和服务，包括云服务器、对象存储、云数据库、人工智能服务等，可以在腾讯云官网进行详细了解和查询相关产品文档。