duanmo6937 2017-01-28 15:04
浏览 21

如何发出所有正在等待的go例程的信号?

The problem I have is to "signal all go routines that are waiting". Some go routines may be performing other tasks (simulated by time.Sleep in code below), before waiting for the signal. Others go routines may wait for the signal immediately after starting. In some case there may not be any go routines that are waiting (not simulated in the code below)

I came with the following approach:

package main

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

func main() {

    wg := sync.WaitGroup{}
    wg.Add(3)
    cond := sync.NewCond(&sync.Mutex{})
    signalled := false

    producer := func() {
        time.Sleep(1)
        cond.L.Lock()
        signalled = true
        cond.Broadcast()
        cond.L.Unlock()
        wg.Done()
    }
    go producer()

    go func() {
        time.Sleep(3 * time.Second)
        cond.L.Lock()
        for !signalled {
            cond.Wait()
        }
        cond.L.Unlock()
        wg.Done()
    }()

    go func() {
        cond.L.Lock()
        for !signalled {
            cond.Wait()
        }
        cond.L.Unlock()
        wg.Done()
    }()

    wg.Wait()
    fmt.Println("done once")

    reset := func() {
        cond.L.Lock()
        signalled = false
        cond.L.Unlock()
    }
    // a reset function
    reset()

    wg.Add(2)
    go producer()
    go func() {
        cond.L.Lock()
        for !signalled {
            cond.Wait()
        }
        cond.L.Unlock()
        wg.Done()
    }()
    wg.Wait()
    fmt.Println("done twice")
}

https://play.golang.org/p/uNmyofH2hs

I can use a channel and close the channel as a signal. But this means that in case there is a need for "reset" (where in the "signal" can be triggered again), the channel would have to be created again.

Is there a better (concise) way to achieve this?

  • 写回答

0条回答 默认 最新

    报告相同问题?

    悬赏问题

    • ¥20 基于MSP430f5529的MPU6050驱动,求出欧拉角
    • ¥20 Java-Oj-桌布的计算
    • ¥15 powerbuilder中的datawindow数据整合到新的DataWindow
    • ¥20 有人知道这种图怎么画吗?
    • ¥15 pyqt6如何引用qrc文件加载里面的的资源
    • ¥15 安卓JNI项目使用lua上的问题
    • ¥20 RL+GNN解决人员排班问题时梯度消失
    • ¥60 要数控稳压电源测试数据
    • ¥15 能帮我写下这个编程吗
    • ¥15 ikuai客户端l2tp协议链接报终止15信号和无法将p.p.p6转换为我的l2tp线路