import time
from concurrent.futures.thread import ThreadPoolExecutor

import requests


def download_picture(pic_url):
    resp = requests.get(pic_url)
    if resp.status_code == 200:
        filename = pic_url[pic_url.rfind('/') + 1:]
        with open(f'images/{filename}', 'wb') as file:
            file.write(resp.content)


def main():
    pool = ThreadPoolExecutor(max_workers=32)
    futures = []
    key = 'e8c5524dd2a365f20908ced735f8e480'
    start = time.time()
    for page in range(1, 11):
        resp = requests.get(
            url=f'http://api.tianapi.com/meinv/index?key={key}&num=20&page={page}'
        )
        result = resp.json()
        if result['code'] == 200:
            for beauty in result['newslist']:
                f = pool.submit(download_picture, beauty['picUrl'])
                futures.append(f)
    for f in futures:
        f.result()
    end = time.time()
    print(f'下载时间：{end - start:.3f}秒')
    pool.shutdown()


if __name__ == '__main__':
    main()