lang

Documentation

Overview

Package lang Create on 2023/6/25 @author xuzhuoxi

Package lang Created by xuzhuoxi on 2019-03-21. @author xuzhuoxi

Package lang Created by xuzhuoxi on 2019-03-23. @author xuzhuoxi

Index

• func Equal(a, b interface{}) bool
• func TypeEqual(a, b interface{}) (bool, reflect.Type)
• type Callback
  • func NewCallback(call FuncCallback, args ...interface{}) *Callback
  • func (c *Callback) Apply(args ...interface{})
  • func (c *Callback) Clear()
  • func (c *Callback) Invoke()
  • func (c *Callback) SetArgs(args ...interface{})
  • func (c *Callback) SetCall(call FuncCallback)
• type ChannelLimit
  • func (l *ChannelLimit) Add()
  • func (l *ChannelLimit) Done()
  • func (l *ChannelLimit) SetMax(max int)
  • func (l *ChannelLimit) StartLimit() bool
  • func (l *ChannelLimit) StopLimit() bool
• type ChannelLimitNone
  • func (l *ChannelLimitNone) Add()
  • func (l *ChannelLimitNone) Done()
  • func (l *ChannelLimitNone) SetMax(max int)
  • func (l *ChannelLimitNone) StartLimit() bool
  • func (l *ChannelLimitNone) StopLimit() bool
• type FuncCallback
• type IChannelLimit
• type IChannelLimitHandler
• type IChannelLimitSwitch
• type IObjectPool
  • func NewObjectPool(sync bool) IObjectPool
  • func NewObjectPoolAsync() IObjectPool
  • func NewObjectPoolSync() IObjectPool
  • func NewSizeObjectPool(size int, sync bool) IObjectPool
• type IPoolInstanceChecker
• type ISizeObjectPool
  • func NewSizeObjectPoolAsync(size int) ISizeObjectPool
  • func NewSizeObjectPoolSync(size int) ISizeObjectPool
• type LChannelLimitMaxSetter
• type PoolCheckFunc

Functions

func Equal

func Equal(a, b interface{}) bool

func TypeEqual

func TypeEqual(a, b interface{}) (bool, reflect.Type)

Types

type Callback

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

func NewCallback

func NewCallback(call FuncCallback, args ...interface{}) *Callback

func (*Callback) Apply

func (c *Callback) Apply(args ...interface{})

func (*Callback) Clear

func (c *Callback) Clear()

func (*Callback) Invoke

func (c *Callback) Invoke()

func (*Callback) SetArgs

func (c *Callback) SetArgs(args ...interface{})

func (*Callback) SetCall

func (c *Callback) SetCall(call FuncCallback)

type ChannelLimit

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

func (*ChannelLimit) Add

func (l *ChannelLimit) Add()

func (*ChannelLimit) Done

func (l *ChannelLimit) Done()

func (*ChannelLimit) SetMax

func (l *ChannelLimit) SetMax(max int)

func (*ChannelLimit) StartLimit

func (l *ChannelLimit) StartLimit() bool

func (*ChannelLimit) StopLimit

func (l *ChannelLimit) StopLimit() bool

type ChannelLimitNone

type ChannelLimitNone struct{}

func (*ChannelLimitNone) Add

func (l *ChannelLimitNone) Add()

func (*ChannelLimitNone) Done

func (l *ChannelLimitNone) Done()

func (*ChannelLimitNone) SetMax

func (l *ChannelLimitNone) SetMax(max int)

func (*ChannelLimitNone) StartLimit

func (l *ChannelLimitNone) StartLimit() bool

func (*ChannelLimitNone) StopLimit

func (l *ChannelLimitNone) StopLimit() bool

type FuncCallback

type FuncCallback = func(...interface{})

type IChannelLimit

type IChannelLimit interface {
	LChannelLimitMaxSetter
	IChannelLimitSwitch
	IChannelLimitHandler
}

type IChannelLimitHandler

type IChannelLimitHandler interface {
	Add()
	Done()
}

type IChannelLimitSwitch

type IChannelLimitSwitch interface {
	StartLimit() bool
	StopLimit() bool
}

type IObjectPool

type IObjectPool interface {
	Register(newFunc func() interface{}, check PoolCheckFunc)
	GetInstance() interface{}
	Recycle(instance interface{}) bool
}

func NewObjectPool

func NewObjectPool(sync bool) IObjectPool

func NewObjectPoolAsync

func NewObjectPoolAsync() IObjectPool

func NewObjectPoolSync

func NewObjectPoolSync() IObjectPool

func NewSizeObjectPool

func NewSizeObjectPool(size int, sync bool) IObjectPool

type IPoolInstanceChecker

type IPoolInstanceChecker interface {
	SetCheckFunc(check PoolCheckFunc)
}

type ISizeObjectPool

type ISizeObjectPool interface {
	SetMaxSize(size int)
	IObjectPool
}

func NewSizeObjectPoolAsync

func NewSizeObjectPoolAsync(size int) ISizeObjectPool

func NewSizeObjectPoolSync

func NewSizeObjectPoolSync(size int) ISizeObjectPool

type LChannelLimitMaxSetter

type LChannelLimitMaxSetter interface {
	SetMax(max int)
}

type PoolCheckFunc

type PoolCheckFunc func(instance interface{}) bool