Golang |CyclicBarrier 循环栅栏 – 兰陵美酒郁金香的个人博客

package main

import (
	"context"
	"fmt"
	"time"

	"github.com/marusama/cyclicbarrier"
)

func main() {
	b := cyclicbarrier.NewWithAction(3, func() error {
		fmt.Println("放行")
		return nil
	})

	for i := 0; i < 3; i++ {
		go func(id int) {
			fmt.Printf("协程 %d 准备好了 \n", id)
			// 阻塞等待其它人
			b.Await(context.Background())
			fmt.Printf("协程 %d 通过栅栏 \n", id)
		}(i)
	}

	time.Sleep(5 * time.Second)
}

package main

import (

"context"

"fmt"

"time"

"github.com/marusama/cyclicbarrier"

)

func main() {

b := cyclicbarrier.NewWithAction(3, func() error {

fmt.Println("放行")

return nil

})

for i := 0; i < 3; i++ {

go func(id int) {

fmt.Printf("协程 %d 准备好了 \n", id)

// 阻塞等待其它人

b.Await(context.Background())

fmt.Printf("协程 %d 通过栅栏 \n", id)

}(i)

}

time.Sleep(5 * time.Second)

}

暂无

兰陵美酒郁金香

大道至简 Simplicity is the ultimate form of sophistication.

文章评论（0）

你必须登录才能发表评论