locking

Documentation

Index

• type Executor
  • func New(taskExecutor func(task func())) *Executor
  • func (e *Executor) Destroy()
  • func (e *Executor) ExecuteSynchronouslyWithCompleteLock(f func())
  • func (e *Executor) ExecuteSynchronouslyWithInstanceLock(id int64, f func())
  • func (e *Executor) SubmitWithCompleteLock(f func())
  • func (e *Executor) SubmitWithInstanceLock(id int64, f func())
• type Provider
  • func NewProvider() *Provider
  • func (provider *Provider) Get(key string) entity.Executor

Types

type Executor

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

func New

func New(taskExecutor func(task func())) *Executor

func (*Executor) Destroy

func (e *Executor) Destroy()

func (*Executor) ExecuteSynchronouslyWithCompleteLock

func (e *Executor) ExecuteSynchronouslyWithCompleteLock(f func())

func (*Executor) ExecuteSynchronouslyWithInstanceLock

func (e *Executor) ExecuteSynchronouslyWithInstanceLock(id int64, f func())

func (*Executor) SubmitWithCompleteLock

func (e *Executor) SubmitWithCompleteLock(f func())

func (*Executor) SubmitWithInstanceLock

func (e *Executor) SubmitWithInstanceLock(id int64, f func())

type Provider

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

func NewProvider

func NewProvider() *Provider

func (*Provider) Get

func (provider *Provider) Get(key string) entity.Executor