lifecycle

package

v1.2.0 Latest Latest Go to latest Published: Oct 1, 2026 License: MIT Imports: 3 Imported by: 0

Details

Package lifecycle 管理实例准入、在途操作和统一关闭。

This section is empty.

View Source

var ErrClosed = errors.New("实例已经关闭")

This section is empty.

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

func New(concurrency int) *Gate

func (g *Gate) Begin(parent context.Context) (context.Context, func(), error)

Begin 在关闭开始前登记操作。释放函数必须在资源使用结束后调用。

func (g *Gate) Close(cleanup func() error) error