我有两个进程,initiator和responder,它们应该在彼此之间并行地重复地发送和接收值(值在循环中修改)(请参见简化的代码示例:
def initiatior():
for i in range(0, _passes):
_permutations.append(newPermutation(n))
with _lock:
pubCon.send(_permutations[i])
pass
def responder():
for i in range(0, _passes):
with _lock:
_permutations[i] = pubCon.receive()
pass
我想将发起者创建的排列发送给响应者,以便能够基于接收到的每个排列进行进一步的处理
多处理具有在不同的解释程序(进程)之间进行通信的特性
链接:https://docs.python.org/2/library/multiprocessing.html#multiprocessing-listeners-clients
文档中的示例-使用此示例可以很容易地在流程之间架起桥梁:
警告:python3和python2的语法有一些细微的差别
侦听器:
客户
编辑: 如果您只想在一个程序中的两个函数之间传递数据,可以使用全局变量。你知道吗
所需要的只是定义函数外的变量。你知道吗
示例:
相关问题 更多 >
编程相关推荐