How can I use asyncio for advanced concurrency in Python?

How can I use asyncio for advanced concurrency in Python?

You can use asyncio to manage multiple tasks concurrently using coroutines, event loops, and tasks. Would you like an example?

Yes, please provide an example of using asyncio with multiple coroutines.

Sure! Here's a simple example:

import asyncio

async def fetch_data(num):
    print(f'Starting fetch {num}')
    await asyncio.sleep(2)
    print(f'Finished fetch {num}')

async def main():
    tasks = [fetch_data(i) for i in range(5)]
    await asyncio.gather(*tasks)

asyncio.run(main())

This will run five fetch operations concurrently.

What if I want to handle exceptions in my coroutines?

You can use try-except blocks within your coroutines to handle exceptions. For example:

async def fetch_data(num):
    try:
        # Simulate a fetch operation
        if num == 2:
            raise ValueError('An error occurred!')
        await asyncio.sleep(2)
        print(f'Finished fetch {num}')
    except Exception as e:
        print(f'Error in fetch {num}: {e}')