Пикка - Актеры медленные?

Question

В настоящее время я экспериментирую с 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     0m0.308s

Answer 1

Так что здесь происходит то, что ваша функциональная версия создает два очень больших списка, что составляет большую часть времени. Когда вы представляете актеров, изменяемые данные, такие как списки, должны быть скопированы перед отправкой актеру для обеспечения надлежащего параллелизма. Также список, созданный внутри субъекта, также должен быть скопирован при отправке обратно отправителю. Это означает, что вместо двух очень больших списков мы создали четыре очень больших списка.

Подумайте о том, чтобы спроектировать вещи так, чтобы субъект создавал и поддерживал данные, а затем запрашивал их, сводя к минимуму размер сообщений, передаваемых туда и обратно. Попробуйте применить принцип минимального перемещения данных. Передача списка в функциональном случае эффективна только потому, что данные на самом деле не перемещаются, что позволяет использовать общее пространство памяти. Если бы актер находился на другой машине, мы не получили бы преимущества от общего пространства памяти, даже если данные сообщения были неизменными и их не нужно было копировать.