ReSQL.ru
     
powered by simpleCommunicator - 2.0.61     © 2026 Programmizd 02
Мобильная версия    Контакт    Правила    FAQ    Помощь
Целевая тема:
Создать новую тему:
Автор:
Закрыть
Цитировать
Доб. в избранное | Игнор. тему | Прикреп. тему | Пометить прочит. / непрочит. | Фильтр
Форумы / Java [игнор отключен] [закрыт для гостей] / ConcurrentHashMap и List
33 сообщений из 33, показаны все 2 страниц
  все  
ConcurrentHashMap и List
    #38491191
GorloPavel
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
GorloPavel
Участник
Здравствуйте. Такое дело.
Код: java
1.
public static ConcurrentHashMap<Integer,Session> USER_SESSIONS...


В этом HashMap-e находятся некие сессии где ключ это ID пользователя. Когда пользователь отключается сессия удаляется.
Код: java
1.
USER_SESSIONS.remove(mUserId);


Все отлично работает. Но как быть если в системе разрешено быть авторизированным двум сессиям с одним и тем же ID пользователя? Ну то есть грубо говоря на двух ПК в сидят под одной и той же учеткой, но при этом сессии разные.
Пробовал сделать так:
Код: 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.
33.
34.
35.
ConcurrentHashMap<Integer,List<Session>> USER_SESSIONS....

......................

private void addUser(Session session){
   List<Session> userSessions = Server.USER_SESSIONS.get(session.mUserId);
   
   if(userSessions==null){
       userSessions = new List<Session>();
       userSessions.add(session);
       Server.USER_SESSIONS.put(session.getUserId(),userSessions);
   }else{
       userSessions.add(session);
   }
}

private void removeUser(Session session){
   List<Session> userSessions = Server.USER_SESSIONS.get(session.mUserId);
   
   if(userSessions==null){
        userSessions.remove(session);
        if(userSessions.size()==0)
        {
            Server.USER_SESSIONS.remove(session.getUserId());
        }
   }
}

.....................
private void workWithUsers(int userId){
     for(Session session : Server.USER_SESSIONS.get(userId))
    {
         <какие-то действия>
    }
}



Естественно все эти методы могут вызываться из разных потоков, и я получаю ошибки связанные с List<Session>. И это естественно, потому что пока я foreach-у список сессия может быть удалена методом removeUser из другого потока. Как быть? Как сделать так что-бы при работе со списком List<Session> все потоки ждали пока занимающий его поток не закончит с ним работу? Пока сделал так :)
Код: java
1.
public static ConcurrentHashMap<Integer,ConcurrentHashMap<Session,Session>> USER_SESSIONS


Так как ConcurrentHashMap потокобезопасен. Но мне кажется это кривое решение. Заранее огромное спасибо за помощь!

P.S: JRE 1. 6
...
Рейтинг: 0 / 0
06.12.2013, 05:20
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38491224
GorloPavel
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
GorloPavel
Участник
Как я понял CopyOnWriteList мне не подходит. Ведь при каждом изменении производится копирование массива и потом подменяется ссылка. Но что будет если в момент удаления произойдет добавление? Или я что-то не понимаю. Просто попробовал использовать CopyOnWriteList и сразу сильно возрасло потребление памяти и оно постоянно растет.
...
Рейтинг: 0 / 0
06.12.2013, 07:59
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38491272
am_sasa
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
am_sasa
Гость
GorloPavel,

не понятно зачем HashMap - id usera дублируется, он же в сессии есть, может HashSet хватит?
у меня так
Код: java
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
 public void addSession(HttpSession s) {
            this.sessions.add(s);
            s.setAttribute(SessionBug.class.getName(), new SessionBug());
        }

        public void removeSession(HttpSession s) {
            this.sessions.remove(s);
        }

        public Collection<HttpSession> getSessions(){
           return Collections.unmodifiableCollection(this.sessions);
        }


