thread

package

v1.2.2 Latest Latest Go to latest Published: Mar 30, 2023 License: Apache-2.0 Imports: 5 Imported by: 0

Details

* @Author: cnzf1 * @Date: 2021-12-15 14:18:20 * @LastEditors: cnzf1 * @LastEditTime: 2022-12-02 22:07:45 * @Description:

* @Author: cnzf1 * @Date: 2021-12-15 14:18:20 * @LastEditors: cnzf1 * @LastEditTime: 2022-08-27 16:06:04 * @Description:

* @Author: cnzf1 * @Date: 2021-12-15 14:18:20 * @LastEditors: cnzf1 * @LastEditTime: 2022-12-02 23:23:22 * @Description:

* @Author: cnzf1 * @Date: 2021-12-15 14:18:20 * @LastEditors: cnzf1 * @LastEditTime: 2022-08-30 11:34:24 * @Description:

This section is empty.

This section is empty.

func GoSafe(fn func())

func Recover(cleanups ...func()) (err error)

func RunSafe(fn func())

func RunSafeEx(fn func(), err *error)

var err error

RunSafeEx(func(){...}, &err)

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

func NewRoutineGroup() *RoutineGroup

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

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

func (g *RoutineGroup) Wait()

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

A TaskRunner is used to control the concurrency of goroutines.

func NewTaskRunner(concurrency int) *TaskRunner

NewTaskRunner returns a TaskRunner.

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

Schedule schedules a task to run under concurrency control.

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

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

func (wg WorkerGroup) Start()