
复制import redis,使用s实术 time rc = redis.Redis() def wait( wait_for ): ps = rc.pubsub() ps.subscribe( wait_for ) ps.get_message() wait_msg = None while True: msg = ps.get_message() if msg and msg[type] == message: wait_msg = msg break time.sleep(0.001) ps.close() return wait_msg def signal_broadcast( wait_in, data ): wait_count = rc.publish(wait_in, data) return wait_count 1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.