Как иметь неизменяемый общий объект на карте многопроцессорности Python ⇐ Python

[Anonymous]

Как я могу позволить всем моим рабочим процессам использовать один и тот же объект, чтобы ни один из них не изменял? Например, как лучше всего написать функцию, которая вычисляет скалярное произведение вектора аргумента со вторым вектором, одинаковым для всех процессов? Я бы по наивности написал что-то вроде этого:

Код: Выделить всё

import multiprocessing
import numpy as np

def main():
static_vector = np.array([1,2,3,4,5])

def f(v):
return np.dot(v, static_vector)

with multiprocessing.Pool() as p:
results = p.map(f, [np.random.random((5,1)) for _ in range(10)])

print(results)

if __name__ == "__main__":
main()

Но это не удается из-за ошибки AttributeError: невозможно выбрать локальный объект «main..f». В качестве аргумента вычисление статического вектора занимает некоторое время и не должно выполняться в каждом подпроцессе.

Подробнее здесь: https://stackoverflow.com/questions/791 ... essing-map