Trying out multiprocessing and reduce_socket on windows

test_client.py

# Echo client program
import socket

HOST = 'localhost'    # The remote host
PORT = 50007              # The same port as used by the server
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((HOST, PORT))
s.send(b'Hello, world')
data = s.recv(1024)
s.close()
print('Received', repr(data))

test_send_accepted_conn.py

import multiprocessing
from multiprocessing.reduction import reduce_socket
import socket


def worker(q):
    while True:
        (fn, args), addr = q.get()
        conn = fn(*args)
        print('Connected by', addr)
        while 1:
            data = conn.recv(1024)
            if not data: break
            conn.send(data)
        conn.close()


if __name__=='__main__':
    queue = multiprocessing.Queue()
    HOST = ''
    PORT = 50007
    p = multiprocessing.Process(target=worker, args=(queue,))
    p.start()

    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    s.bind((HOST, PORT))
    while True:
        s.listen(1)
        conn, addr = s.accept()
        queue.put((reduce_socket(conn), addr))

test_shared_listen_socket.py

import time
import multiprocessing
from multiprocessing.reduction import reduce_socket
import socket


def worker(sockargs, name):
    fn, args = sockargs
    s = fn(*args)
    while True:
        s.listen(1)
        conn, addr = s.accept()
        print ('Connected by', addr, 'to', name)
        while 1:
            data = conn.recv(1024)
            if not data: break
            conn.send(data)
        conn.close()


if __name__=='__main__':
    queue = multiprocessing.Queue()
    HOST = ''
    PORT = 50007


    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    s.bind((HOST, PORT))

    p1 = multiprocessing.Process(target=worker, args=(reduce_socket(s), 'p1'))
    p1.start()

    time.sleep(1)
    

    p2 = multiprocessing.Process(target=worker, args=(reduce_socket(s), 'p2'))
    p2.start()