# pip install greenlet
"""
greenlet是一个在同一个线程中实现微线程的库，可以用它来实现协程。
下面是一个使用greenlet实现的简单协程的示例：
"""

from greenlet import greenlet


def coroutine_one():
    print("Start Coroutine One")
    gr2.switch()  # 切换到协程二
    print("End Coroutine One")
    gr2.switch()  # 再次切换到协程二，形成循环


def coroutine_two():
    print("Start Coroutine Two")
    gr1.switch()  # 切换到协程一
    print("End Coroutine Two")


# 创建两个 greenlet 对象，分别代表两个协程
gr1 = greenlet(coroutine_one)
gr2 = greenlet(coroutine_two)


def main():
    gr1.switch()  # 切换到协程一


if __name__ == "__main__":
    main()

"""
yield 实现比较牵强，为了实现协程而实现，没有什么意义
"""

from greenlet import greenlet


def coroutine_one():
    yield "Start Coroutine One"
    yield from coroutine_two()  # 切换到协程二
    yield "End Coroutine One"


def coroutine_two():
    yield "Start Coroutine Two"
    yield "End Coroutine Two"


gr1 = coroutine_one()
for item in gr1:
    print(item)

"""
python 3.4 之后引入
可以看到上面有个中划线，代表要废弃
特点：遇到IO阻塞自动切换
"""
import asyncio


@asyncio.coroutine
def coroutine_one():
    print("Start Coroutine One")
    # 遇到IO耗时操作，自动切换到tasks中的其他任务
    yield from asyncio.sleep(2)
    print("End Coroutine One")


@asyncio.coroutine
def coroutine_tow():
    print("Start Coroutine Two")
    yield from asyncio.sleep(1)
    print("End Coroutine Two")


task = [
    asyncio.ensure_future(coroutine_one()),
    asyncio.ensure_future(coroutine_tow())
]

# 协程函数执行有点特殊
loop = asyncio.get_event_loop()
loop.run_until_complete(asyncio.wait(task))

"""
python 3.5 之后引入
对装饰器进行修改
特点：遇到IO阻塞自动切换
"""
import asyncio
import time


async def coroutine_one():
    print("Start Coroutine One")
    # 遇到IO耗时操作，自动切换到tasks中的其他任务
    await asyncio.sleep(2)
    print("End Coroutine One")


async def coroutine_tow():
    print("Start Coroutine Two")
    await asyncio.sleep(1)
    print("End Coroutine Two")


task = [
    asyncio.ensure_future(coroutine_one()),
    asyncio.ensure_future(coroutine_tow())
]

start_time = time.time()
loop = asyncio.get_event_loop()
loop.run_until_complete(asyncio.wait(task))
end_time = time.time()
total_time = end_time - start_time
print(f"耗时是: {total_time} 秒")

import time

import requests
from io import BytesIO
from PIL import Image


def download_images(url, name):
    print(f"图片{name} 开始下载！")
    # time.sleep(1)
    response = requests.get(url)

    if response.status_code == 200:
        print(f"图片{name} 获取成功！")
        # 使用 BytesIO 将图片内容转换为二进制流
        image_data = BytesIO(response.content)
        # time.sleep(2)
        # 使用 PIL 库打开图片
        image = Image.open(image_data)

        # 保存图片到本地
        image.save(f'image_{name}.jpg')

        print(f"图片{name} 保存成功.")


if __name__ == "__main__":
    image_urls = [
        'https://img1.tuguaishou.com/ips_templ_preview/69/76/1b/lg_5811401_1701160656_6565a6d092aee.jpg!w440?auth_key=1701387000-0-0-ed2a2dbae71d8fa6e08da8dca5662d7d',
        'https://img1.tuguaishou.com/ips_templ_small/ec/b1/ee/sm_5850428_1701141850_65655d5a10191.jpg!w440?auth_key=1701387000-0-0-61b975a896823b40c461a4a7d6c204af',
        'https://img2.tuguaishou.com/ips_templ_small/2a/9d/a5/sm_5850288_1701281313_65677e21d7bb2.jpg!w440?auth_key=1701387000-0-0-850ab5453894a2313ef7690125379b34'
    ]

    start_time = time.time()
    for i, item in enumerate(image_urls):
        download_images(item, i)
    end_time = time.time()
    total_time = end_time - start_time
    print(f"耗时是: {total_time} 秒")

