协程里，这种逻辑一般怎么实现？

linux_c_py_php

比如我有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

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

shang2010

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

OwnWaterloo

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. 
   
2. 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的"概念"类似（并不指它的效率或真的需要系统调用)。。。 可以等待多个"事件"。。。

OwnWaterloo

go就不写了。。。 我估计自己写不对。。。
clojure的A大致是。。。

1. 
   
2. (go ; "A"
   
3.   (while true
   
4.     (>! ping-channel "ping")
   
5.     (<! (timeout 1000))))
   

复制代码

(>! c v) 往 c 这个channel里写入v。
如果c被关闭， 直接返回。
如果c没满， 写入后直接返回。
否则挂起， 当实际被写入（有人消费）后恢复执行。

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

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

然后原始的B大致是：

1. 
   
2. (go ; "B"
   
3.   (while true
   
4.     (let [request (<! socket-incoming)
   
5.           response (processes request)]
   
6.       (>! socket-outgoing response))))
   

复制代码

从socket-incoming读取， processes， 写入socket-outgoing。

然后B加上ping大致是：

1. 
   
2. (go ; "B+ping"
   
3.   (while true
   
4.     (let [response-or-ping
   
5.          (alt!
   
6.            ; 从 socket-incoming 或 ping-channel 里读取
   
7.            socket-incoming
   
8.              ; 从 socket-incoming 读取到的执行这个函数
   
9.              ([request] (processes request))
   
10.            ping-channel
    
11.              ; 从 ping-channel 读取到的执行这个函数
    
12.              ([ping] ping))]
    
13.       (>! socket-outgoing response-or-ping))))
    
14. 
    
15. ([request] (processes request)) 和
    
16. ([ping] ping)
    
17. 大致是
    
18. function (request) { return processes(request); }
    
19. function (ping) { return ping; }
    

复制代码

cokeboL

                        

linux_c_py_php

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都是双向双工的，也是这种形式的核心点吧。

csumck

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

bandaotidejia

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

yulihua49

bandaotidejia 发表于 2016-07-07 16:27
c++开发服务器的不多了吧

如果开发服务器都不用C＋＋了，C＋＋可以寿终正寝了。