concurrency

Documentation

Overview

Package concurrency contains utilities for goroutines coordination

Index

• type Executed
  • func NewExecuted() *Executed
  • func (i *Executed) Broadcast()
  • func (i *Executed) Wait()
• type MultipleExecuted
  • func (m MultipleExecuted) Wait()

Types

type Executed

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

Executed can be used to wait for something to be executed, it has a similar semantics to sync.Cond, but with a way to know whether it was already executed once and waiting only if that's not the case.

func NewExecuted

func NewExecuted() *Executed

NewExecuted creates a new Executed

func (*Executed) Broadcast

func (i *Executed) Broadcast()

Broadcast broadcasts execution to waiting goroutines

func (*Executed) Wait

func (i *Executed) Wait()

Wait waits for execution

type MultipleExecuted

type MultipleExecuted []*Executed

MultipleExecuted can be used to wrap multiple Executed conditions that should all be waited

func (MultipleExecuted) Wait

func (m MultipleExecuted) Wait()

Wait waits for the execution for all the conditions in a MultipleExecuted