LecturesCMC/PythonIntro2023/Homework_BarrierSync

Написать сопрограмму serial(number, barrier), принимающую два параметра — некоторый номер number и объект barrier типа Barrier.

В тестах создаётся один барьер bar определённого размера num и запускается num заданий видаserial(i, bar), где i — некоторое произвольное целое
Каждая сопрограмма должна однократно выводить number.
Задание serial(m, b) выводит m раньше, чем serial(n, b) выводит n, если m < n
- Таким образом в результате номера выводятся в порядке неубывания.

   1 from random import shuffle
   2 
   3 async def main(num):
   4     bar = asyncio.Barrier(num)
   5     tasks = [serial(i * 2 % num, bar) for i in range(num)]
   6     shuffle(tasks)
   7     await asyncio.gather(*tasks)
   8 
   9 asyncio.run(main(10))

Я просто хранил список номеров в дополнительном поле barrier
Надо вызывать asyncio.sleep(0) для того, чтобы другие сопрограммы тоже поработали
Однако решение «в лоб» (с asyncio.sleep(0)) занимало у меня слишком много времени, и мне пришлось заменить его на ещё одну синхронизацию, которую я тоже сделал с помощью Barrier-ов (см. спойлер)

Спойлер. В очередной раз замечу, что async — это не параллелизм, так что проблем с одновременным доступом, например, к списку number-ов, нет. Я решал задачу так (уверен, что может быть и более простое решение):

CategoryHomework

LecturesCMC/PythonIntro2023/Homework_BarrierSync (последним исправлял пользователь FrBrGeorge 2023-12-09 21:56:54)