ReSQL.ru
     
powered by simpleCommunicator - 2.0.61     © 2026 Programmizd 02
Мобильная версия    Контакт    Правила    FAQ    Помощь
Целевая тема:
Создать новую тему:
Автор:
Закрыть
Цитировать
Доб. в избранное | Игнор. тему | Прикреп. тему | Пометить прочит. / непрочит. | Фильтр
Форумы / Java [игнор отключен] [закрыт для гостей] / Вопрос на понимание синхронизации
11 сообщений из 11, страница 1 из 1
Вопрос на понимание синхронизации
    #38082411
swerg
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
swerg
Гость
У меня есть синхронизация некого числа (long). Детали использования и область применения не важны.

Число надо увечивать и уменьшать на некие задаваемые значения и в случае креша сбрасывать в ноль.
Число должно быть синхронизировано.
Уменьшение/увеличение числа достигается через знак (пложителное/отрицаельное).
Плюс, есть константа ограничитель - при привышении кидаю эксепшен.
Понимаю, что кода под синхронайзд секцией должно быть меньше, но пока так.

Код: java
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
    private Object lockMonitor = new Object();
    private long mynumber = 0;

    private void change(long value) throws MaxExceededException {
        synchronized (lockMonitor) {
            if (value < 0) {
                mynumber += value;
            } else {
                if (mynumber + value< MAX_NUMBER) {
                    mynumber += value;
                } else {
                    throw new MaxStorageSizeExceededException("Limit.");
                }
            }
        }
    }

    private void clean() {
        synchronized (lockMonitor) {
                mynumber = 0;
        }
    }



Вопросы:
1. Будет ли работать синхронизаци для вторго блока (я думаю нет, но хочу понять почему)?
2. Может в этом случае использовать synchronized переменную?
3. Может надо применить другое решение? Плиз, пните мне в нужном направлении.
...
Рейтинг: 0 / 0
17.12.2012, 18:10:38
| Ответить | Цитировать | Написать  
Вопрос на понимание синхронизации
    #38082428
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
swerg1. Будет ли работать синхронизаци для вторго блока (я думаю нет, но хочу понять почему)?

Будет, только надо lockMonitor сделать final, чтобы никто другой монитор туда не записал.

swerg2. Может в этом случае использовать synchronized переменную?

Таких не бывает.

swerg3. Может надо применить другое решение? Плиз, пните мне в нужном направлении.
С точки зрения synchronized норм. Если в логику не вникать. А вообще, то есть AtomicLong и Lock.
...
Рейтинг: 0 / 0
17.12.2012, 18:23:55
| Ответить | Цитировать | Написать  
Вопрос на понимание синхронизации
    #38082436
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
Ещё стоит добавить volatile и синхронизировать чтение переменной. Тут бы ReadWriteLog и пригодился.
...
Рейтинг: 0 / 0
17.12.2012, 18:33:15
| Ответить | Цитировать | Написать  
Вопрос на понимание синхронизации
    #38082437
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
ReadWriteLock
...
Рейтинг: 0 / 0
17.12.2012, 18:33:29
| Ответить | Цитировать | Написать  
Вопрос на понимание синхронизации
    #38082451
swerg
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
swerg
Гость
Спасибо.

Ее походу читать вообще не надою Нужно лишь чекать превышение и тогда включать полную очистку.
...
Рейтинг: 0 / 0
17.12.2012, 18:44:16
| Ответить | Цитировать | Написать  
Вопрос на понимание синхронизации
    #38082460
забыл ник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
забыл ник
Участник
Самый идеальный вариант - унаследоваться от AbstractQueuedSynchronizer и переопределить tryAcquireShared(), но это advanced use-case. Можно посмотреть в стандартной библиотеке - например Semaphore, CountdownLatch реализованы по похожей схеме.

А так да - Lock и AtomicLong попроще будут, единственно надо будет дописать логику по очистке при переполнении.
...
Рейтинг: 0 / 0
17.12.2012, 18:52:12
| Ответить | Цитировать | Написать  
Вопрос на понимание синхронизации
    #38082468
swerg
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
swerg
Гость
Стоит ли еще туда же запихать ConcurrentHashMap (нуно для скорости - не надо обходить граф при удалении вершин, кроче детали). Или нуно искать другой подход.

Код: java
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
    private Object lockMonitor = new Object();
    private final ConcurrentMap<String, Long> sizes = new ConcurrentHashMap<String, Long>();
    private long mynumber = 0;

    private void change(String key, long value) throws MaxExceededException {
        synchronized (lockMonitor) {
            if (value < 0) {
                mynumber += value;
                if (sizes.exists(key)) {
                    sizes.set(sizes.get(key) + value);
                } // TODO: check negative value
            } else {
                if (mynumber + value< MAX_NUMBER) {
                    mynumber += value;
                    if (sizes.exists(key)) {
                         sizes.put(key, sizes.get(key) + value);
                    } else {
                         sizes.put(key, value);
                    }
                } else {
                    throw new MaxStorageSizeExceededException("Limit.");
                }
            }
        }
    }

    private void clean() {
        synchronized (lockMonitor) {
                mynumber = 0;
                sizes.clean();
        }
    }
