util

func (*SyncMap) Check ¶

func (m *SyncMap) Check(k interface{}) bool

Returns true if k is exist in the map.

func (*SyncMap) Clean ¶

func (m *SyncMap) Clean()

func (*SyncMap) Delete ¶

func (m *SyncMap) Delete(k interface{})

func (*SyncMap) Get ¶

func (m *SyncMap) Get(k interface{}) interface{}

Get from maps return the k's value

func (*SyncMap) GetMap ¶

func (m *SyncMap) GetMap() map[interface{}]interface{}

func (*SyncMap) Lock ¶

func (m *SyncMap) Lock()

func (*SyncMap) Set ¶

func (m *SyncMap) Set(k interface{}, v interface{}) bool

Maps the given key and value. Returns false if the key is already in the map and changes nothing.

func (*SyncMap) Unlock ¶

func (m *SyncMap) Unlock()

func (*SyncQueue) Close ¶

func (q *SyncQueue) Close()

Close SyncQueue

After close, Pop will return nil without block, and TryPop will return v=nil, ok=True

func (*SyncQueue) Len ¶

func (q *SyncQueue) Len() (l int)

Get the length of SyncQueue

func (*SyncQueue) Pop ¶

func (q *SyncQueue) Pop() (v interface{})

Pop an item from SyncQueue, will block if SyncQueue is empty

func (*SyncQueue) PopAll ¶

func (q *SyncQueue) PopAll() (v []interface{})

PopAll all items from SyncQueue, will block if SyncQueue is empty

func (*SyncQueue) Push ¶

func (q *SyncQueue) Push(v interface{})

Push an item to SyncQueue. Always returns immediately without blocking

func (*SyncQueue) TryPop ¶

func (q *SyncQueue) TryPop() (v interface{}, ok bool)

Try to pop an item from SyncQueue, will return immediately with bool=false if SyncQueue is empty

func (*SyncQueue) TryPopAll ¶

func (q *SyncQueue) TryPopAll() (v []interface{}, ok bool)

Try to pop all items from SyncQueue, will return immediately with bool=false if SyncQueue is empty

func (*WorkerPool) Run ¶

func (p *WorkerPool) Run(w Work)

func (*WorkerPool) Shutdown ¶

func (p *WorkerPool) Shutdown()