R
Size: a a a
2021 April 08
ST
Файбер захватывает транзакционныц тред. Делайте fiber.yielf периодически, чтобы давать работать другим файберам
АГ
мм. понял в какую сторону копать, большое спасибо)
АГ
вообще по идее нужно что-то типа крона. как это по-грамотному сделать?
YD
Трясите @arturbrsg
АГ
а fiber.yield() вызвать годится вместо слипа?
АГ
ок, понял идею, спасибо) в тарантуле многопоточности же нет, верно?
NK
А ещё может быть вариант обновлять агрегаты сразу при вставке/обновлении товаров в одной транзакции
NK
Есть кооперативная многозадачность в одном треде
АГ
если бы это было возможно, так бы и сделали, скорее всего) там сильно много всего придется переписывать, пока нереально.
MA
для обхода ещё можете воспользоваться moonwalker
там внутрь всё уже зашито
там внутрь всё уже зашито
АГ
ок, посмотрю что это, спасибо
MA
http://github.com/tarantool/moonwalker
создавался во времена, когда итераторы ещё не были стабильными, но вполне неплохо себя зарекомендовал как инструмен для обхода спейсов (с целью массово обновить или что-то посчитать)
создавался во времена, когда итераторы ещё не были стабильными, но вполне неплохо себя зарекомендовал как инструмен для обхода спейсов (с целью массово обновить или что-то посчитать)
АГ
только у нас надо несколько спейсов обойти, там не так тривиально все, ну суть я понял - 1 поток - любой файбер, любая процедура его блокирует. надо обрабатывать данные частями, и файбер слипить, чтобы в это время другое успевало прожеваться.
MA
Альтернативно, можно скопировать себе в проект вот этот кусочек кода (что-то мы никак его не дотащим в luafun) https://github.com/moonlibs/kit/blob/master/kit/1/6%2B.lua#L2-L19
это даст на любом итераторе
это даст на любом итераторе
:pairs() дополнительный метод :yield(N), которы будет раз в N итераций делать fiber.yieldYD
Консистентный промоут гарантирует, что is_master true не прилетит раньше времени. По крайней мере внутри одного репликасета. Между репликасетами такой слой синхронизации не натянут. Про это и тикет который я упоминал