rp

package

v0.2.10 Latest Latest Go to latest Published: Jan 4, 2026 License: MIT Imports: 5 Imported by: 0

Details

View Source

const (
	StatStop    = 0
	StatRunning = 1
	StatPause   = 2

	ExecMajor = int8(0)
	ExecMinor = int8(1)
)

This section is empty.

This section is empty.

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

func NewRp(concurrency int) (*RoutinePool, error)

NewRp 从协程池对象池中取出一个并发数为concurrency的rp

func (p *RoutinePool) Clear()

Clear 清空任务队列

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

GetSingleResult 获取单个任务结果

func (p *RoutinePool) Pause()

Pause 暂停调度

func (p *RoutinePool) RegisterExecutor(executor func(*fuzzCtx.TaskCtx) *fuzzTypes.Reaction, which int8)

RegisterExecutor 注册任务执行函数，如果协程池是运行状态，或注册下标不为ExecMinor或ExecMajor，则退出特别注意：协程池在运行状态时是不能调用此函数的，必须先暂停

func (p *RoutinePool) ReleaseSelf()

ReleaseSelf 将自身放入池中

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(execArg *fuzzCtx.TaskCtx, whichExec int8, timeout time.Duration) bool

Submit 添加任务

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

Wait 等待协程池若干时间

func (p *RoutinePool) WaitResume()