10-4 用select进行调度

两个generator，1个worker消耗，如果worker处理慢（worker处理sleep 5s）。则会出现有些n没有打印。

package mainimport ("fmt""time""math/rand"
)func generator() chan int {out := make(chan int)go func() {i := 0for {time.Sleep(time.Duration(rand.Intn(1500)) *time.Millisecond)out <- ii++}}()return out
}
func worker(id int, c chan int) {for n := range c {time.Sleep(5 * time.Second)fmt.Printf("Worker %d received %d\n",id, n)}
}
// <- chan
// chan <-
func createWorker(id int) chan <- int {c := make(chan int)go worker(id, c)return c
}
func main() {//var c1, c2 chan int // c1 and c2 = nilvar c1, c2 = generator(), generator()worker := createWorker(0)n := 0hasValue := falsefor {var activeWorker chan<- intif hasValue {activeWorker = worker}select {case n = <-c1://fmt.Println("Received from c1:", n)hasValue = truecase n = <-c2://fmt.Println("Received from c2", n)hasValue = truecase activeWorker <- n:hasValue = false}}
}

代码：https://github.com/NIGHTFIGHTING/go_learning/blob/master/src/channel/select/select.go

package mainimport ("fmt""time""math/rand"
)func generator() chan int {out := make(chan int)go func() {i := 0for {time.Sleep(time.Duration(rand.Intn(1500)) *time.Millisecond)out <- ii++}}()return out
}
func worker(id int, c chan int) {for n := range c {// 模拟worker处理慢情况//time.Sleep(5 * time.Second)time.Sleep(1 * time.Second)fmt.Printf("Worker %d received %d\n",id, n)}
}
// <- chan
// chan <-
func createWorker(id int) chan <- int {c := make(chan int)go worker(id, c)return c
}
func main() {//var c1, c2 chan int // c1 and c2 = nilvar c1, c2 = generator(), generator()worker := createWorker(0)var values []inttm := time.After(10 * time.Second)tick := time.Tick(time.Second)for {var activeWorker chan<- int // activeWorker is nil，下面activeWorker <- activeValue会阻塞var activeValue intif len(values) > 0 {activeWorker = workeractiveValue = values[0]}select {case n := <-c1:// 缓存数据values = append(values, n)case n := <-c2:// 缓存数据values = append(values, n)case activeWorker <- activeValue:// 数据为准备号activeWorker是nil channel,这里会不会执行values = values[1:]case <- time.After(800 * time.Millisecond):// 没有tick情况下表示，800ms内generator没有生成数据// 有tick表示，两次select处理时差是否超过800msfmt.Println("timeout")case <- tick:fmt.Println("queue len = ", len(values))case <- tm:// 这段程序运行10s退出fmt.Println("bye")return}}
}

10-4 用select进行调度相关推荐

【操作系统/OS笔记10】进程/线程的调度原则、调度算法、实时调度、多处理器调度、优先级反转
本次笔记内容: 8.1 背景 8.2 调度原则 8.3 调度算法1 8.4 调度算法2 8.5 实时调度 8.6 多处理调度与优先级反转文章目录 CPU调度背景上下文切换 CPU调度在进程/线程 ...
面向大数据与云计算调度挑战的阿里经济体核心调度系统
编者按伏羲(Fuxi)是十年前最初创立飞天平台时的三大服务之一(分布式存储 Pangu,分布式计算 MaxCompute,分布式调度 Fuxi),当时的设计初衷是为了解决大规模分布式资源的调度问题( ...
大数据千亿级离线数仓项目第五天指标统计/导出和工作流调度
千亿级数仓第05天讲义课程目标掌握常见指标PV.UV的开发统计掌握流量常见指标分类掌握指标数据导出理解工作流调度流程模块开发–数据入库创建ODS层数据表原始日志数据表 drop tab ...
mysql select语法_MySQL SELECT语法（一）SELECT语法详解
SELECT的语法如下: SELECT[ALL | DISTINCT | DISTINCTROW ] [HIGH_PRIORITY] [STRAIGHT_JOIN] [SQL_SMALL_RESULT ...
智源青年科学家梁云：异构系统中张量计算的自动调度和优化框架
与6位图灵奖得主和100多位专家共同探讨人工智能的下一个十年长按图片,内行盛会,首次免费注册北京智源大会倒计时:9天计算机体系结构领域国际顶级会议每次往往仅录用几十篇论文,录用率在20%左右 ...
mysql select in 怎么优化
2017年7月10日 22:36:54 星期一原理: 把select where in 变换成 "where = " 或者 "where between and &qu ...
mysql查询后10条数据类型_30多条mysql数据库优化方法,千万级数据库记录查询轻松解决...
1.对查询进行优化,应尽量避免全表扫描,首先应考虑在 where 及 order by 涉及的列上建立索引. 2.应尽量避免在 where 子句中对字段进行 null 值判断,否则将导致引擎放弃使用索 ...
10.11杭州Clouder lab 十分钟搭建共享应用 2：如何通过日志服务实现用户的日志收集与分析...
场景描述共享电动车企业使用函数服务搭建服务端.在函数服务中开启日志,把程序日志写到日志服务,同时在函数代码中使用SDK把运营日志写入到日志服务,使用日志服务进行日志分析. 在日志服务中,用户可以: ...
select的5中子句where，group by, havaing, order by, limit的使用顺序及实例
-- 语法: SELECT select_list FROM table_name [ WHERE search_condition ] [ GROUP BY group_by_expression ...

10-4 用select进行调度

10-4 用select进行调度相关推荐

最新文章

热门文章