免费注册 查看新帖 |

Chinaunix

  平台 论坛 博客 文库
最近访问板块 发新帖
楼主: yulihua49

[其他] 事件响应方式 [复制链接]

论坛徽章:
15
射手座
日期:2014-11-29 19:22:4915-16赛季CBA联赛之青岛
日期:2017-11-17 13:20:09黑曼巴
日期:2017-07-13 19:13:4715-16赛季CBA联赛之四川
日期:2017-02-07 21:08:572015年亚冠纪念徽章
日期:2015-11-06 12:31:58每日论坛发贴之星
日期:2015-08-04 06:20:00程序设计版块每日发帖之星
日期:2015-08-04 06:20:00程序设计版块每日发帖之星
日期:2015-07-12 22:20:002015亚冠之浦和红钻
日期:2015-07-08 10:10:132015亚冠之大阪钢巴
日期:2015-06-29 11:21:122015亚冠之广州恒大
日期:2015-05-22 21:55:412015年亚洲杯之伊朗
日期:2015-04-10 16:28:25
发表于 2016-08-18 12:09 |显示全部楼层
本帖最后由 yulihua49 于 2016-08-18 12:29 编辑
cokeboL 发表于 2016-08-18 11:38
go c2sCor()
go s2cCor()
这两句就是启动两个协程,然后

启动两个协程,而不是线程?那么没有并行功能,无法充分利用多核。
我希望看到多线程协程,能够并行,也能把任务在多个线程间切换。要看看你是怎么管理协程与线程的关系。

少线程服务器  --- 其实还是多线程服务器,就是线程数不多,大约=核数。要充分利用所有的线程,一旦发生等待就yield,放弃这个任务赶紧接别的任务。

我那个例子只是应用侧代码,很简单,而且是同步异步自适应的。就是:同步框架可以调用它,异步框架也可以调用它,只是需要事先提供yield函数即可。

多线程与多协程的关系在于yield函数内的代码,作为C,当然是非常的庞杂,但是完全可以实现上述需求。

你是每个连接产生3个协程?如果10000个连接来了,就是30000个协程?30000个棧?每个棧就算1M,所需内存?
在C里也是这个问题,我用棧池来解决,就是栈数=线程数,激活的协程才拥有棧。

论坛徽章:
36
子鼠
日期:2013-08-28 22:23:29黄金圣斗士
日期:2015-12-01 11:37:51程序设计版块每日发帖之星
日期:2015-12-14 06:20:00CU十四周年纪念徽章
日期:2015-12-22 16:50:40IT运维版块每日发帖之星
日期:2016-01-25 06:20:0015-16赛季CBA联赛之深圳
日期:2016-01-27 10:31:172016猴年福章徽章
日期:2016-02-18 15:30:3415-16赛季CBA联赛之福建
日期:2016-04-07 11:25:2215-16赛季CBA联赛之青岛
日期:2016-04-29 18:02:5915-16赛季CBA联赛之北控
日期:2016-06-20 17:38:50技术图书徽章
日期:2016-07-19 13:54:03程序设计版块每日发帖之星
日期:2016-08-21 06:20:00
发表于 2016-08-18 12:21 |显示全部楼层
yulihua49 发表于 2016-08-18 12:09
启动两个协程,而不是线程?那么没有并行功能,无法充分利用多核。
我希望看到多线程协程,能够并行,也 ...


golang的协程,是应用层调度,1.4还是哪个版本之前,golang启动默认只用单核,
可以手动设置使用的核心数量,现在比较高版本的golang,启动默认使用硬件核数的
线程数做底层,当然依旧可以手动设置核心数

golang和erlang的协程/进程(erlang把协程叫做进程)调度算法性能都不错,协程
本身也很轻量级,非常棒

