Как правильно работать с CopyOnWriteArrayList?

Question

[furyon]

Добрый день!

Задача
Допустим, есть web-страничка на которой пользователи делают действия. История действий записывается в переменную типа CopyOnWriteArrayList. Как только величина массива достигает 10-ти, мне нужно сохранить данные в БД.
Вопрос в том, как это правильно реализовать в условиях многопоточности. Я сделал так (но на это больно смотреть):

private val syncMinLimit = 10
private val userActions = CopyOnWriteArrayList<UserAction>()

fun addAction (action: UserAction) {
    userActions.add(action)

    // Условие перед synchronized чтобы постоянно не блокировать поток
    if (userActions.size >= syncMinLimit) {
        synchronized(userActions) {
            // Еще раз это условие, т.к. перед synchronized могла выстроиться очередь пока выполнялся код ниже
            if (userActions.size >= syncMinLimit) {
                val iterator = userActions.iterator()
                val removed = mutableListOf<UserAction>()
                while (iterator.hasNext())
                    removed.add(iterator.next())
                userActions.removeAll(removed)
                saveToDB(removed) // my function
            }
        }
    }
}

Comments

[Jacen11]

а почему не используете корутины? там же и в др потоке запуск этих дел можно запустить, или вообще мб сервис использовать стоит

[furyon]

Jacen11, если под сервисом понимать запуск скрипта через определенный промежуток времени, то проблема синхронизации остается, т.к. во время работы в переменную будут писаться события.

Что касается корутин, если вы знаете как это реализовать, я бы с удовольствием посмотрел.

[Jacen11]

furyon, вы в активити все делаете? когда приложение будет свернуто, оно может быть убито, и все ваши не сохраненные данные исчезнут. Вам нужно как то это обойти, сервис это компонент андроида, живет дольше.

по корутинам, мне нужно вникать, чтобы конкретную реализацию дать

Просто когда нужно что то сделать в др потоке в андроде используют корутины или rxJava. Там удобно переключать потоки.

[furyon]

Jacen11, Вы неправильно поняли, это не в приложении, это веб-сервер. В комментарии к ответу azerphoenix я подробнее описал суть.

[Jacen11]

furyon, да, вы правы, я неправильно вас понял, хотя все равно предлагаю сделать сохранение в др потоке, хотя бы средствами джавы

[furyon]

Jacen11, тем-же способом что и сделано в моем примере? Не вижу принципиальной разницы.

[furyon]

Bavashi, думаю Ваш пример будет работать прилично медленнее. Я сделаю тесты и отпишу о результатах.

[furyon]

Bavashi, на простом примере результаты схожие, позже попробую сделать тест близкий к условиям прода.

Answer 1

[Орхан Гасанлы]

Допустим, есть web-страничка на которой пользователи делают действия. История действий записывается в переменную типа CopyOnWriteArrayList

Не совсем вас понимаю, как именно история действий записывается в переменую CopyOnWriteArrayList? А самое главное - зачем?

Может быть есть смысл сделать следующее:
записывать историю действий в localStorage браузера пользователя (средствами JavaScript), а далее по исстечению определенного времени или по нажатию кнопки "Сохранить" или еще какого-либо другого триггера сохранить все в БД.

Comments

[furyon]

Дело в том, что пример гипотетический, для простоты, на деле у меня бекенд для API мобильного приложения. Делать запрос в бд для каждого действия - плохо ввиду особенностей БД (clickhouse).

как именно история действий записывается в переменую

Вызывается функция addAction() которая описана в примере, она же добавляет событие в CopyOnWriteArrayList и при необходимости отправляет в БД.