VV
да вот не получается повторить так то получается просто экспериментировать на проде вылечилось или нет типа
Size: a a a
2020 November 20
VV
как минимум при текущей Вашей реализации рискуете нарваться на ConcurrentModificationException
ConcurrentHashMap используется
VV
удаляется по типу удали из стека если есть в нем, а если нет игнор
VL
ConcurrentHashMap при чтении дублируется, т.е. если в этот момент в него что-то добавить, то при чтении Вы не увидите что было что-то добавлено
VV
сразу после ответа запроса
VL
Я бы это как-то через синхронизацию рулил бы
VL
Но я не знаю Вашей архитектуры
VV
ConcurrentHashMap при чтении дублируется, т.е. если в этот момент в него что-то добавить, то при чтении Вы не увидите что было что-то добавлено
ухты
VV
вот это похоже на причину (при чтении дублируется)
VV
потому что все баги именно в рамках милисекунд
VL
Concurrent призван избавить Вас от проблем многопоточности в коллекциях, но никак не синхронизации)
VL
Сам им не пользуюсь, так как это потенциальный источник багов
VL
Тупо через mutexы делаю
VV
@Synchronized
override fun execute(act: Act) {
return when {
mapDisposable.contains(act.id) -> when (act.strategy) {
KillMe -> {
stop(act.id)
startExecution(act)
}
SaveMe -> log("${act.id} - Act duplicate")
}
else -> startExecution(act)
}
}
override fun execute(act: Act) {
return when {
mapDisposable.contains(act.id) -> when (act.strategy) {
KillMe -> {
stop(act.id)
startExecution(act)
}
SaveMe -> log("${act.id} - Act duplicate")
}
else -> startExecution(act)
}
}
VV
mapDisposable.contains дергается только в этом методе
VV
стратегия всегда SaveMe
VV
типа только в лог кидай
VV
если повтор
VL
startExecution, случаем, не асинхронный? если так, то Вы синхронизировали только запуск, а не выполнение
VV
startExecution асинхронный