在主程序启动的时候开一个goroutine作为消费者,用管道连接生产者和消费者,消费者处于无限循环,从管道中获取channel传过来定时event
注意:channel在消费者创建的时候就连通生产者和消费者
结构图大体如上
消费者代码:
消费者处于无限循环,在循环中拿到Eventchan传过来的数据,再通过select调度chan,进行业务操作
生产者代码如下:
生产者创建一个定时器,在定时器完成之后把要传的数据放入Eventchan,消费者从Eventchan中获取数据进行业务操作
备注:消费者要一直循环,且创建的管道需要加缓冲