вот это должно помочь Collections.unmodifiableCollection(USER_SESSIONS)
...
Рейтинг: 0 / 0
06.12.2013, 09:21
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38491282
cdtyjv
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
cdtyjv
Участник
am_sasaвот это должно помочь Collections.unmodifiableCollection(USER_SESSIONS) Это никак не может помочь пользователю, так как ему необходимо эту коллекцию изменять, а unmodifiableCollection запрещает удаление.
...
Рейтинг: 0 / 0
06.12.2013, 09:28
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38491289
cdtyjv
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
cdtyjv
Участник
GorloPavel ,
CopyOnWriteArrayList - нормальное решение, когда у вас много чтений, но мало записей. Память у вас течет из-за бага где-то у вас, а не из-за на него.
Если CopyOnWriteArrayList не устраивает, то используйте другую коллекцию из java.util.concurrent, коих очень много - Set, Queue, Deque - в зависимости от того, что вам больше подходит.
...
Рейтинг: 0 / 0
06.12.2013, 09:32
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38491301
am_sasa
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
am_sasa
Гость
cdtyjv,

в каком месте удаление?
Код: java
1.
2.
3.
4.
5.
6.
private void workWithUsers(int userId){
     for(Session session : Server.USER_SESSIONS.get(userId))
    {
         <какие-то действия>
    }
}
...
Рейтинг: 0 / 0
06.12.2013, 09:42
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38491332
cdtyjv
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
cdtyjv
Участник
am_sasa ,
Ну вы проблему автора читали? :-) Ему нужно конкурентно обновлять коллекцию. А вы ему на это отвечаете: "Вам должен помочь Collections.unmodifiableList". Вопрос: как он ему поможет?
Collections.unmodifiable* полезены только в двух случаях:
1) Это публичный API, которым будет пользоваться хрен знает кто.
2) Это не публичный API, но разработчик все равно хочет перестраховаться, использую unmodifiableList в качестве своеобразного assert.

К проблема конкуретного доступа к коллекциям Collections.unmodifiable* отношения вообще не имеет.
...
Рейтинг: 0 / 0
06.12.2013, 10:00
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38491447
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
Если нужно разрашить множественные сессии под одним аккаунтом, то нужно максимально везде заменить userId на sessionId:
Map<SessionId, Session>
А для каждой операции с userId, нужно хорошенько подумать, почему там нужен именно userId, а не sessionId. И свести такие операции к минимуму. Ведь юзер работает в двух РАЗНЫХ сессиях и он не ожидает что в обоих сессиях будет идентичное состояние, только потому что внутри всё равно всё привязано к userId.
...
Рейтинг: 0 / 0
06.12.2013, 11:25
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38491756
GorloPavel
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
GorloPavel
Участник
Может мне кто-нибудь объяснить? Как я понимаю в этом случае remove и add потокобезопасны? Т.е если какой-то поток добавляет что-то в лист, то поток который хочет удалить будет ожидать завершения удаления и наоборот? А чтобы синхронизировать и перебор(все ждут пока идет перебор) нужно делать так?
Код: java
1.
2.
3.
4.
5.
6.
7.
Collection c = Collections.synchronizedCollection(myCollection);
     ...
  synchronized(c) {
      Iterator i = c.iterator(); // Must be in the synchronized block
      while (i.hasNext())
         foo(i.next());
  }
...
Рейтинг: 0 / 0
06.12.2013, 13:58
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38491759
GorloPavel
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
GorloPavel
Участник
BlazkowiczЕсли нужно разрашить множественные сессии под одним аккаунтом, то нужно максимально везде заменить userId на sessionId:
Map<SessionId, Session>
А для каждой операции с userId, нужно хорошенько подумать, почему там нужен именно userId, а не sessionId. И свести такие операции к минимуму. Ведь юзер работает в двух РАЗНЫХ сессиях и он не ожидает что в обоих сессиях будет идентичное состояние, только потому что внутри всё равно всё привязано к userId.
К моему приложению это не подходит. Мне нужно именно синхронно редактировать или читать список.
...
Рейтинг: 0 / 0
06.12.2013, 14:00
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38491883
GorloPavel
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
GorloPavel
Участник
cdtyjv GorloPavel ,
CopyOnWriteArrayList - нормальное решение, когда у вас много чтений, но мало записей. Память у вас течет из-за бага где-то у вас, а не из-за на него.
Да нет бага. Просто заменяю на
Код: java
1.
public static ConcurrentHashMap<Integer,ConcurrentHashMap<Session,Session>> USER_SESSIONS


