linux_c_py_php 发表于 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应该怎么把红色部分的逻辑插入到代码里，各种语言的协程都有什么机制来实现呢。

hanxin83 发表于 2016-07-01 17:46

本帖最后由 hanxin83 于 2016-07-04 11:30 编辑

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

shang2010 发表于 2016-07-01 18:38

看引擎代码就知道，干吗自己研究

OwnWaterloo 发表于 2016-07-03 22:13

linux_c_py_php 发表于 2016-07-01 15:14 static/image/common/back.gif
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改成：
while (true) { write(socket, "ping"); sleep(1); }
如果不行的话。。。

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


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

OwnWaterloo 发表于 2016-07-03 22:26

go就不写了。。。 我估计自己写不对。。。
clojure的A大致是。。。
(go ; "A"
(while true
    (>! ping-channel "ping")
    (<! (timeout 1000))))
(>! c v) 往 c 这个channel里写入v。
如果c被关闭， 直接返回。
如果c没满， 写入后直接返回。
否则挂起， 当实际被写入（有人消费）后恢复执行。

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

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

然后原始的B大致是：
(go ; "B"
(while true
    (let [request (<! socket-incoming)
          response (processes request)]
      (>! socket-outgoing response))))
从socket-incoming读取， processes， 写入socket-outgoing。

然后B加上ping大致是：
(go ; "B+ping"
(while true
    (let [response-or-ping
         (alt!
         ; 从 socket-incoming 或 ping-channel 里读取
         socket-incoming
             ; 从 socket-incoming 读取到的执行这个函数
             ( (processes request))
         ping-channel
             ; 从 ping-channel 读取到的执行这个函数
             ( ping))]
      (>! socket-outgoing response-or-ping))))

( (processes request)) 和
( ping)
大致是
function (request) { return processes(request); }
function (ping) { return ping; }

cokeboL 发表于 2016-07-04 10:29

:em22:                        

linux_c_py_php 发表于 2016-07-04 19:11

本帖最后由 linux_c_py_php 于 2016-07-04 19:13 编辑

OwnWaterloo 发表于 2016-07-03 22:26 static/image/common/back.gif
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都是双向双工的，也是这种形式的核心点吧。

csumck 发表于 2016-07-07 08:49

没太看懂，红色部分的代码是阻塞操作或者异步操作吗？理论上非阻塞、非异步的代码直接在代码里写就是了。

bandaotidejia 发表于 2016-07-07 16:27

c++开发服务器的不多了吧

yulihua49 发表于 2016-07-10 15:12

bandaotidejia 发表于 2016-07-07 16:27 static/image/common/back.gif
c++开发服务器的不多了吧
如果开发服务器都不用C＋＋了，C＋＋可以寿终正寝了。
页: [1]
查看完整版本: 协程里，这种逻辑一般怎么实现？