import socket import errno import sys count, = sys.argv[1:] count = int(count) blob = b"X" * 100 socket_list = [] # Keep all sockets open. for n in range(count): sockets = socket.socketpair( socket.AF_UNIX, socket.SOCK_STREAM | socket.SOCK_NONBLOCK, 0) for sock in sockets: while True: try: sock.send(blob) except BlockingIOError: break socket_list.append(sock)