rp

package

v0.1.2 Latest Latest Go to latest Published: Aug 27, 2025 License: MIT Imports: 3 Imported by: 0

Details

View Source

const (
	StatStop    = 0
	StatRunning = 1
	StatPause   = 2
)

This section is empty.

This section is empty.

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

var CurrentRp *RoutinePool

func New(concurrency int) *RoutinePool

New 创建一个新的协程池

func (p *RoutinePool) Clear()

Clear 清空任务队列

func (p *RoutinePool) GetSingleResult() *fuzzTypes.Reaction

GetSingleResult 获取单个任务结果

func (p *RoutinePool) Pause()

Pause 暂停调度

func (p *RoutinePool) Resize(size int)

func (p *RoutinePool) Resume()

Resume 恢复调度

func (p *RoutinePool) Start()

Start 启动所有 worker

func (p *RoutinePool) Status() int8

func (p *RoutinePool) Stop()

Stop 关闭管道，停止所有 worker

func (p *RoutinePool) Submit(task Task, timeout time.Duration) bool

Submit 添加任务

func (p *RoutinePool) Wait(maxTime time.Duration) bool

Wait 等待协程池若干时间

type Task func() *fuzzTypes.Reaction