toolsync

func (*ConcurrentControl[T]) Add ¶

func (s *ConcurrentControl[T]) Add(param T, f func(data T))

Add 添加任务 param是传给回调函数的参数，data==param add任务个数等于Concurrent时，add函数会阻塞

func (*ConcurrentControl[T]) Close ¶

func (s *ConcurrentControl[T]) Close()

Close 关闭实例

func (*ConcurrentControl[T]) Wait ¶

func (s *ConcurrentControl[T]) Wait()

Wait 等待所有任务完成

func (*Map[K, V]) CompareAndDelete ¶

func (m *Map[K, V]) CompareAndDelete(key K, old V) (deleted bool)

CompareAndDelete 如果键的值等于旧值，则删除该项。 旧值必须是可比较的类型。 如果映射中没有键的当前值，则CompareAndDelete 返回false（即使旧值是nil接口值）。

func (*Map[K, V]) CompareAndSwap ¶

func (m *Map[K, V]) CompareAndSwap(key K, old, new V) bool

func (*Map[K, V]) Delete ¶

func (m *Map[K, V]) Delete(key K)

func (*Map[K, V]) Load ¶

func (m *Map[K, V]) Load(key K) (value V, ok bool)

func (*Map[K, V]) LoadAndDelete ¶

func (m *Map[K, V]) LoadAndDelete(key K) (value V, loaded bool)

LoadAndDelete 删除键的值，返回以前的值（如果有的话）。 加载的结果报告key是否存在。

func (*Map[K, V]) LoadOrStore ¶

func (m *Map[K, V]) LoadOrStore(key K, value V) (actual V, loaded bool)

LoadOrStore 返回key的现有值（如果存在）。 否则，它将存储并返回给定的值。 如果值已加载，则加载的结果为true，如果存储，则为false。

func (*Map[K, V]) Range ¶

func (m *Map[K, V]) Range(f func(key K, value V) bool)

func (*Map[K, V]) Store ¶

func (m *Map[K, V]) Store(key K, value V)

func (*Map[K, V]) Swap ¶

func (m *Map[K, V]) Swap(key K, value V) (previous V, loaded bool)

Swap 将值交换为键，并返回以前的值（如果有）。 loaded结果报告key是否存在。

func (*SyncLinear) Do ¶

func (s *SyncLinear) Do(f func())

Do 新开一个 goroutine 执行函数f, 并保证函数f 在同一时刻只有一个并发在执行 使用场景 如:在linux cround 每分钟中执行一个脚本，脚本执行一次需要2分钟， 此函数能保证脚本在同一时间只有一个进程在执行

func (*WaitGroup) Add ¶

func (s *WaitGroup) Add(delta int)

func (*WaitGroup) Done ¶

func (s *WaitGroup) Done()

func (*WaitGroup) Wait ¶

func (s *WaitGroup) Wait()