sync

Documentation

Index

• Variables
• type Map
  • func NewMap[K comparable, V any](items ...lo.Tuple2[K, V]) *Map[K, V]
  • func (p *Map[K, V]) Delete(key K)
  • func (p *Map[K, V]) Load(key K) (V, bool)
  • func (p *Map[K, V]) LoadAndDelete(key K) (V, bool)
  • func (p *Map[K, V]) LoadOrCreate(key K, create func() V) (V, bool)
  • func (p *Map[K, V]) LoadOrStore(key K, value V) (V, bool)
  • func (p *Map[K, V]) Range(call func(key K, value V) bool)
  • func (p *Map[K, V]) Store(key K, value V)
• type RoutineGroup
  • func NewRoutineGroup(group int32) *RoutineGroup
  • func (p *RoutineGroup) Done()
  • func (p *RoutineGroup) Incr()
  • func (p *RoutineGroup) Wait()

Examples

• NewMap
• NewRoutineGroup
• RoutineGroup.Incr

Variables

var ErrGroupLessZero = errors.New("group less than 0")

Types

type Map

type Map[K comparable, V any] struct{ sync.Map }

func NewMap

func NewMap[K comparable, V any](items ...lo.Tuple2[K, V]) *Map[K, V]

Example

package main

import (
	"fmt"

	"github.com/xuender/kit/sync"
)

func main() {
	smap := sync.NewMap[int, int]()

	smap.Store(1, 1)
	fmt.Println(smap.Load(1))
	fmt.Println(smap.LoadOrCreate(2, func() int { return 2 }))

}

Output:

1 true
2 false

func (*Map[K, V]) Delete

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

func (*Map[K, V]) Load

func (p *Map[K, V]) Load(key K) (V, bool)

func (*Map[K, V]) LoadAndDelete

func (p *Map[K, V]) LoadAndDelete(key K) (V, bool)

func (*Map[K, V]) LoadOrCreate

func (p *Map[K, V]) LoadOrCreate(key K, create func() V) (V, bool)

func (*Map[K, V]) LoadOrStore

func (p *Map[K, V]) LoadOrStore(key K, value V) (V, bool)

func (*Map[K, V]) Range

func (p *Map[K, V]) Range(call func(key K, value V) bool)

func (*Map[K, V]) Store

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

type RoutineGroup

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

RoutineGroup 协程组，是sync.WaitGroup的增强版本.

func NewRoutineGroup

func NewRoutineGroup(group int32) *RoutineGroup

NewRoutineGroup 协程组，控制协程总数量.

Example

package main

import (
	"fmt"

	"github.com/xuender/kit/sync"
)

func main() {
	group := sync.NewRoutineGroup(3)
	for i := 0; i < 5; i++ {
		group.Incr()

		go func() {
			defer group.Done()

			fmt.Println("x")
		}()
	}

	group.Wait()

}

Output:

x
x
x
x
x

func (*RoutineGroup) Done

func (p *RoutineGroup) Done()

Done 协程完成.

func (*RoutineGroup) Incr

func (p *RoutineGroup) Incr()

Incr 加1.

Example

package main

import (
	"fmt"

	"github.com/xuender/kit/sync"
)

func main() {
	group := sync.NewRoutineGroup(3)
	for i := 0; i < 5; i++ {
		group.Incr()

		go func() {
			defer group.Done()

			fmt.Println("x")
		}()
	}

	group.Wait()

}

Output:

x
x
x
x
x

func (*RoutineGroup) Wait

func (p *RoutineGroup) Wait()

Wait 等待全部完成.