и памяти на 15-20% меньше жрет приложение.
...
Рейтинг: 0 / 0
06.12.2013, 14:51
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38491885
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
CopyOnWriteArrayList очень агресивно использует память, что, как бы, следует из его названия и принципа работы.
...
Рейтинг: 0 / 0
06.12.2013, 14:53
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38491947
Фотография Petro123
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Petro123
Участник
GorloPavelBlazkowiczЕсли нужно разрашить множественные сессии под одним аккаунтом, то нужно максимально везде заменить userId на sessionId:
Map<SessionId, Session>
А для каждой операции с userId, нужно хорошенько подумать, почему там нужен именно userId, а не sessionId. И свести такие операции к минимуму. Ведь юзер работает в двух РАЗНЫХ сессиях и он не ожидает что в обоих сессиях будет идентичное состояние, только потому что внутри всё равно всё привязано к userId.
К моему приложению это не подходит. Мне нужно именно синхронно редактировать или читать список.
не очень понял ответ Blazkowicz'у.
Разве 2 пользователя под одним именем но на разных компах не A синхронно работают?
...
Рейтинг: 0 / 0
06.12.2013, 15:25
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38491968
GorloPavel
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
GorloPavel
Участник
Petro123GorloPavelпропущено...
К моему приложению это не подходит. Мне нужно именно синхронно редактировать или читать список.
не очень понял ответ Blazkowicz'у.
Разве 2 пользователя под одним именем но на разных компах не A синхронно работают?

Асинхронно. Но сервер с списком сессий должен работать синхронно. Долго объяснять. Вообщем мне не подходит это решение. Я уже думал над этим. Пожалуйста прокомментируйте это сообщение 15252928
...
Рейтинг: 0 / 0
06.12.2013, 15:38
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38491990
Фотография Petro123
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Petro123
Участник
GorloPavel,
не очень понял, зачем бегать по списку в конкурентном окружении?
...
Рейтинг: 0 / 0
06.12.2013, 15:53
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38491993
Фотография Petro123
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Petro123
Участник
GorloPavel,
и приведи конкретный код с ошибкой минимальный
...
Рейтинг: 0 / 0
06.12.2013, 15:54
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38491999
GorloPavel
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
GorloPavel
Участник
Petro123GorloPavel,
и приведи конкретный код с ошибкой минимальный
Ну как же. А если во время foreach другой поток удалит из списка элемент? Пользователь отключается, а в этот момент сервер пробегает по списку и рассылает пользователям под этой учеткой "ПРИВЕТ ТОВАРИЩ!" :)
...
Рейтинг: 0 / 0
06.12.2013, 15:59
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38492017
забыл ник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
забыл ник
Участник
GorloPavelPetro123GorloPavel,
и приведи конкретный код с ошибкой минимальный
Ну как же. А если во время foreach другой поток удалит из списка элемент? Пользователь отключается, а в этот момент сервер пробегает по списку и рассылает пользователям под этой учеткой "ПРИВЕТ ТОВАРИЩ!" :)

Так не критично же? Ну а что вас спасет если вы успели пробежать по циклу, но клиент отосединился как раз когда вы посылаете сообщение? Выдуманно как-то смотрится проблема.
...
Рейтинг: 0 / 0
06.12.2013, 16:08
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38492026
Фотография Petro123
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Petro123
Участник
забыл ник,
+1
...
Рейтинг: 0 / 0
06.12.2013, 16:13
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38492067
GorloPavel
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
GorloPavel
Участник
забыл никGorloPavelпропущено...