...
Рейтинг: 0 / 0
17.12.2012, 18:54:50
| Ответить | Цитировать | Написать  
Вопрос на понимание синхронизации
    #38082471
забыл ник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
забыл ник
Участник
swergСтоит ли еще туда же запихать ConcurrentHashMap (нуно для скорости - не надо обходить граф при удалении вершин, кроче детали). Или нуно искать другой подход.

Код: java
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
    private Object lockMonitor = new Object();
    private final ConcurrentMap<String, Long> sizes = new ConcurrentHashMap<String, Long>();
    private long mynumber = 0;

    private void change(String key, long value) throws MaxExceededException {
        synchronized (lockMonitor) {
            if (value < 0) {
                mynumber += value;
                if (sizes.exists(key)) {
                    sizes.set(sizes.get(key) + value);
                } // TODO: check negative value
            } else {
                if (mynumber + value< MAX_NUMBER) {
                    mynumber += value;
                    if (sizes.exists(key)) {
                         sizes.put(key, sizes.get(key) + value);
                    } else {
                         sizes.put(key, value);
                    }
                } else {
                    throw new MaxStorageSizeExceededException("Limit.");
                }
            }
        }
    }

    private void clean() {
        synchronized (lockMonitor) {
                mynumber = 0;
                sizes.clean();
        }
    }



Тут не имеет особого смысла использовать ConcurrentMap для скорости - ибо боттлнек у вас в любом случае - это монитор. Тут хоть какая мапа - по барабану.
Ну и оффтоп - если уж используете ConcurrentMap, то у него есть метод putIfAbsent вместо exists()
...
Рейтинг: 0 / 0
17.12.2012, 18:59:26
| Ответить | Цитировать | Написать  
Вопрос на понимание синхронизации
    #38082477
забыл ник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
забыл ник
Участник
Да и смысла в первом if я вообще не вижу, вы экономите на спичках, предполагаю что значение у вас будут чаще положительные чем ортицательные, да и якобы экономию на проверке mynumber + value< MAX_NUMBER - вы просто напросто теряете такой же проверкой вначале - if (value < 0), так что смысла в if вообще нет
...
Рейтинг: 0 / 0
17.12.2012, 19:03:10
| Ответить | Цитировать | Написать  
Вопрос на понимание синхронизации
    #38082487
забыл ник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
забыл ник
Участник
ну и напоследок, я как параноик сделал бы или весь класс final или метод change
...
Рейтинг: 0 / 0
17.12.2012, 19:08:00
| Ответить | Цитировать | Написать  
Вопрос на понимание синхронизации
    #38082512
swerg
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
swerg
Гость
забыл ник,
вы правы накапливание будет только положительных значений. Как только вершина графа будет удаляться, я буду получать из мапа размер всех чайлдов (и буду вычитать из mynumber). Мне не надо будет их обходить; взять размер чайлда очень дрогостоящая операция.

Типа что-то такого:

Код: java
1.
2.
3.
4.
5.
6.
7.
8.
9.
    private void deleteTopItem(String key) {
        synchronized (lockMonitor) {
           Long topItemSize = sizes.get(key);
           if (topItemSize != null) { // check if it's already deleted
                 mynumber -= 
                 sizes.remove(key);
           }
        }
    }
...
Рейтинг: 0 / 0
17.12.2012, 19:24:31
| Ответить | Цитировать | Написать  
11 сообщений из 11, страница 1 из 1
Форумы / Java [игнор отключен] [закрыт для гостей] / Вопрос на понимание синхронизации
Найденые пользователи ...
Разблокировать пользователей ...
Читали тему (0):
Читали форум (0):
Пользователи онлайн (0):
Польз. соглашение   Полит. конфиден.  
NoSQL.ru       Кролег: Проекты, Новости, Чат       РЕД ФОРУМ       Фотоальбом: Участники, Встречи
Закрыть
start [/forum/topic.php?fid=59&gotonew=1&tid=2130344]:
 0ms
get settings:
 22ms
get forum list:
 30ms
check forum access:
 8ms
check topic access:
 8ms
track hit:
 52ms
get topic data:
 25ms
get first new msg:
 16ms
get forum data:
 6ms
get page messages:
 110ms
get tp. blocked users:
 3ms
others: 337ms
total:  617ms
созд. / загр.: 617ms
x
x
Закрыть


Просмотр
0 / 0
Close
Debug Console [Select Text]