for client in ws_clients:
client.write_message("hello")
async def on_message(self, message):
for client in ws_clients:
asyncio.ensure_future(client.write_message(message))
from multiprocessing.dummy import Pool
def sm(client):
client.send_message('hello')
p = Pool(100)
_ = p.map(sm, ws_clients)
p.close()
p.join()