cyclicbarrierx

Documentation

Index

• type Group
  • func NewGroup(parties int, barrierAction func()) *Group
  • func (cb *Group) Wait()
  • func (cb *Group) WaitContext(ctx context.Context) error

Types

type Group

type Group struct {
	// contains filtered or unexported fields
}

Group 实现了一个可重用的屏障，等待一组线程到达指定点后一起继续执行。 当所有等待的线程都到达屏障时，会执行一个指定的屏障动作。

func NewGroup

func NewGroup(parties int, barrierAction func()) *Group

NewGroup 创建并返回一个新的 CyclicBarrier 实例。 参数 parties 指定需要到达屏障的线程数量。 参数 barrierAction 是一个函数，当所有线程都到达屏障时会被执行。

func (*Group) Wait

func (cb *Group) Wait()

Wait 方法用于表示一个线程到达了屏障。 线程调用此方法后，会等待直到所有线程都到达屏障，然后一起继续执行。

func (*Group) WaitContext

func (cb *Group) WaitContext(ctx context.Context) error

WaitContext 方法与 Wait 类似，但支持通过 context 上下文取消等待。 如果上下文被取消，方法会返回相应的错误；否则，它会等待直到所有线程到达屏障。