并发模型,runner

打印 上一主题 下一主题

主题 547|帖子 547|积分 1641

并发模型,runner

runner

模型概述

​        runner模型做的事情就是,我们把任务丢给一个runner,然后runner去帮我们在后台跑这些任务,如果执行任务的过程超时或者收到了中断,我们就报错。
runner的定义

这里我们定义了一个结构体Runner和两种error
[code]var (        ErrTimeout   = errors.New("connot finish tasks within the timeout")   //超时error        ErrInterrupt = errors.New("received interrupt from OS")       //中断error)type Runner struct {        interrupt chan os.Signal              //存放中断信号        complete  chan error                      //放错误        timeout
回复

使用道具 举报

0 个回复

倒序浏览

快速回复

您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

络腮胡菲菲

金牌会员
这个人很懒什么都没写!

标签云

快速回复 返回顶部 返回列表