多处理目标在父进程中依次运行

Question

我有一个函数orderbook(pair)，它打开一个websocket，订阅一个频道并侦听消息。我希望能够订阅多个频道，并行收听消息。有什么办法吗

到目前为止，我正在尝试以下方法：

from dev.orderbook import *
from multiprocessing import Process

def main():
    process01 = Process(target=orderbook('BTC-USD'))
    process02 = Process(target=orderbook('ETH-USD'))
    process01.start()
    process02.start()

if __name__ == '__main__':
    main()

但是，所有这些都是运行process01，只有当我停止脚本时，它才会运行process02。这不是我想要的行为。有没有办法我可以同时订阅这两个频道，同时收听和打印消息/回复？如果没有，那么有什么方法可以启动一个进程-让它运行指定的时间，然后启动下一个进程

我的websocket反映了以下内容：

import websocket

class orderbook(object):

def __init__(self, pair):
    self.pair = pair
    websocket.enableTrace(True)
    ws = websocket.WebSocketApp("ws://echo.websocket.org/",
                          on_message = self.on_message,
                          on_error = self.on_error,
                          on_close = self.on_close)
    ws.on_open = self.on_open
    ws.run_forever()

def on_message(self, ws, message):
    print(message)

def on_error(self, ws, error):
    print(error)

def on_close(self, ws):
    print("### closed ###")

def on_open(self, ws):
   ws.send(self.pair)

Answer 1

Process构造函数包含对目标函数的实际调用。因此，在父进程中，在计算构造函数行的过程中调用函数，结果作为target传递给Process()

您应该传递函数本身，并分别传递其参数：

process01 = Process(target=orderbook, args=('BTC-USD',))