论坛徽章:
36
子鼠
日期:2013-08-28 22:23:29黄金圣斗士
日期:2015-12-01 11:37:51程序设计版块每日发帖之星
日期:2015-12-14 06:20:00CU十四周年纪念徽章
日期:2015-12-22 16:50:40IT运维版块每日发帖之星
日期:2016-01-25 06:20:0015-16赛季CBA联赛之深圳
日期:2016-01-27 10:31:172016猴年福章徽章
日期:2016-02-18 15:30:3415-16赛季CBA联赛之福建
日期:2016-04-07 11:25:2215-16赛季CBA联赛之青岛
日期:2016-04-29 18:02:5915-16赛季CBA联赛之北控
日期:2016-06-20 17:38:50技术图书徽章
日期:2016-07-19 13:54:03程序设计版块每日发帖之星
日期:2016-08-21 06:20:00
发表于 2016-08-18 12:23 |显示全部楼层
所以golang的协程,是多核的,并发的

而且轻量,golang开上万个协程跟玩似的

论坛徽章:
36
子鼠
日期:2013-08-28 22:23:29黄金圣斗士
日期:2015-12-01 11:37:51程序设计版块每日发帖之星
日期:2015-12-14 06:20:00CU十四周年纪念徽章
日期:2015-12-22 16:50:40IT运维版块每日发帖之星
日期:2016-01-25 06:20:0015-16赛季CBA联赛之深圳
日期:2016-01-27 10:31:172016猴年福章徽章
日期:2016-02-18 15:30:3415-16赛季CBA联赛之福建
日期:2016-04-07 11:25:2215-16赛季CBA联赛之青岛
日期:2016-04-29 18:02:5915-16赛季CBA联赛之北控
日期:2016-06-20 17:38:50技术图书徽章
日期:2016-07-19 13:54:03程序设计版块每日发帖之星
日期:2016-08-21 06:20:00
发表于 2016-08-18 12:30 |显示全部楼层
Golang调度器源码分析
http://www.tuicool.com/articles/JBnMVn3

论坛徽章:
15
射手座
日期:2014-11-29 19:22:4915-16赛季CBA联赛之青岛
日期:2017-11-17 13:20:09黑曼巴
日期:2017-07-13 19:13:4715-16赛季CBA联赛之四川
日期:2017-02-07 21:08:572015年亚冠纪念徽章
日期:2015-11-06 12:31:58每日论坛发贴之星
日期:2015-08-04 06:20:00程序设计版块每日发帖之星
日期:2015-08-04 06:20:00程序设计版块每日发帖之星
日期:2015-07-12 22:20:002015亚冠之浦和红钻
日期:2015-07-08 10:10:132015亚冠之大阪钢巴
日期:2015-06-29 11:21:122015亚冠之广州恒大
日期:2015-05-22 21:55:412015年亚洲杯之伊朗
日期:2015-04-10 16:28:25
发表于 2016-08-18 15:06 |显示全部楼层
本帖最后由 yulihua49 于 2016-08-18 15:16 编辑
cokeboL 发表于 2016-08-18 12:21
golang的协程,是应用层调度,1.4还是哪个版本之前,golang启动默认只用单核,
可以手动设置使用的核心 ...

主要是不了解。不知道里边的资源,事件如何管理的。如,几万协程,棧空间怎么管?不象erlang,根本就没有局部变量,也不需要多少棧(好像它根本就是共用棧的,进程没有私有棧)。

论坛徽章:
36
子鼠
日期:2013-08-28 22:23:29黄金圣斗士
日期:2015-12-01 11:37:51程序设计版块每日发帖之星
日期:2015-12-14 06:20:00CU十四周年纪念徽章
日期:2015-12-22 16:50:40IT运维版块每日发帖之星
日期:2016-01-25 06:20:0015-16赛季CBA联赛之深圳
日期:2016-01-27 10:31:172016猴年福章徽章
日期:2016-02-18 15:30:3415-16赛季CBA联赛之福建
日期:2016-04-07 11:25:2215-16赛季CBA联赛之青岛
日期:2016-04-29 18:02:5915-16赛季CBA联赛之北控
日期:2016-06-20 17:38:50技术图书徽章
日期:2016-07-19 13:54:03程序设计版块每日发帖之星
日期:2016-08-21 06:20:00
发表于 2016-08-18 15:52 |显示全部楼层
回复 24# yulihua49


