python - 使用 Thespian 在演员之间发送低延迟消息的低性能

问题描述

我使用 Thespian 开发一个应用程序来通过套接字消耗低延迟数据。我最初创建了两个参与者：一个消费者（套接字客户端连接）和处理程序。测试中，我检测到在消费者 (Actor1) 中发送一条消息的时间与该消息到达处理程序 (Actor2) 的时间之间存在一些延迟。

为了测试这一点，我使用了以下代码。

from thespian.actors import ActorSystem, Actor

import time


class Actor1(Actor):
    def receiveMessage(self, handler, sender):
        # benchmark
        data = {'tic': time.perf_counter(), 'lim': 10000}
        print('Elapsed Time to process {} messages'.format(data['lim']))
        for i in range(data['lim']):
            self.send(handler, data)
        # perf
        toc = time.perf_counter() - data['tic']
        print('Actor 1: {} sec'.format(round(toc, 3)))
        # self.actorSystemShutdown()


class Actor2(Actor):
    def __init__(self):
        self.msg_count = 0

    def receiveMessage(self, data, sender):
        self.msg_count += 1
        if self.msg_count == data['lim']:
            toc = time.perf_counter() - data['tic']
            print('Actor 2: {} sec'.format(round(toc, 3)))

def main():
    asys = ActorSystem('multiprocTCPBase')
    consumer = asys.createActor(Actor1)
    handler = asys.createActor(Actor2)
    asys.tell(consumer, handler)

if __name__ == '__main__':
    main()

结果：

Elapsed Time to process 10 messages
Actor 1: 0.002 sec
Actor 2: 0.008 sec

Elapsed Time to process 100 messages
Actor 1: 0.019 sec
Actor 2: 0.099 sec

Elapsed Time to process 1000 messages
Actor 1: 0.131 sec
Actor 2: 0.769 sec

Elapsed Time to process 10000 messages
Actor 1: 1.219 sec
Actor 2: 7.608 sec

Elapsed Time to process 100000 messages
Actor 1: 22.012 sec
Actor 2: 91.419 sec

查看这些结果，我的代码中是否存在错误或缺失？或者还有另一种更快的方式在参与者之间发送消息？此外，还有任何其他基准可以帮助我们分析文档中评论的性能。

标签： pythonactor

python - 使用 Thespian 在演员之间发送低延迟消息的低性能

问题描述

解决方案

推荐阅读