AN
Значит там стоит блокировка. Корутины сделаны для того, чтобы блокировки не было
Size: a a a
2020 August 01
AI
happens before это про доступ к памяти. А я уже раз пять сказал, что job.cancel() только выставляет флаг, то, что там крутится в лбюом случае доработает до ближайшей suspension point.
Так корутина же как раз suspended, я же об этом толкую
AI
А если убрать offer? Offer делает рандеву и может разбудить колбек на другой стороне
Так без offer ничего работать не будет. Если например использовать Main.immediate диспатчер, то collect{} вызывается в том же самом кол стеке , и тогда всё ок.
RI
Вот тут должно упасть?
AN
Так корутина же как раз suspended, я же об этом толкую
Корутина гарантирует порядок выполнения только внутри одной конкретной корутины. Если вы пытаетесь без мьютексов сделать синхронизацию двух разных корутин, вы сами себе грабли раскладываете.
AI
В моём понимании не должно Могу проверить
AI
Корутина гарантирует порядок выполнения только внутри одной конкретной корутины. Если вы пытаетесь без мьютексов сделать синхронизацию двух разных корутин, вы сами себе грабли раскладываете.
Так там одна корутина, о чём речь?
RI
Вот тогда тест, у меня падает с
java.util.concurrent.ExecutionException: kotlin.UninitializedPropertyAccessException: lateinit property myChannel has not been initializedAI
да верно
AI
потому что start и stop надо разделит
AN
Так там одна корутина, о чём речь?
Нет, у вас cancel внешний. Он не синхронизирован никак со внутренностями корутины.
AI
в отдельные submit
RI
в отдельные submit
https://pastebin.com/Sqw56KNz
Разделил, все равно падает с
Разделил, все равно падает с
java.util.concurrent.ExecutionException: kotlin.UninitializedPropertyAccessException: lateinit property myChannel has not been initialized
AI
Печатает error
AI
Просто корутина должна успеть запуститься
RI
Т.е. тут гонка ок?
AI
Проблема не в lateinit
AN
Т.е. тут гонка ок?
Две