golang协程的栈,好像是不够用的时候语言底层自动扩展,也不需要自己操心

事件,怎么说呢,比如lua里我有这样写:
  1. local eventCenter = {}
  2. eventCenter.events = {}


  3. function eventCenter:new(name, event, cb)
  4.         if self.events[name] then
  5.                 assert(false, "eventCenter", "eventCenter:new Error: eventCenter addListener, listener already exists!")
  6.                 return
  7.         end
  8.         print("eventCenter:new: ", name, event, cb)
  9.         self.events[name] = {event=event, cb=cb}
  10. end


  11. function eventCenter:delete(name)
  12.         self.events[name] = nil
  13. end

  14. function eventCenter:dispatch(event, ...)
  15.         print("eventCenter dispatch: ", event, ...)
  16.         for _, v in pairs(self.events) do
  17.                 if event == v.event then
  18.                         print("eventCenter dispatch222: ", event, ...)
  19.                         v.cb(event, ...)
  20.                 end
  21.         end
  22. end

  23. return eventCenter
复制代码
因为lua单线程的,不需要锁,其他语言比如golang,new、delete、dispatch的时候上锁就好了
也就算个观察者模式或者发布-订阅吧

跨进程,就用socket,几个new、delete、dispatch,几个消息号和key data就是了

golang进程内的我也写了个,不过是刚接触golang的时候写的,写完没整理代码

  1. import (
  2.         //"fmt"
  3.         "sync"
  4. )

  5. type EventMgr struct {
  6.         listenerMap map[interface{}]interface{}
  7.         listeners   map[interface{}]map[interface{}]EventHandler
  8.         mutex       *sync.Mutex
  9.         valid       bool
  10. }

  11. var (
  12.         defaultInstance *EventMgr = nil
  13.         instanceMap     map[interface{}]*EventMgr
  14.         instanceMutex   = &sync.Mutex{}
  15. )

  16. func eventHandler(handler EventHandler, event interface{}, args []interface{}) {
  17.         defer PanicHandle(true)
  18.         handler(event, args)
  19. }

  20. func (eventMgr *EventMgr) NewListener(tag interface{}, event interface{}, handler EventHandler) bool {
  21.         eventMgr.mutex.Lock()
  22.         defer eventMgr.mutex.Unlock()

  23.         if _, ok := eventMgr.listenerMap[tag]; ok {
  24.                 LogError(LOG_IDX, LOG_IDX, "NewListener Error: listener %v exist!", tag)
  25.                 return false
  26.         }

  27.         eventMgr.listenerMap[tag] = event
  28.         if eventMgr.listeners[event] == nil {
  29.                 eventMgr.listeners[event] = make(map[interface{}]EventHandler)
  30.         }
  31.         eventMgr.listeners[event][tag] = handler

  32.         return true
  33. }

  34. func (eventMgr *EventMgr) DeleteListener(tag interface{}) {
  35.         eventMgr.mutex.Lock()
  36.         defer eventMgr.mutex.Unlock()

  37.         if event, ok := eventMgr.listenerMap[tag]; ok {
  38.                 delete(eventMgr.listenerMap, tag)
  39.                 delete(eventMgr.listeners[event], tag)
  40.         }
  41. }

  42. func (eventMgr *EventMgr) Dispatch(event interface{}, args ...interface{}) {
  43.         eventMgr.mutex.Lock()
  44.         defer eventMgr.mutex.Unlock()

  45.         if listeners, ok := eventMgr.listeners[event]; ok {
  46.                 for _, listener := range listeners {
  47.                         eventHandler(listener, event, args)
  48.                 }
  49.         }
  50. }

  51. func GetInstance() *EventMgr {
  52.         if defaultInstance == nil {
  53.                 defaultInstance = &EventMgr{
  54.                         listenerMap: make(map[interface{}]interface{}),
  55.                         listeners:   make(map[interface{}]map[interface{}]EventHandler),
  56.                         mutex:       &sync.Mutex{},
  57.                         valid:       true,
  58.                 }
  59.         }
  60.         return defaultInstance
  61. }

  62. func NewEventMgr(tag interface{}) *EventMgr {
  63.         instanceMutex.Lock()
  64.         defer instanceMutex.Unlock()

  65.         if _, ok := instanceMap[tag]; ok {
  66.                 LogError(LOG_IDX, LOG_IDX, "NewEventMgr Error: EventMgr %v exist!", tag)
  67.                 return nil
  68.         }

  69.         eventMgr := &EventMgr{
  70.                 listenerMap: make(map[interface{}]interface{}),
  71.                 listeners:   make(map[interface{}]map[interface{}]EventHandler),
  72.                 mutex:       &sync.Mutex{},
  73.                 valid:       true,
  74.         }

  75.         if instanceMap == nil {
  76.                 instanceMap = make(map[interface{}]*EventMgr)
  77.         }
  78.         instanceMap[tag] = eventMgr

  79.         return eventMgr
  80. }

  81. func DeleteEventMgr(tag interface{}) {
  82.         instanceMutex.Lock()
  83.         defer instanceMutex.Unlock()

  84.         if eventMgr, ok := instanceMap[tag]; ok {
  85.                 eventMgr.mutex.Lock()
  86.                 defer eventMgr.mutex.Unlock()

  87.                 for k, e := range eventMgr.listenerMap {
  88.                         if emap, ok := eventMgr.listeners[e]; ok {
  89.                                 for kk, _ := range emap {
  90.                                         delete(emap, kk)
  91.                                 }
  92.                         }
  93.                         delete(eventMgr.listeners, k)
  94.                 }
  95.                 delete(instanceMap, tag)
  96.         }
  97. }

  98. func GetEventMgrByTag(tag interface{}) (*EventMgr, bool) {
  99.         instanceMutex.Lock()
  100.         defer instanceMutex.Unlock()

  101.         if eventMgr, ok := instanceMap[tag]; ok {
  102.                 return eventMgr, true
  103.         }
  104.         return nil, false
  105. }
