Зыков Валерий Павлович, 517 GroupWork 11251			Морозов Иван Дмитриевич, 517 GroupWork 11254
f	1	import asyncio	f	1	import asyncio
	2	from collections import deque		2	from collections import deque
	3			3
	4	class Loop:		4	class Loop:
n	5	"""Параметрический декоратор для корутин с синхронизацией выполнения	n
	>	"""
	6	_coros = []
	7	_args_kwargs = []		5	_tasks = []
				6	_params = []
	8	_current = 0		7	_cursor = 0
	9	_done = False
	10	_scheduled = False		8	_finished = False
				9	_active = False
	11			10
	12	def __init__(self):		11	def __init__(self):
n	13	self.index = len(Loop._coros)	n	12	self._id = len(Loop._tasks)
				13	Loop._tasks.append(None)
	14	Loop._coros.append(None)		14	Loop._params.append(None)
	15	Loop._args_kwargs.append(None)
	16			15
n	17	def __call__(self, coro):	n	16	def __call__(self, fn):
	18	Loop._coros[self.index] = coro		17	Loop._tasks[self._id] = fn
	19			18
n	20	async def wrapper(*args, **kwargs):	n	19	async def launcher(*args, **kwargs):
	21	Loop._args_kwargs[self.index] = (args, kwargs)		20	Loop._params[self._id] = (args, kwargs)
	22	if not Loop._scheduled:		21	if not Loop._active:
	23	Loop._scheduled = True		22	Loop._active = True
	24	return await Loop._run_scheduler()		23	return await Loop._run_scheduler()
	25	return None		24	return None
n	26	return wrapper	n	25	return launcher
	27			26
	28	@classmethod		27	@classmethod
	29	async def _run_scheduler(cls):		28	async def _run_scheduler(cls):
n	30	"""Планировщик, который выполняет все корутины по очереди"""	n
	31	step = 0		29	pointer = 0
	32	total_coros = len(cls._coros)		30	count = len(cls._tasks)
	33	while not cls._done:		31	while not cls._finished:
	34	idx = step % total_coros		32	slot = pointer % count
	35	coro = cls._coros[idx]		33	task = cls._tasks[slot]
	36	args_kwargs = cls._args_kwargs[idx]		34	payload = cls._params[slot]
	37	if coro is None or args_kwargs is None:		35	if task is None or payload is None:
	38	step += 1		36	pointer += 1
	39	await asyncio.sleep(0)		37	await asyncio.sleep(0)
	40	continue		38	continue
n	41	args, kwargs = args_kwargs	n	39	args, kwargs = payload
	42	try:		40	try:
n	43	result = await coro(*args, **kwargs)	n	41	outcome = await task(*args, **kwargs)
	44	except asyncio.CancelledError:		42	except asyncio.CancelledError:
n	45	cls._done = True	n	43	cls._finished = True
	46	return None		44	return None
n	47	if result is None:	n	45	if outcome is None:
	48	cls._done = True		46	cls._finished = True
	49	return None		47	return None
t	50	step += 1	t	48	pointer += 1
	51	await asyncio.sleep(0)		49	await asyncio.sleep(0)
	52	return None		50	return None

Legends
Colors  Added  Changed Deleted	Links (f)irst change (n)ext change (t)op