标签: pykka

我目前正在尝试使用Actor-concurreny(在Python上),因为我想了解更多相关信息.因此我选择了pykka,但是当我测试它时,它比正常功能慢一半.

该守则只是看它是否有效; 它并不意味着优雅.:)

也许我做错了什么？

from pykka.actor import ThreadingActor
import numpy as np

class Adder(ThreadingActor):
    def add_one(self, i):
        l = []
        for j in i:
            l.append(j+1)
        return l

if __name__ == '__main__':
    data = np.random.random(1000000)
    adder = Adder.start().proxy()
    adder.add_one(data)
    adder.stop()

这不会那么快:

time python actor.py

real    0m8.319s
user    0m8.185s
sys     0m0.140s

而现在虚拟'正常'功能:

def foo(i):
    l = []
    for j in i:
        l.append(j+1)
    return l

if __name__ == '__main__':
    data = np.random.random(1000000)
    foo(data)

给出这个结果:

real    0m3.665s
user    0m3.348s
sys …

我有一些用Python编写的分析代码。目前，我正在使用Storm处理流。因为Storm允许使用消息序列化调用python代码，所以我在Storm螺栓中从Java / Scala调用了Python代码。

我发现Pykka是actor模型的Python实现。我想知道是否有一种方法可以从Akka演员那里调用Python代码？例如，是否可以将消息从Akka演员传递到Pykka演员？

我想和 python 中的演员一起玩。显然，两个最受欢迎的替代品是thespian和pykka。我正在寻找积极开发且易于使用的东西。

您会推荐哪一个，为什么？