复制代码

论坛徽章:
36
子鼠
日期:2013-08-28 22:23:29黄金圣斗士
日期:2015-12-01 11:37:51程序设计版块每日发帖之星
日期:2015-12-14 06:20:00CU十四周年纪念徽章
日期:2015-12-22 16:50:40IT运维版块每日发帖之星
日期:2016-01-25 06:20:0015-16赛季CBA联赛之深圳
日期:2016-01-27 10:31:172016猴年福章徽章
日期:2016-02-18 15:30:3415-16赛季CBA联赛之福建
日期:2016-04-07 11:25:2215-16赛季CBA联赛之青岛
日期:2016-04-29 18:02:5915-16赛季CBA联赛之北控
日期:2016-06-20 17:38:50技术图书徽章
日期:2016-07-19 13:54:03程序设计版块每日发帖之星
日期:2016-08-21 06:20:00
发表于 2016-08-18 15:54 |显示全部楼层
golang还有chan,相当于pipe,或者那个eventfd吧,锁和chan多数场景是可以替换的

论坛徽章:
36
子鼠
日期:2013-08-28 22:23:29黄金圣斗士
日期:2015-12-01 11:37:51程序设计版块每日发帖之星
日期:2015-12-14 06:20:00CU十四周年纪念徽章
日期:2015-12-22 16:50:40IT运维版块每日发帖之星
日期:2016-01-25 06:20:0015-16赛季CBA联赛之深圳
日期:2016-01-27 10:31:172016猴年福章徽章
日期:2016-02-18 15:30:3415-16赛季CBA联赛之福建
日期:2016-04-07 11:25:2215-16赛季CBA联赛之青岛
日期:2016-04-29 18:02:5915-16赛季CBA联赛之北控
日期:2016-06-20 17:38:50技术图书徽章
日期:2016-07-19 13:54:03程序设计版块每日发帖之星
日期:2016-08-21 06:20:00
发表于 2016-08-18 15:58 |显示全部楼层
本帖最后由 cokeboL 于 2016-08-18 15:59 编辑

