threading

Mar 2, 2024

Changes in this version

+ var ErrRunnerClosed = errors.New("runner closed")

+ var ErrTaskRunnerBusy = errors.New("task runner is busy")

+ type StableRunner struct

+ func NewStableRunner[I, O any](fn func(I) O) *StableRunner[I, O]

+ func (r *StableRunner[I, O]) Get() (O, error)

+ func (r *StableRunner[I, O]) Push(v I) error

+ func (r *StableRunner[I, O]) Wait()

type TaskRunner

+ func (rp *TaskRunner) ScheduleImmediately(task func()) error

+ func (rp *TaskRunner) Wait()

Jun 1, 2023

Changes in this version

+ func GoSafeCtx(ctx context.Context, fn func())

+ func RunSafeCtx(ctx context.Context, fn func())

Dec 14, 2022 GO-2024-2604

  GO-2024-2604: CORS Filter bypass in github.com/zeromicro/go-zero

Oct 22, 2022 GO-2024-2604

  GO-2024-2604: CORS Filter bypass in github.com/zeromicro/go-zero

Sep 17, 2022 GO-2024-2604

  GO-2024-2604: CORS Filter bypass in github.com/zeromicro/go-zero

Aug 7, 2022 GO-2024-2604

  GO-2024-2604: CORS Filter bypass in github.com/zeromicro/go-zero

Jul 9, 2022 GO-2024-2604

  GO-2024-2604: CORS Filter bypass in github.com/zeromicro/go-zero

Jun 3, 2022 GO-2024-2604

  GO-2024-2604: CORS Filter bypass in github.com/zeromicro/go-zero

Apr 28, 2022 GO-2024-2604

  GO-2024-2604: CORS Filter bypass in github.com/zeromicro/go-zero

Apr 3, 2022 GO-2024-2604

  GO-2024-2604: CORS Filter bypass in github.com/zeromicro/go-zero

Mar 1, 2022 GO-2024-2604

  GO-2024-2604: CORS Filter bypass in github.com/zeromicro/go-zero

Feb 1, 2022 GO-2024-2604

  GO-2024-2604: CORS Filter bypass in github.com/zeromicro/go-zero

Changes in this version

+ func GoSafe(fn func())

+ func RoutineId() uint64

+ func RunSafe(fn func())

+ type RoutineGroup struct

+ func NewRoutineGroup() *RoutineGroup

+ func (g *RoutineGroup) Run(fn func())

+ func (g *RoutineGroup) RunSafe(fn func())

+ func (g *RoutineGroup) Wait()

+ type TaskRunner struct

+ func NewTaskRunner(concurrency int) *TaskRunner

+ func (rp *TaskRunner) Schedule(task func())

+ type WorkerGroup struct

+ func NewWorkerGroup(job func(), workers int) WorkerGroup

+ func (wg WorkerGroup) Start()

Jan 25, 2022 GO-2024-2604

  GO-2024-2604: CORS Filter bypass in github.com/zeromicro/go-zero

Jan 5, 2022 GO-2024-2604

  GO-2024-2604: CORS Filter bypass in github.com/zeromicro/go-zero