Лукьянов Артём Васильевич, 317, Севастопольский филилал GroupWork 11041			Сагура Николай, 392, сев. филиал GroupWork 10435
f	1	import asyncio	f	1	import asyncio
	2			2
	3	class Loop:		3	class Loop:
n	4	_registry_count = 0	n	4	_count = 0
	5	_registry_funcs = []		5	_funcs = []
	6	_registry_args = []		6	_call_args = []
	7	_registry_started = 0		7	_started = 0
	8	_all_started_event = None		8	_all_started_event = None
n	9	_finished_future = None	n	9	_done_fut = None
	10	_scheduler_active = False		10	_scheduler_running = False
	11			11
	12	def __init__(self):		12	def __init__(self):
	13	pass		13	pass
	14			14
n	15	def __call__(self, coro_func):	n	15	def __call__(self, func):
	16	cls = self.__class__		16	cls = self.__class__
n	17	my_idx = cls._registry_count	n	17	idx = cls._count
	18	cls._registry_count += 1		18	cls._count += 1
	19	cls._registry_funcs.append(coro_func)		19	cls._funcs.append(func)
	20	if len(cls._registry_args) < cls._registry_count:		20	if len(cls._call_args) < cls._count:
	21	cls._registry_args.append(None)		21	cls._call_args.append(None)
	22			22
	23	async def wrapper(*args, **kwargs):		23	async def wrapper(*args, **kwargs):
n			n	24	cls = self.__class__
	24	loop = asyncio.get_running_loop()		25	loop = asyncio.get_running_loop()
n	25	if cls._finished_future is None:	n	26	if cls._done_fut is None:
	26	cls._finished_future = loop.create_future()		27	cls._done_fut = loop.create_future()
	27	if cls._all_started_event is None:		28	if cls._all_started_event is None:
	28	cls._all_started_event = asyncio.Event()		29	cls._all_started_event = asyncio.Event()
n	29	cls._registry_args[my_idx] = (args, kwargs)	n	30	cls._call_args[idx] = (args, kwargs)
	30	cls._registry_started += 1		31	cls._started += 1
	31	if cls._scheduler_active:		32	if cls._scheduler_running:
	32	if cls._registry_started == cls._registry_count:		33	if cls._started == cls._count:
	33	cls._all_started_event.set()		34	cls._all_started_event.set()
n	34	await cls._finished_future	n	35	await cls._done_fut
	35	return None		36	return None
n	36	cls._scheduler_active = True	n	37	cls._scheduler_running = True
	37	try:		38	try:
n	38	if cls._registry_started < cls._registry_count:	n	39	if cls._started < cls._count:
	39	await cls._all_started_event.wait()		40	await cls._all_started_event.wait()
	40	else:		41	else:
	41	cls._all_started_event.set()		42	cls._all_started_event.set()
n	42	idx_cycle = 0	n	43	idx_local = 0
	43	while True:		44	while True:
n	44	func = cls._registry_funcs[idx_cycle]	n	45	func_local = cls._funcs[idx_local]
	45	args_cycle, kwargs_cycle = cls._registry_args[idx_cy		46	args_local, kwargs_local = cls._call_args[idx_local]
	>	cle]
	46	result = await func(*args_cycle, **kwargs_cycle)		47	res = await func_local(*args_local, **kwargs_local)
	47	if result is None:		48	if res is None:
	48	break		49	break
n	49	idx_cycle = (idx_cycle + 1) % cls._registry_count	n	50	idx_local = (idx_local + 1) % cls._count
	50	if not cls._finished_future.done():		51	if not cls._done_fut.done():
	51	cls._finished_future.set_result(None)		52	cls._done_fut.set_result(None)
	52	finally:		53	finally:
n	53	cls._scheduler_active = False	n	54	cls._scheduler_running = False
	54	cls._registry_count = 0		55	cls._count = 0
	55	cls._registry_funcs = []		56	cls._funcs = []
	56	cls._registry_args = []		57	cls._call_args = []
	57	cls._registry_started = 0		58	cls._started = 0
	58	cls._all_started_event = None		59	cls._all_started_event = None
t	59	cls._finished_future = None	t	60	cls._done_fut = None
	60	return None		61	return None
	61	return wrapper		62	return wrapper

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