coroutine

Documentation

Index

• func Context() context.Context
• func GetContextWithCancel() (context.Context, context.CancelFunc)
• func Shutdown()
• type RollingMutex
  • func (o *RollingMutex) Date() string
  • func (o *RollingMutex) Do(f func(), today ...func() (newDate string))
  • func (o *RollingMutex) Reset()

Functions

func Context

func Context() context.Context

Context 获取全局顶层context

func GetContextWithCancel

func GetContextWithCancel() (context.Context, context.CancelFunc)

func Shutdown

func Shutdown()

Shutdown 关闭应用程序, 通知所有协程退出

Types

type RollingMutex

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

RollingMutex 按指定rolling策略加锁, 指定周期内只加载一次

滑动窗口锁, 窗口期内只初始化一次, 目前只支持1天切换

func (*RollingMutex) Date

func (o *RollingMutex) Date() string

func (*RollingMutex) Do

func (o *RollingMutex) Do(f func(), today ...func() (newDate string))

func (*RollingMutex) Reset

func (o *RollingMutex) Reset()