非同期並列実行版 map 関数（Python） - Qiita

こんにちは。 非同期並列実行版 map関数を、asyncio を利用して作りました（下記ソース内の map_async）。 動作確認 最大並列数（limit）を 2 へ指定し、実行時間が 1/2 となることを確かめました。 ソース #!/usr/bin/env python3 # -*- coding: utf-8 -*- import asyncio def map_async(func, data, limit): loop = asyncio.get_event_loop() async def run_all(): sem = asyncio.Semaphore(limit) async def run_each(d): async with sem: return await loop.run_in_executor(None, func, d) return await asy