# -*- encoding: utf-8 -*-
"""
@Time    : 2020/7/12
@Author  : hongboli
"""
import asyncio
import aioredis


async def execute(address, password=None):
    print("开始执行", address)

    # 网络IO操作：先去连接第一个 ，遇到IO则自动切换任务，去连接另一个
    if password:
        redis = await aioredis.create_redis_pool(address, password=password)
    else:
        redis = await aioredis.create_redis_pool(address)

    # 网络IO操作：遇到IO会自动切换任务
    await redis.hmset_dict('car', key1=1, key2=2, key3=3)

    # 网络IO操作：遇到IO会自动切换任务
    result = await redis.hgetall('car', encoding='utf-8')
    print(result)

    redis.close()
    # 网络IO操作：遇到IO会自动切换任务
    await redis.wait_closed()

    print("结束", address)


task_list = [
    execute('redis://127.0.0.1:6379'),
    execute('redis://127.0.0.1:6379')
]

asyncio.run(asyncio.wait(task_list))