chanUtil

Documentation

Index

• Variables
• type Chan1Sender1Receiver
  • func NewDefaultChan1Sender1Receiver(size uint) Chan1Sender1Receiver

Variables

var (
	ErrNoLongerReceive = errors.New("receiver no longer receives value from channel")
	ErrFullChan        = errors.New("channel is full")
	ErrEmptyChan       = errors.New("channel is empty")
)

Types

type Chan1Sender1Receiver

type Chan1Sender1Receiver interface {
	TrySend(val interface{}) error           // 尝试发送
	Send(val interface{})                    // 接收
	StopSend()                               // 发送方停止发送
	TryReceive() (interface{}, error)        // 尝试接收
	Receive() interface{}                    // 接收 v := <-c
	ReceiveWithBoolean() (interface{}, bool) // 接收 v, ok := <-c
	StopReceive()                            // 接收方停止接收
	Range(func(val interface{}) bool)        // for-range语法 类似于sync.Map.Range
}

func NewDefaultChan1Sender1Receiver

func NewDefaultChan1Sender1Receiver(size uint) Chan1Sender1Receiver