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

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