Я использую многопроцессорность для создания подпроцесса в моем приложении Python. Я хотел бы поделиться данными между моим родительским и дочерним процессами. Важно отметить, что мне нужно поделиться этим асинхронно, это означает, что дочерний процесс и родительский процесс будут обновлять данные во время выполнения кода.
Как лучше всего это сделать?
Это один простой пример из документации Python -
from multiprocessing import Process, Queue
def f(q):
q.put([42, None, 'hello'])
if __name__ == '__main__':
q = Queue()
p = Process(target=f, args=(q,))
p.start()
print q.get() # prints "[42, None, 'hello']"
p.join()
Вы также можете использовать канал. Дополнительные сведения см. В https://docs.python.org/2/library/multiprocessing.html
Вот пример многопроцессорной многопоточности и совместного использования пары переменных:
from multiprocessing import Process, Queue, Value, Manager
from ctypes import c_bool
from threading import Thread
ps = []
def yourFunc(var1, var2, pause, budget):
while True:
print(budget.value, pause.value)
##set value
pause.value = True
....
def multiProcess(distributor, threads, pause, budget):
for _ in range(threads):
t = Thread(target=yourFunc(), args=([1,2],None, distributor, pause, budget,))
t.start()
ts.append(t)
time.sleep(3)
if __name__ == '__main__':
pause = Value(c_bool, False)
budget = Value('i', 5000)
for i in range(2):
p = Process(target=multiProcess, args=('distributor', 2, pause, budget))
p.start()
ps.append(p)
