threads

May 8, 2025

Changes in this version

+ type OnFinishFunc func(context.Context, ThreadReturn)

+ type Thread struct

+ func NewThread(ctx context.Context, id string, work WorkFunc, onFinish OnFinishFunc) Thread

+ func (t *Thread) Cancel()

+ func (t *Thread) Context() context.Context

+ func (t *Thread) ID() string

+ func (t *Thread) OnFinishFunc() OnFinishFunc

+ func (t *Thread) WorkFunc() WorkFunc

+ type ThreadManager struct

+ func NewThreadManager(mgrCtx context.Context, onFinish OnFinishFunc) *ThreadManager

+ func (tm *ThreadManager) IsRunning() bool

+ func (tm *ThreadManager) IsStarted() bool

+ func (tm *ThreadManager) IsStopped() bool

+ func (tm *ThreadManager) Restart(_ context.Context, tr ThreadReturn)

+ func (tm *ThreadManager) RestartOnError(ctx context.Context, tr ThreadReturn)

+ func (tm *ThreadManager) RestartOnSuccess(ctx context.Context, tr ThreadReturn)

+ func (tm *ThreadManager) Run(ctx context.Context, id string, work func(context.Context) error, ...)

+ func (tm *ThreadManager) RunThread(t Thread)

+ func (tm *ThreadManager) Start()

+ func (tm *ThreadManager) Stop()

+ type ThreadReturn struct

+ Err error

+ Thread *Thread

+ func NewThreadReturn(thread *Thread, err error) ThreadReturn

+ type WorkFunc func(context.Context) error