免费注册 查看新帖 |

Chinaunix

  平台 论坛 博客 文库
最近访问板块 发新帖
查看: 3281 | 回复: 9

[其他] 协程里,这种逻辑一般怎么实现? [复制链接]

论坛徽章:
4
水瓶座
日期:2013-09-06 12:27:30摩羯座
日期:2013-09-28 14:07:46处女座
日期:2013-10-24 14:25:01酉鸡
日期:2014-04-07 11:54:15
发表于 2016-07-01 15:14 |显示全部楼层
比如我有2个协程A和B,

A的逻辑是:
   每隔1秒,通过channel(协程间队列)向B协程发送一条ping消息。

coroutine A:
   while (true) { write(channel,"ping"); sleep(1); }

B的逻辑是:
   处理某个客户端的socket的读写,同时如果channel里有ping消息,那么取出来发送给socekt。

coroutine B:
   while (true) { request=read(socket); response=procoess(request); write(socket,response); }


请问,coroutine B应该怎么把红色部分的逻辑插入到代码里,各种语言的协程都有什么机制来实现呢。

论坛徽章:
3
2015年辞旧岁徽章
日期:2015-03-03 16:54:152015年迎新春徽章
日期:2015-03-04 09:49:032015年亚洲杯之中国
日期:2015-04-22 15:52:45
发表于 2016-07-01 17:46 |显示全部楼层
本帖最后由 hanxin83 于 2016-07-04 11:30 编辑

理解错题目了--|||
编辑掉, 期待各侠大牛的回答----

论坛徽章:
136
2022北京冬奥会纪念版徽章
日期:2015-08-07 17:10:5719周年集字徽章-庆
日期:2019-08-27 13:28:5615-16赛季CBA联赛之福建
日期:2019-09-10 11:43:25
发表于 2016-07-01 18:38 来自手机 |显示全部楼层
看引擎代码就知道,干吗自己研究

论坛徽章:
2
青铜圣斗士
日期:2015-11-26 06:15:59数据库技术版块每日发帖之星
日期:2016-07-24 06:20:00
发表于 2016-07-03 22:13 |显示全部楼层
linux_c_py_php 发表于 2016-07-01 15:14
coroutine A:
   while (true) { write(channel,"ping"); sleep(1); }
coroutine B:
   while (true) { request=read(socket); response=procoess(request); write(socket,response); }


不能A与B共享一个socket,然后A每1秒直接写吗。。。  就是B不变A改成:

  1. while (true) { write(socket, "ping"); sleep(1); }
复制代码
如果不行的话。。。

linux_c_py_php 发表于 2016-07-01 15:14
请问,coroutine B应该怎么把红色部分的逻辑插入到代码里,各种语言的协程都有什么机制来实现呢。


go里面叫select。。。
clojure(core.async)是alt一系列的操作。。。
和操作系统那个select的"概念"类似(并不指它的效率或真的需要系统调用)。。。 可以等待多个"事件"。。。

论坛徽章:
2
青铜圣斗士
日期:2015-11-26 06:15:59数据库技术版块每日发帖之星
日期:2016-07-24 06:20:00
发表于 2016-07-03 22:26 |显示全部楼层
go就不写了。。。 我估计自己写不对。。。
clojure的A大致是。。。

  1. (go ; "A"
  2.   (while true
  3.     (>! ping-channel "ping")
  4.     (<! (timeout 1000))))
复制代码
(>! c v) 往 c 这个channel里写入v。
如果c被关闭, 直接返回。
如果c没满, 写入后直接返回。
否则挂起, 当实际被写入(有人消费)后恢复执行。

(<! c) 从c 这个channel读取一个值。
如果c被关闭, 直接返回。
如果c非空, 取出一个值后返回。
否则挂起, 直到能读取值(有人产生)后恢复执行。

(timeout 1000) 返回一个channel, 该channel会在1000毫秒后被关闭。

然后原始的B大致是:

  1. (go ; "B"
  2.   (while true
  3.     (let [request (<! socket-incoming)
  4.           response (processes request)]
  5.       (>! socket-outgoing response))))
复制代码
从socket-incoming读取, processes, 写入socket-outgoing。

然后B加上ping大致是:

  1. (go ; "B+ping"
  2.   (while true
  3.     (let [response-or-ping
  4.          (alt!
  5.            ; 从 socket-incoming 或 ping-channel 里读取
  6.            socket-incoming
  7.              ; 从 socket-incoming 读取到的执行这个函数
  8.              ([request] (processes request))
  9.            ping-channel
  10.              ; 从 ping-channel 读取到的执行这个函数
  11.              ([ping] ping))]
  12.       (>! socket-outgoing response-or-ping))))

  13. ([request] (processes request)) 和
  14. ([ping] ping)
  15. 大致是
  16. function (request) { return processes(request); }
  17. function (ping) { return ping; }
复制代码

论坛徽章:
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-07-04 10:29 |显示全部楼层
                        

论坛徽章:
4
水瓶座
日期:2013-09-06 12:27:30摩羯座
日期:2013-09-28 14:07:46处女座
日期:2013-10-24 14:25:01酉鸡
日期:2014-04-07 11:54:15
发表于 2016-07-04 19:11 |显示全部楼层
本帖最后由 linux_c_py_php 于 2016-07-04 19:13 编辑
OwnWaterloo 发表于 2016-07-03 22:26
go就不写了。。。 我估计自己写不对。。。
clojure的A大致是。。。(>! c v) 往 c 这个channel里写入v。
如 ...


我百度了一下,发现Go可以把同时读socket和channel转化成同时select多个channel。

思路就是每个连接一个main goroutine,做select监视一个广播消息的channel。另外,在main goroutine内创建一个额外的channel,并启动一个额外的goroutine死循环读socekt的数据,放到这个额外的channel里。最终,main goroutine的select同时监听这个额外的channel。

和erlang的确是差不多的,只不过erlang把一切都叫做msg,而go需要把socket的数据自己转化为msg,最终都是select这种形式做并发。

另外,socket或者channel都是双向双工的,也是这种形式的核心点吧。

论坛徽章:
1
2015年辞旧岁徽章
日期:2015-03-03 16:54:15
发表于 2016-07-07 08:49 |显示全部楼层
没太看懂,红色部分的代码是阻塞操作或者异步操作吗?  理论上非阻塞、非异步的代码直接在代码里写就是了。

论坛徽章:
0
发表于 2016-07-07 16:27 |显示全部楼层
c++开发服务器的不多了吧

论坛徽章:
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-07-10 15:12 |显示全部楼层
bandaotidejia 发表于 2016-07-07 16:27
c++开发服务器的不多了吧

如果开发服务器都不用C++了,C++可以寿终正寝了。
您需要登录后才可以回帖 登录 | 注册

本版积分规则 发表回复

SACC2019中国系统架构师大会

【数字转型 架构演进】SACC2019中国系统架构师大会,8.5折限时优惠重磅来袭!
2019年10月31日~11月2日第11届中国系统架构师大会(SACC2019)将在北京隆重召开。四大主线并行的演讲模式,1个主会场、20个技术专场、超千人参与的会议规模,100+来自互联网、金融、制造业、电商等领域的嘉宾阵容,将为广大参会者提供一场最具价值的技术交流盛会。

限时8.5折扣期:2019年9月30日前


----------------------------------------

大会官网>>
  

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

清除 Cookies - ChinaUnix - Archiver - WAP - TOP