def __init__(self, host="localhost", port=6379):
conn = psutil.net_connections()
ports = [c.laddr[1] for c in conn]
port = max(ports) + 1
self.__port = port
self.__redis_server = Popen(["redis-server", "--port", str(port)])
sleep(1)
self.__worker = [
Process(target=work,
args=(["--host", "localhost", "--port", str(port)],),
daemon=False)
for _ in range(2)
]
for p in self.__worker:
p.start()
super().__init__(host, port)
评论列表
文章目录