أنماط async/await

async def main():
    # return_exceptions=True يُعيد الاستثناءات كنتائج بدل رميها
    # return_exceptions=True returns exceptions as results instead of raising
    results = await asyncio.gather(
        fetch_orders(),
        failing_task(),   # ستفشل هذه
        fetch_stats(),
        return_exceptions=True
    )

    for r in results:
        if isinstance(r, Exception):
            print(f"خطأ: {r}")
        else:
            print(f"نتيجة: {r}")

import asyncio
import aiofiles  # مكتبة خارجية لقراءة الملفات بشكل غير متزامن

async def read_file():
    # async with يضمن إغلاق الملف حتى عند الأخطاء
    # async with ensures file closes even on errors
    async with aiofiles.open("data.txt", "r") as f:
        content = await f.read()
    return content

# مثال آخر: اتصال بقاعدة بيانات
async def db_operation(pool):
    async with pool.acquire() as connection:
        result = await connection.fetch("SELECT * FROM users")
    return result

import asyncio

async def slow_operation():
    await asyncio.sleep(10)  # عملية بطيئة جداً

async def main():
    try:
        # انتظر بحد أقصى 2 ثانية — Wait maximum 2 seconds
        result = await asyncio.wait_for(slow_operation(), timeout=2.0)
    except asyncio.TimeoutError:
        print("انتهى الوقت المحدد!")

async def main():
    # ❌ ينشئ coroutine ولا ينفّذها
    fetch_data()  # RuntimeWarning: coroutine 'fetch_data' was never awaited

    # ✅ صواب
    await fetch_data()

import requests  # مكتبة HTTP تقليدية (blocking)

async def bad():
    # ❌ يُجمّد حلقة الأحداث كلها
    response = requests.get("https://api.example.com")

async def good():
    # ✅ استخدم مكتبة async
    # import aiohttp
    # async with aiohttp.ClientSession() as session:
    #     async with session.get("https://api.example.com") as response:
    #         data = await response.json()
    pass

async def main():
    # ❌ المهام تُنشأ لكن لا تُكتمل بالضرورة قبل نهاية main
    asyncio.create_task(background_job())

    # ✅ احتفظ بمرجع وانتظر
    task = asyncio.create_task(background_job())
    await task