М
Здравствуйте. Не подскажете возможно ли через корутины сделать так, чтобы потребители, которые приходят с одной и той же задачей, не создавали новую задачу, а подключались к ответу старой?
Каналы можно посмотреть
Size: a a a
2020 January 10
NK
Каналы можно посмотреть
Выглядит слишком сложно, легче по старинке сделать
М
Ну если сохранять ссылку на deffered надо какой нибудь atomic reference юзать
NK
Ну если сохранять ссылку на deffered надо какой нибудь atomic reference юзать
Достаточно synchronize(this)
М
недавно обсуждали вроде, но не помню к чему пришли, как правильнее сделать чтобы async не ложил джобу до вызова await?
А мне ктонибудь подскажет?) Вижу два варика, кинуть в скоуп асинк Job(), завернуть асинк в coroutineScope {} . Мб еще есть варики покрасивее?
AM
Достаточно synchronize(this)
Это очень плохой совет при использовании корутин.
QH
Достаточно synchronize(this)
синхронизироваться надо на каждое чтение, а вот атомик/волатайл можно читать откуда угодно
AM
Наиболее близким аналогом для корутин будет местный мьютекс.
NK
Это очень плохой совет при использовании корутин.
if(deffer != null) {
synchronize (this){
if(deffer != null){
deffer = get()
synchronize (this){
if(deffer != null){
deffer = get()
NK
Что тут плохого?
NK
синхронизироваться надо на каждое чтение, а вот атомик/волатайл можно читать откуда угодно
Ну и + volatile на ссылку, да, спасибо
QH
омагад, что я натворил
QH
if(deffer != null) {
synchronize (this){
if(deffer != null){
deffer = get()
synchronize (this){
if(deffer != null){
deffer = get()
ненавижу читать такое
NK
if(deffer != null) {
synchronize (this){
if(deffer != null){
deffer = get()
synchronize (this){
if(deffer != null){
deffer = get()
Хотя в таком случае volatile не нужен
NK
ненавижу читать такое
А как лучше, не посоветуешь?
QH
А как лучше, не посоветуешь?
мне нравится
AtomicReference<Deferred>NK
мне нравится
AtomicReference<Deferred>Кажется, от блока выше всеравно никуда не деться
QH
Кажется, от блока выше всеравно никуда не деться
А нельзя создать пустой Deferred, как с CF?
NK
А нельзя создать пустой Deferred, как с CF?
Не понял. А что потом с ним делать
QH
var d: Deferredif (ref.get().also { d = it } == null && ref.cas(null, Deferred().also { d = it })) {
запускаем задачу, которая присвоит внутрь d
} else {
return d.await()
}