# pip install aiohttp

import time

import aiohttp
import asyncio
import os

from io import BytesIO
from PIL import Image


async def download_image(session, url, name, save_path='.'):
    print(f"图片{name} 开始下载！")
    try:
        async with session.get(url, verify_ssl=False) as response:
            await asyncio.sleep(1)
            response.raise_for_status()  # 检查是否有请求错误

            print(f"图片{name} 获取成功！")
            # 使用 BytesIO 将图片内容转换为二进制流
            image_data = BytesIO(await response.read())
            await asyncio.sleep(2)
            # 使用 PIL 库打开图片
            image = Image.open(image_data)

            # 检查保存路径是否存在，不存在则创建
            save_folder = os.path.join(save_path, 'images')
            os.makedirs(save_folder, exist_ok=True)

            # 保存图片到本地 异步调整
            image.save(os.path.join(save_folder, f'image_{name}.jpg'))

            print(f"图片{name} 保存成功.")
    except aiohttp.ClientError as e:
        print(f"图片{name} 下载失败: {e}")


async def main():
    image_urls = [
        'https://img1.tuguaishou.com/ips_templ_preview/69/76/1b/lg_5811401_1701160656_6565a6d092aee.jpg!w440?auth_key=1701387000-0-0-ed2a2dbae71d8fa6e08da8dca5662d7d',
        'https://img1.tuguaishou.com/ips_templ_small/ec/b1/ee/sm_5850428_1701141850_65655d5a10191.jpg!w440?auth_key=1701387000-0-0-61b975a896823b40c461a4a7d6c204af',
        'https://img2.tuguaishou.com/ips_templ_small/2a/9d/a5/sm_5850288_1701281313_65677e21d7bb2.jpg!w440?auth_key=1701387000-0-0-850ab5453894a2313ef7690125379b34'
    ]

    async with aiohttp.ClientSession() as session:
        tasks = [download_image(session, url, i) for i, url in enumerate(image_urls)]
        await asyncio.gather(*tasks)


if __name__ == "__main__":
    start_time = time.time()
    asyncio.run(main())
    end_time = time.time()
    total_time = end_time - start_time
    print(f"耗时是: {total_time} 秒")

import time
import requests
from concurrent.futures import ThreadPoolExecutor
from io import BytesIO
from PIL import Image
import os


def download_image(url, name, save_path='.'):
    print(f"图片{name} 开始下载！")
    # time.sleep(1)
    try:
        response = requests.get(url)
        response.raise_for_status()  # 检查是否有请求错误

        print(f"图片{name} 获取成功！")
        image_data = BytesIO(response.content)
        # time.sleep(2)
        image = Image.open(image_data)

        save_folder = os.path.join(save_path, 'images')
        os.makedirs(save_folder, exist_ok=True)

        image.save(os.path.join(save_folder, f'image_{name}.jpg'))

        print(f"图片{name} 保存成功.")
    except requests.RequestException as e:
        print(f"图片{name} 下载失败: {e}")


def main():
    image_urls = [
        'https://img1.tuguaishou.com/ips_templ_preview/69/76/1b/lg_5811401_1701160656_6565a6d092aee.jpg!w440?auth_key=1701387000-0-0-ed2a2dbae71d8fa6e08da8dca5662d7d',
        'https://img1.tuguaishou.com/ips_templ_small/ec/b1/ee/sm_5850428_1701141850_65655d5a10191.jpg!w440?auth_key=1701387000-0-0-61b975a896823b40c461a4a7d6c204af',
        'https://img2.tuguaishou.com/ips_templ_small/2a/9d/a5/sm_5850288_1701281313_65677e21d7bb2.jpg!w440?auth_key=1701387000-0-0-850ab5453894a2313ef7690125379b34'
    ]

    with ThreadPoolExecutor(max_workers=3) as executor:
        for i, url in enumerate(image_urls):
            executor.submit(download_image, url, i)


if __name__ == "__main__":
    start_time = time.time()
    main()
    end_time = time.time()
    total_time = end_time - start_time
    print(f"耗时是: {total_time} 秒")