因为golang这种,真正做到了多路并发,各路可以顺序编程,不过rpc或者不同模块间,也避免不了需要异步的场景

erlang的进程,太虐心了,进程间通信竟然只能用消息,互不可见,所以当初erlang研究到这个特性的时候,就没有
继续了,erlang这种适合web的场景,用户之间没什么交互,每个连接一个进程,妥妥的。
但是并不适合其他一些交互较多的场景,比如游戏内向全服在线玩家广播,虽然说给所有玩家进程发个msg,每个进程
再发网络包没什么问题,但总感觉比遍历所有连接并send 麻烦,或者一些其他交互的地方,erlang也是鸡肋

论坛徽章:
15
射手座
日期:2014-11-29 19:22:4915-16赛季CBA联赛之青岛
日期:2017-11-17 13:20:09黑曼巴
日期:2017-07-13 19:13:4715-16赛季CBA联赛之四川
日期:2017-02-07 21:08:572015年亚冠纪念徽章
日期:2015-11-06 12:31:58每日论坛发贴之星
日期:2015-08-04 06:20:00程序设计版块每日发帖之星
日期:2015-08-04 06:20:00程序设计版块每日发帖之星
日期:2015-07-12 22:20:002015亚冠之浦和红钻
日期:2015-07-08 10:10:132015亚冠之大阪钢巴
日期:2015-06-29 11:21:122015亚冠之广州恒大
日期:2015-05-22 21:55:412015年亚洲杯之伊朗
日期:2015-04-10 16:28:25
发表于 2016-08-18 16:52 |显示全部楼层
嗯。学习一下。要出差了,回来再细看。

论坛徽章:
36
子鼠
日期:2013-08-28 22:23:29黄金圣斗士
日期:2015-12-01 11:37:51程序设计版块每日发帖之星
日期:2015-12-14 06:20:00CU十四周年纪念徽章
日期:2015-12-22 16:50:40IT运维版块每日发帖之星
日期:2016-01-25 06:20:0015-16赛季CBA联赛之深圳
日期:2016-01-27 10:31:172016猴年福章徽章
日期:2016-02-18 15:30:3415-16赛季CBA联赛之福建
日期:2016-04-07 11:25:2215-16赛季CBA联赛之青岛
日期:2016-04-29 18:02:5915-16赛季CBA联赛之北控
日期:2016-06-20 17:38:50技术图书徽章
日期:2016-07-19 13:54:03程序设计版块每日发帖之星
日期:2016-08-21 06:20:00
发表于 2016-08-18 17:43 |显示全部楼层
回复 28# yulihua49


    好,一路顺利!
您需要登录后才可以回帖 登录 | 注册

本版积分规则 发表回复

DTCC2020中国数据库技术大会

【架构革新 高效可控】2020年12月21日-23日第十一届中国数据库技术大会将在北京隆重召开。

大会设置2大主会场,20+技术专场,将邀请超百位行业专家,重点围绕数据架构、AI与大数据、传统企业数据库实践和国产开源数据库等内容展开分享和探讨,为广大数据领域从业人士提供一场年度盛会和交流平台。

http://dtcc.it168.com


大会官网>>
  

北京盛拓优讯信息技术有限公司. 版权所有 16024965号-6 北京市公安局海淀分局网监中心备案编号:11010802020122
中国互联网协会会员  联系我们:huangweiwei@it168.com
感谢所有关心和支持过ChinaUnix的朋友们 转载本站内容请注明原作者名及出处

清除 Cookies - ChinaUnix - Archiver - WAP - TOP