sys

package

v0.0.51 Latest Latest Go to latest Published: Sep 2, 2025 License: Apache-2.0 Imports: 11 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/acexy/golang-toolkit

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func DetectCPULimit() int
func EnableLocalTraceId(supplier Supplier[string])
func GetGoroutineId() uint64
func GetLocalTraceId() string
func IsEnabledLocalTraceId() bool
func SetGoMaxProc(limit int)
func SetGoMaxProcType(limit CPULimitType)
func SetLocalTraceId(traceId string)
func ShutdownCallback(f func(), sig ...os.Signal)
func ShutdownCallbackDeadline(f func(), deadline time.Duration, sig ...os.Signal)
func ShutdownHolding(sig ...os.Signal)
func ShutdownSignal(sig ...os.Signal) <-chan struct{}
type CPULimitType
type Local
- func NewThreadLocal[T any](supplier ...Supplier[T]) *Local[T]
type Supplier

Constants ¶

View Source

const (
	LimitHalf  = -1 // 使用一半核心数，最小1，向下取整
	LimitMax   = -2 // 全部
	Limit1Left = -3 // 保留一个核心 最小1
)

Variables ¶

This section is empty.

Functions ¶

func DetectCPULimit ¶ added in v0.0.46

func DetectCPULimit() int

DetectCPULimit 检测操作系统/容器可运行CPU核数

func EnableLocalTraceId ¶ added in v0.0.36

func EnableLocalTraceId(supplier Supplier[string])

EnableLocalTraceId 激活TraceIdLocal处理器如果不指定supplier则使用默认策略 uuid

func GetGoroutineId ¶ added in v0.0.36

func GetGoroutineId() uint64

GetGoroutineId 获取当前协程id

func GetLocalTraceId ¶ added in v0.0.36

func GetLocalTraceId() string

GetLocalTraceId 获取当前线程的TraceId

func IsEnabledLocalTraceId ¶ added in v0.0.36

func IsEnabledLocalTraceId() bool

IsEnabledLocalTraceId 判断是否启用了TraceIdLocal处理器

func SetGoMaxProc ¶ added in v0.0.46

func SetGoMaxProc(limit int)

SetGoMaxProc 设置GOMAXPROCS

func SetGoMaxProcType ¶ added in v0.0.46

func SetGoMaxProcType(limit CPULimitType)

SetGoMaxProcType 设置GOMAXPROCS

func SetLocalTraceId ¶ added in v0.0.49

func SetLocalTraceId(traceId string)

SetLocalTraceId 设置当前线程的TraceId

func ShutdownCallback ¶

func ShutdownCallback(f func(), sig ...os.Signal)

ShutdownCallback 监听指定的信号，若不传递则使用默认信号方法会一直阻塞直到触发所监听的信号为止，并执行回调

func ShutdownCallbackDeadline ¶

func ShutdownCallbackDeadline(f func(), deadline time.Duration, sig ...os.Signal)

ShutdownCallbackDeadline 监听指定的信号，若不传递则使用默认信号方法会一直阻塞直到触发所监听的信号为止并执行回调若在指定时间未完成回调执行，则放弃等待

func ShutdownHolding ¶

func ShutdownHolding(sig ...os.Signal)

ShutdownHolding 监听指定的信号，若不传递则使用默认信号方法会一直阻塞直到触发所监听的信号为止

func ShutdownSignal ¶ added in v0.0.50

func ShutdownSignal(sig ...os.Signal) <-chan struct{}

ShutdownSignal 监听指定的信号，若不传递则使用默认信号方法会一直阻塞直到触发所监听的信号为止，并返回一个通道 ** 如果使用 for select ，强烈建议不要在使用 case: <-ShutdownSignal() 特别是高频循环中，这样会一直创建新的简单信号管道应当定义一个全局的通道变了sig := ShutdownSignal()，然后使用 case: <-sig

Types ¶

type CPULimitType ¶ added in v0.0.46

type CPULimitType int

type Local ¶ added in v0.0.36

type Local[T any] struct {
	// contains filtered or unexported fields
}

Local ThreadLocalStorage 线程本地存储

func NewThreadLocal ¶ added in v0.0.36

func NewThreadLocal[T any](supplier ...Supplier[T]) *Local[T]

NewThreadLocal 创建线程本地存储

func (*Local[T]) Delete ¶ added in v0.0.36

func (l *Local[T]) Delete()

Delete 删除值

func (*Local[T]) Get ¶ added in v0.0.36

func (l *Local[T]) Get() T

Get 获取值

func (*Local[T]) Set ¶ added in v0.0.36

func (l *Local[T]) Set(value T)

Set 设置值

type Supplier ¶ added in v0.0.36

type Supplier[T any] func() T

Supplier 创建初始化值的提供者

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL