routine

package

v0.0.0-...-ac69a99 Latest Latest Go to latest Published: Feb 22, 2026 License: AGPL-3.0 Imports: 9 Imported by: 4

Details

This section is empty.

This section is empty.

func AddAfterRoutine(f AfterRoutine)

func AddBeforeRoutine(f BeforeRoutine)

func Go(f func() (err error))

func GoWithMustSuccess(f func() (err error))

func GoWithRecover(f func() (err error))

type AfterRoutine func(currentGid int64)

type BeforeRoutine func(baseGid, currentGid int64)

type Cache[K cmp.Ordered, V any] struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Cache 协程的信息缓存

func NewCache[K cmp.Ordered, V any]() *Cache[K, V]

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

func (p *Cache[K, V]) Get(key K) (V, bool)

func (p *Cache[K, V]) GetWithDef(key K, def ...V) V

func (p *Cache[K, V]) Set(key K, value V)

func (p *Cache[K, V]) SetEx(key K, value V, ex time.Duration)

type Group struct {
}