multiprocessing-pipes.py

from multiprocessing import Pipe, Process

def _thread_fun(pipe: Pipe):
    while True:
        print('WAITING')
        val = pipe.recv()
        if val == 'FINISH':
            print('FINISHING')
            break
        pipe.send(val * 10)
        print('DONE')

    print('OUTSIDE')


if __name__ == '__main__':
    myPipe, subPipe = Pipe()
    p = Process(target=_thread_fun, args=(subPipe, ))
    p.start()
    myPipe.send(1)
    while not (status := myPipe.poll()):
        print(status)
    print(status)
    print(myPipe.recv())
    myPipe.send(2)
    print(myPipe.recv())
    myPipe.send(3)
    print(myPipe.recv())
    myPipe.send('FINISH')
    p.join()