waiter.acquire()Задача реальная. Коротко - парсинг бирж с тяжелыми вычислениями. Каждую биржу решил вынести в отдельный процесс, чтоб процессор задействовать на 100%. А внутри каждого уже всё делать асинхронно. Появилась задача сделать прокси менеджер. Попытался расшарить синглтон между процессами, идея оказалась гиблой (кто сомневался). Решил сделать общение через сокеты.from threading import Thread
def safe(func):
func()
threads = []
for i in range(2):
threads.append(
Thread(target=safe, args=[lambda: print(i)])
)
for t in threads:
t.start()
# output
# 1
# 1
readuntilс каким-нибудь сепаратором, но я от него отказался.