Эквивалент многопроцессорности. Процесс в пафосе

Question

Я пытался бесконечно долго использовать следующий фрагмент кода для чтения из консоли:

def read_console(hub):
    while True:
        text = input("write stuff")
        if text == 'y':
            hub.server.invoke('Say', 'hello')
        print (text)

connection = Connection('https://1234.net/signalr', session=None)
hub = connection.register_hub('echo')

read_console_process = multiprocessing.Process(target=read_console, args=(hub,))
read_console_process.start()

Однако я столкнулся с проблемой рассола и решил попробовать использовать pathosЯ попробовал следующее, но я получаю сообщение об ошибке - zip argument #1 must support iteration:

def main():
    connection = Connection('https://1234.net/signalr', session=None)
    hub = connection.register_hub('echo')

    executor = ProcessingPool()
    executor.map(read_console, hub)

Answer 1

Я pathos автор. ProcessingPool это бассейн Process объекты. Я думаю, что вы ищете multiprocess.Process, или же pathos.helpers.mp.Process, которые на самом деле являются одним и тем же объектом.