Ну как же. А если во время foreach другой поток удалит из списка элемент? Пользователь отключается, а в этот момент сервер пробегает по списку и рассылает пользователям под этой учеткой "ПРИВЕТ ТОВАРИЩ!" :)

Так не критично же? Ну а что вас спасет если вы успели пробежать по циклу, но клиент отосединился как раз когда вы посылаете сообщение? Выдуманно как-то смотрится проблема.
А null pointer exception? Ну и вообще изменилась же коллекция, а я тут форичу. Вообщем с CopyOnWriteArrayList работает, но жрет память. С
Код: java
1.
public static ConcurrentHashMap<Integer,ConcurrentHashMap<Session,Session>> USER_SESSIONS

вообще все отлично и памяти навалом и работает хорошо. Вот как-нибудь сделать такой же список.
...
Рейтинг: 0 / 0
06.12.2013, 16:37
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38492070
GorloPavel
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
GorloPavel
Участник
Последний вариант мне кажется кривым, но он замечательно работает.
...
Рейтинг: 0 / 0
06.12.2013, 16:38
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38492072
GorloPavel
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
GorloPavel
Участник
Попробовал так
Код: java
1.
Collections.synchronizedCollection

- вообще все повисло в какой-то момент, видимо где-то дедлочит.
...
Рейтинг: 0 / 0
06.12.2013, 16:39
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38492076
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
GorloPavelПопробовал так
Код: java
1.
Collections.synchronizedCollection

- вообще все повисло в какой-то момент, видимо где-то дедлочит.
Использование synchronized в многопоточных приложениях это не только потенциальные взаимоблокировки но и удар по производительности системы в целом. Особено учитывая тот факт что это у вас центральное состояние всех пользователей.
...
Рейтинг: 0 / 0
06.12.2013, 16:43
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38492082
Фотография Petro123
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Petro123
Участник
GorloPavelдедлочит
OFF
осталось взять Оракл - неблокировочник))))
...
Рейтинг: 0 / 0
06.12.2013, 16:46
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38492086
Фотография Petro123
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Petro123
Участник
GorloPavelа я тут форичу
зачем?
Сделай список по уникальному ключику
...
Рейтинг: 0 / 0
06.12.2013, 16:47
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38492115
Фотография Petro123
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Petro123
Участник
ммммм.
центральный список польз. должен быть синхронным.
Т.е. при закрытии сессии нужно убрать из списка.
Обычное дело для списка респондентов в операционке или ГУИ-контролах при перерисовке.
Добавив проверки на висяки получим решение.
...
Рейтинг: 0 / 0
06.12.2013, 17:02
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38492139
GorloPavel
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
GorloPavel
Участник
Petro123ммммм.
центральный список польз. должен быть синхронным.
Т.е. при закрытии сессии нужно убрать из списка.
Обычное дело для списка респондентов в операционке или ГУИ-контролах при перерисовке.
Добавив проверки на висяки получим решение.

Не понял вас. У меня значением Hash таблицы является список. Он должен быть синхронизирован. С этим списком могут работать N потоков. Один из потоков может читать, другой писать, третий удалять. И все это может происходить "одновременно". Пользователь отключился - сессия удалилась из списка. Список стал "нулевым", т.е сессий с данным аккаунтом уже нет - удалился сам список из хэш таблицы. Вопрос как синхронизировать список внутри хэш таблицы? Пока остановился на CopyOnWriteArrayList. Но хочется чего-то подобного ConcurrentHashMap но только для списка, ведь с ним тоже в программе работает много потоков, и читают и удаляют, добавляют. И никаких с ним проблем.
...
Рейтинг: 0 / 0
06.12.2013, 17:17
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38492171
cdtyjv
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
cdtyjv
Участник
GorloPavelМожет мне кто-нибудь объяснить? Как я понимаю в этом случае remove и add потокобезопасны? Т.е если какой-то поток добавляет что-то в лист, то поток который хочет удалить будет ожидать завершения удаления и наоборот? А чтобы синхронизировать и перебор(все ждут пока идет перебор) нужно делать так?
Код: java
1.
2.
3.
4.
5.
6.
7.
Collection c = Collections.synchronizedCollection(myCollection);
     ...
  synchronized(c) {
      Iterator i = c.iterator(); // Must be in the synchronized block
      while (i.hasNext())
         foo(i.next());
  }

