Python非同期処理入門 第1部：なぜasyncioが必要なのか？基礎から理解する

import time

def cook_pasta():
    """パスタを作る（3秒かかる）"""
    print("パスタを作り始めました...")
    time.sleep(3)  # 3秒待つ
    print("パスタが完成しました！")
    return "パスタ"

def cook_salad():
    """サラダを作る（2秒かかる）"""
    print("サラダを作り始めました...")
    time.sleep(2)  # 2秒待つ
    print("サラダが完成しました！")
    return "サラダ"

# 順番に料理を作る
start_time = time.time()

pasta = cook_pasta()  # 3秒待つ
salad = cook_salad()  # さらに2秒待つ

end_time = time.time()
print(f"\n完成した料理: {pasta}と{salad}")
print(f"かかった時間: {end_time - start_time:.1f}秒")

# 結果: 約5秒かかる

import asyncio

async def cook_pasta_async():
    """パスタを非同期で作る"""
    print("パスタを作り始めました...")
    await asyncio.sleep(3)  # 3秒待つ（非同期）
    print("パスタが完成しました！")
    return "パスタ"

async def cook_salad_async():
    """サラダを非同期で作る"""
    print("サラダを作り始めました...")
    await asyncio.sleep(2)  # 2秒待つ（非同期）
    print("サラダが完成しました！")
    return "サラダ"

async def main():
    """メイン処理"""
    # 両方の料理を同時に開始
    results = await asyncio.gather(
        cook_pasta_async(),
        cook_salad_async()
    )
    return results

# 実行
start_time = time.time()
pasta, salad = asyncio.run(main())
end_time = time.time()

print(f"\n完成した料理: {pasta}と{salad}")
print(f"かかった時間: {end_time - start_time:.1f}秒")

# 結果: 約3秒で完成（速い方の時間）

async def my_async_function():
    """これは非同期関数です"""
    return "Hello"

async def example():
    result = await some_async_operation()
    print(result)

asyncio.run(main())  # main()は非同期関数

# ❌ 間違い
async def bad_example():
    result = cook_pasta_async()  # awaitを忘れている！
    print(result)  # <coroutine object...> と表示される

# ✅ 正解
async def good_example():
    result = await cook_pasta_async()
    print(result)  # "パスタ" と表示される

# ❌ 間違い
def normal_function():
    await asyncio.sleep(1)  # エラーになる！

# ✅ 正解
async def async_function():
    await asyncio.sleep(1)  # OK

import asyncio
import aiohttp
import time

async def check_website(session, url):
    """Webサイトの応答時間を測定"""
    try:
        start = time.time()
        async with session.get(url) as response:
            await response.text()
            elapsed = time.time() - start
            return f"{url}: {elapsed:.2f}秒"
    except Exception as e:
        return f"{url}: エラー ({str(e)})"

async def check_all_websites():
    """複数のサイトを同時にチェック"""
    urls = [
        'https://www.google.com',
        'https://www.yahoo.co.jp',
        'https://www.amazon.co.jp'
    ]
    
    async with aiohttp.ClientSession() as session:
        # 全てのサイトを同時にチェック
        results = await asyncio.gather(
            *[check_website(session, url) for url in urls]
        )
        
        return results

# 実行
print("Webサイトの応答時間を測定中...")
results = asyncio.run(check_all_websites())

print("\n結果:")
for result in results:
    print(result)

# 同期処理版
def download_file(filename):
    print(f"{filename}のダウンロード開始")
    time.sleep(2)
    print(f"{filename}のダウンロード完了")
    return f"{filename}の内容"

# 3つのファイルを順番にダウンロード
file1 = download_file("data1.txt")
file2 = download_file("data2.txt")
file3 = download_file("data3.txt")