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

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