Нет. Потоко безопасность не распространяется на составные операции, как то "взять элемент из итератора, а потом его удалить".
С точки зрения итерирования synchronizedCollection никак вам не поможет.
...
Рейтинг: 0 / 0
06.12.2013, 17:36
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38492181
Фотография Petro123
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Petro123
Участник
GorloPavel,
не нужно делать Один ко многим из списков.
Если убрать слово поток и заменить его на UserID+SessionID как ключик списка.
То, параллельно работают 3 юзверя в списке из 3-х элементов.
В чём проблема и где тут Null ошибка?
ЗЫ
SessionID - ключик в списке?
...
Рейтинг: 0 / 0
06.12.2013, 17:39
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38492193
GorloPavel
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
GorloPavel
Участник
cdtyjvС точки зрения итерирования synchronizedCollection никак вам не поможет.
В CopyOnWriteArrayList мое спасение? :) Правда памяти жрет не мало :(
...
Рейтинг: 0 / 0
06.12.2013, 17:42
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38492194
cdtyjv
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
cdtyjv
Участник
GorloPavel,
Коллега, ну вам же дали уже ответ, что вы продолжаете упорствовать со своими сомнениями? ПО вашим требованиям, вам нужна конкуретнтая мапка, в которой будет сидеть конкурентная коллекция. Ну так и делайте это, ничего кривого в этом нет:
ConcurrentHashMap<Integer, CopyOnWriteArrayList<Session>>
ConcurrentHashMap<Integer, ConcurrentArrayQueue<Session>>
ConcurrentHashMap<Integer, ConcurrentLinkedQueue<Session>>
ConcurrentHashMap<Integer, ConcurrentLinkedDeque<Session>>

Громоздко не значит "криво".
...
Рейтинг: 0 / 0
06.12.2013, 17:43
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38739910
D01
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
D01
Гость
List<Session> userSessions = Server.USER_SESSIONS.get(session.mUserId);
synchronized (userSessions) {
///Все операции с userSessions
}

разве это не ответ на вопрос?
...
Рейтинг: 0 / 0
07.09.2014, 20:03
| Ответить | Цитировать | Написать  
ConcurrentHashMap и List
    #38742278
scf
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
scf
Участник
Я думаю, топикстартеру надо вооооот это:
http://docs.guava-libraries.googlecode.com/git/javadoc/com/google/common/collect/ConcurrentHashMultiset.html
...
Рейтинг: 0 / 0
09.09.2014, 23:08
| Ответить | Цитировать | Написать  
33 сообщений из 33, показаны все 2 страниц
  все  
Форумы / Java [игнор отключен] [закрыт для гостей] / ConcurrentHashMap и List
Найденые пользователи ...
Разблокировать пользователей ...
Читали тему (0):
Читали форум (0):
Пользователи онлайн (0):
Польз. соглашение   Полит. конфиден.  
NoSQL.ru       Кролег: Проекты, Новости, Чат       РЕД ФОРУМ       Фотоальбом: Участники, Встречи
Закрыть
start [/forum/topic.php?all=1&fid=59&tid=2126626]:
 0ms
get settings:
 7ms
get forum list:
 12ms
check forum access:
 3ms
check topic access:
 3ms
track hit:
 166ms
get topic data:
 9ms
get forum data:
 2ms
get page messages:
 55ms
get tp. blocked users:
 1ms
others: 207ms
total:  465ms
созд. / загр.: 465ms
x
x
Закрыть


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