utils

Documentation

Index

• func FileExist(filename string) bool
• type AsyncTask
  • func NewAsyncTask(handler interface{}, params ...interface{}) *AsyncTask
  • func (p *AsyncTask) Do() []reflect.Value
• type AsyncTaskPool
  • func NewAsyncTaskPool(threads int, taskChanSize int) *AsyncTaskPool
  • func (p *AsyncTaskPool) Close(waitTaskDone bool, waitThreadStop bool)
  • func (p *AsyncTaskPool) Do(handler interface{}, params ...interface{})
• type MapWithRWMutex
  • func NewMapWithRWMutex() *MapWithRWMutex
  • func (p *MapWithRWMutex) Add(key interface{}, value interface{}) (err error)
  • func (p *MapWithRWMutex) Clear()
  • func (p *MapWithRWMutex) Get(key interface{}) (value interface{}, ok bool)
  • func (p *MapWithRWMutex) Has(key interface{}) bool
  • func (p *MapWithRWMutex) IsEmpty() bool
  • func (p *MapWithRWMutex) Items() (keys []interface{}, values []interface{})
  • func (p *MapWithRWMutex) Keys() (keys []interface{})
  • func (p *MapWithRWMutex) Len() int
  • func (p *MapWithRWMutex) PopOne() (value interface{}, ok bool)
  • func (p *MapWithRWMutex) Remove(key interface{}) (err error)
  • func (p *MapWithRWMutex) Set(key interface{}, value interface{})
  • func (p *MapWithRWMutex) Values() (values []interface{})
• type Set
  • func New() *Set
  • func (p *Set) Add(item interface{})
  • func (p *Set) Clear()
  • func (p *Set) Has(item interface{}) bool
  • func (p *Set) IsEmpty() bool
  • func (p *Set) Len() int
  • func (p *Set) List() []interface{}
  • func (p *Set) PopOne() (item interface{}, ok bool)
  • func (p *Set) Remove(item interface{})

Functions

func FileExist

func FileExist(filename string) bool

Types

type AsyncTask

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

func NewAsyncTask

func NewAsyncTask(handler interface{}, params ...interface{}) *AsyncTask

func (*AsyncTask) Do

func (p *AsyncTask) Do() []reflect.Value

吃掉异步任务异常

type AsyncTaskPool

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

func NewAsyncTaskPool

func NewAsyncTaskPool(threads int, taskChanSize int) *AsyncTaskPool

func (*AsyncTaskPool) Close

func (p *AsyncTaskPool) Close(waitTaskDone bool, waitThreadStop bool)

func (*AsyncTaskPool) Do

func (p *AsyncTaskPool) Do(handler interface{}, params ...interface{})

注意，添加的异步任务不能抛异常

type MapWithRWMutex

type MapWithRWMutex struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewMapWithRWMutex

func NewMapWithRWMutex() *MapWithRWMutex

func (*MapWithRWMutex) Add

func (p *MapWithRWMutex) Add(key interface{}, value interface{}) (err error)

如果key已存在，就不会设置

func (*MapWithRWMutex) Clear

func (p *MapWithRWMutex) Clear()

func (*MapWithRWMutex) Get

func (p *MapWithRWMutex) Get(key interface{}) (value interface{}, ok bool)

func (*MapWithRWMutex) Has

func (p *MapWithRWMutex) Has(key interface{}) bool

func (*MapWithRWMutex) IsEmpty

func (p *MapWithRWMutex) IsEmpty() bool

func (*MapWithRWMutex) Items

func (p *MapWithRWMutex) Items() (keys []interface{}, values []interface{})

func (*MapWithRWMutex) Keys

func (p *MapWithRWMutex) Keys() (keys []interface{})

func (*MapWithRWMutex) Len

func (p *MapWithRWMutex) Len() int

func (*MapWithRWMutex) PopOne

func (p *MapWithRWMutex) PopOne() (value interface{}, ok bool)

func (*MapWithRWMutex) Remove

func (p *MapWithRWMutex) Remove(key interface{}) (err error)

func (*MapWithRWMutex) Set

func (p *MapWithRWMutex) Set(key interface{}, value interface{})

key不存在就新增，key存在就覆盖

func (*MapWithRWMutex) Values

func (p *MapWithRWMutex) Values() (values []interface{})

type Set

type Set struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func New

func New() *Set

func (*Set) Add

func (p *Set) Add(item interface{})

func (*Set) Clear

func (p *Set) Clear()

func (*Set) Has

func (p *Set) Has(item interface{}) bool

func (*Set) IsEmpty

func (p *Set) IsEmpty() bool

func (*Set) Len

func (p *Set) Len() int

func (*Set) List

func (p *Set) List() []interface{}

func (*Set) PopOne

func (p *Set) PopOne() (item interface{}, ok bool)

func (*Set) Remove

func (p *Set) Remove(item interface{})