Go实现CountDownLatch

go语言用的不熟,没找到对应Java的CountDownLatch,就自己写一个......试了试好像能用(后面发现waitGroup就能实现)

ps:拿go造轮子真的快乐啊

package main

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

type DownLatch struct {
    wg sync.WaitGroup
}

func instance(count int) DownLatch {
    latch := DownLatch{}
    latch.wg.Add(count)
    return latch
}

func (latch *DownLatch) Down() {
    latch.wg.Done()
}

func (latch *DownLatch) Wait() {
    latch.wg.Wait()
}

func (latch *DownLatch) WaitTime(t time.Duration) {
    waitCh := make(chan struct{})
    go func() {
        latch.wg.Wait()
        close(waitCh)
    }()
    select {
    case <-waitCh:
        return
    case <-time.After(t):
        return
    }
}

func main() {
    latch := instance(3)
    go func() {
        for i := 0; i < 3; i++ {
            time.Sleep(1 * time.Second)
            go func() {
                latch.Down()
                fmt.Println("count down")
            }()
        }
    }()

    latch.WaitTime(4 * time.Second)
    fmt.Println("keep going")

    time.Sleep(3 * time.Second)
    fmt.Println("end")
}

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

友情链接更多精彩内容