怎么用go实现Event事件
这篇文章主要讲解了“怎么用go实现Event事件”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“怎么用go实现Event事件”吧!
创新互联建站是一家专注于做网站、网站制作与策划设计,尼元阳网站建设哪家好?创新互联建站做网站,专注于网站建设十载,网设计领域的专业建站公司;建站业务涵盖:尼元阳等地区。尼元阳做网站价格咨询:18982081108
描述
go协程之间用通道通信,如何将它改造成事件形式。
需求描述
以下是我的需求
e := NewEvent() //协程1等待结果, 10是等待时间 e.Wait(10) //协程2发送结果 e.Send(xxxx)
原理
原理比较简单,不描述了
示例
package common import ( "go.uber.org/zap" "sync" "time" ) var NOT_USED interface{} = struct{}{} func NewEvent() *Event { e := &Event{ log: zap.S(), } e.Reset() return e } type Event struct{ waiters sync.Map log *zap.SugaredLogger } func (e *Event) Wait(timeout time.Duration) interface{}{ ticker := time.NewTicker(time.Second*timeout) defer ticker.Stop() resultChan := make(chan interface{}, 1) e.waiters.Store(resultChan, true) select{ case result := <- resultChan: if result == NOT_USED{ return nil } return result case <- ticker.C: close(resultChan) } e.waiters.Delete(resultChan) return nil } func (e *Event) Send(result interface{}){ e.waiters.Range(func(k, v interface{})bool{ resultChan := k.(chan interface{}) select{ case resultChan <- result: e.waiters.Delete(resultChan) default: e.log.Warnf("Event.Send %p resultChan=%d, result=%v", e, len(resultChan), result) } return true }) } func (e *Event) Reset(){ e.waiters.Range(func(k, v interface{})bool{ resultChan := k.(chan interface{}) resultChan <- NOT_USED e.waiters.Delete(resultChan) return true }) }
感谢各位的阅读,以上就是“怎么用go实现Event事件”的内容了,经过本文的学习后,相信大家对怎么用go实现Event事件这一问题有了更深刻的体会,具体使用情况还需要大家实践验证。这里是创新互联,小编将为大家推送更多相关知识点的文章,欢迎关注!
当前标题:怎么用go实现Event事件
文章来源:http://scyanting.com/article/gigjjj.html