Блог

Дочерний процесс может отправлять столько данных, сколько захочет, но родительский процесс может отправить его один раз, затем программа останавливается и ждет чего-то (я не знаю, чего). Канал открыт, я не могу понять, почему это происходит… Я уже просмотрел документацию, но в двунаправленном канале нет примера, только однонаправленный канал.

Код:

 from multiprocessing import Process, Pipe, current_process
from multiprocessing.connection import wait

def foo(w, i):
    print("w -> 1234")
    w.send("1234")

    readers = []

    readers.append(w)

    while readers:
        for r in wait(readers):
            try:
                msg = r.recv()
            except EOFError:
                print("w: error")
                readers.remove(r)
            else:

                if(msg == "1234"):
                    w.send("4321")
                    print("1234 -> w -> 4321")

                if(msg == "4321"):
                    print("4321 -> w")
                    print("w: close")


if __name__ == '__main__':

    readers = []
    r, w = Pipe(duplex=True)
    readers.append(r)
    p = Process(target=foo, args=(w, 1))
    p.start()
    w.close()

    while readers:
        for r in wait(readers):
            try:
                msg = r.recv()
                if(msg == "1234"):
                    r.send("1234")
                    print("1234 -> r -> 1234")

                if(msg == "4321"):
                    r.send("r: 4321")
                    print("4321 -> r -> 4321")

            except EOFError:
                print("r: error")
                readers.remove(r)

  

Текущий вывод:

 w -> 1234
1234 -> r -> 1234
1234 -> w -> 4321
4321 -> r -> 4321
  

Ожидаемый результат:

 w -> 1234
1234 -> r -> 1234
1234 -> w -> 4321
4321 -> r -> 4321
4321 -> w
w: close