coroutines

Documentation

Index

• func InjectCoRoutines(s *CoRoutines)
• func InjectCoRunner(s *CoRunner)
• func LoadCoRoutines() baseiface.ISingleton
• func LoadCoRunner() baseiface.ISingleton
• type CoRoutines
  • func FindBeanCoRoutines() *CoRoutines
  • func NewCoRoutines() *CoRoutines
  • func (self *CoRoutines) Execute(iface iface.CoRunnerIface) *basedto.IchubResult
  • func (self *CoRoutines) Merge(resultList *arraylist.List) *basedto.IchubResult
• type CoRunner
  • func FindBeanCoRunner() *CoRunner
  • func NewCoRunner() *CoRunner
  • func (g *CoRunner) Execute(data *dto.CoData) *basedto.IchubResult
  • func (g *CoRunner) GetData() *dto.CoData

Functions

func InjectCoRoutines

func InjectCoRoutines(s *CoRoutines)

func InjectCoRunner

func InjectCoRunner(s *CoRunner)

func LoadCoRoutines

func LoadCoRoutines() baseiface.ISingleton

func LoadCoRunner

func LoadCoRunner() baseiface.ISingleton

Types

type CoRoutines

type CoRoutines struct {
	basedto.BaseEntitySingle
}

func FindBeanCoRoutines

func FindBeanCoRoutines() *CoRoutines

func NewCoRoutines

func NewCoRoutines() *CoRoutines

func (*CoRoutines) Execute

func (self *CoRoutines) Execute(iface iface.CoRunnerIface) *basedto.IchubResult

func (*CoRoutines) Merge

func (self *CoRoutines) Merge(resultList *arraylist.List) *basedto.IchubResult

type CoRunner

type CoRunner struct {
	basedto.BaseEntity // BaseEntity 提供基础实体属性和方法。
	*dto.CoData        `di:"auto"`
	iface.CoRunnerIface
}

CoRunner 是一个负责并发执行任务的协程运行器 它继承了基于DTO的基础实体和协程运行器接口， 用于简化并发任务的管理和执行。

func FindBeanCoRunner

func FindBeanCoRunner() *CoRunner

func NewCoRunner

func NewCoRunner() *CoRunner

NewCoRunner 创建并返回一个新的CoRunner实例。 这是获取CoRunner实例的推荐方式。

func (*CoRunner) Execute

func (g *CoRunner) Execute(data *dto.CoData) *basedto.IchubResult

func (*CoRunner) GetData

func (g *CoRunner) GetData() *dto.CoData