python - gevent，套接字和同步

Question

我有多个 greenlets 在一个公共(public)套接字上发送。是否保证通过 socket.sendall 发送的每个包都很好地分开，或者我是否必须在每次调用 sendall 之前获取锁。

所以我想防止以下情况:

• g1 发送 ABCD
• g2 发送 1234
• 接收到的数据是混淆的，例如AB1234CD
• 预期是 ABCD1234 或 1234ABCD

更新

看了sourcecode之后我认为这种情况不可能发生。但我必须使用锁，因为 g1 或 g2 可能会在 sendall 上崩溃。有人可以证实这一点吗？

Answer 1

我用高延迟/低带宽接口(interface)做了一些测试，得到了预期的错误。

• 模拟慢速接口(interface):https://superuser.com/a/147434
• 测试脚本:https://gist.github.com/4249827/6779dfbebc255e81252e9b29c94add98c5771669

这导致(如预期的那样)出现以下错误:

AssertionError: This event is already used by another greenlet: (<Greenlet 
at 0x7f3e758722d0: <bound method socket.sendall of <socket at 0x7f3e7587719
0 fileno=8 sock=127.0.0.1:1234 peer=127.0.0.1:51042>>('11111111111111111111
11111111111111111111111111111)>, timeout('timed out',))

这是带有 gevent.coros.RLock 的固定测试脚本，它不会产生此错误:https://gist.github.com/4249827/7f02f805331eda4091ae0b39dfea4b102cdba2fa