task

Documentation

Index

• type SyncTask
  • func NewSyncTask(mode, count int, ...) *SyncTask
  • func (c *SyncTask) AddTask(task any, isSnyc bool) bool
  • func (c *SyncTask) GetTaskRes() (res any, resArr []any, err error)

Types

type SyncTask

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

SyncTask 同步任务对象

func NewSyncTask

func NewSyncTask(mode, count int, evalFunc func(taskarr []any) (res any, resArr []any, err error)) *SyncTask

NewSyncTask 创建一个同步任务对象，本对象请创建为全局变量，请勿在循环中创建，否则会内存溢出 传参：

mode：触发模式：0=计时、1=计次，本参数指达到条件后执行任务的时机
count：计时模式下表示秒数，计次模式下表示次数
evalFunc：达到条件后欲执行的函数，taskarr为AddTask函数中传入的task参数

返回：

返回同步任务对象

func (*SyncTask) AddTask

func (c *SyncTask) AddTask(task any, isSnyc bool) bool

AddTask 添加任务 传参：

task：需要传递给最终处理任务函数的参数，最终调用EvalFunc函数会以数组形式将参数传递
isSnyc：是否阻塞，如果正在运行EvalFunc函数，则会一直等到运行结束后在添加任务

func (*SyncTask) GetTaskRes

func (c *SyncTask) GetTaskRes() (res any, resArr []any, err error)

GetTaskRes 获取结果，建议循环获取 返回值：

res：单个结果
resArr：数组结果
err：错误信息