xyz.cofe.collection.map

Class LockEventMap<Key,Value>

java.lang.Object

xyz.cofe.collection.map.MapWrapper<Key,Value>

xyz.cofe.collection.map.BasicEventMap<Key,Value>

xyz.cofe.collection.map.LockEventMap<Key,Value>

Type Parameters:

Key - Тип ключа

Value - Тип значения

All Implemented Interfaces:

Map<Key,Value>, EventMap<Key,Value>, EventMapSender<Key,Value>, GetListenersHelper

public class LockEventMap<Key,Value>
extends BasicEventMap<Key,Value>

Event map с поддержкой блокировки Lock

Author:

nt.gocha@gmail.com

Nested Class Summary

Nested classes/interfaces inherited from interface java.util.Map

Map.Entry<K,V>

Field Summary

Fields

Modifier and Type	Field and Description
protected AtomicInteger	lockLevel
protected Lock	lockRead
protected Lock	lockWrite
protected boolean	trackEventLevel

Fields inherited from class xyz.cofe.collection.map.BasicEventMap

clearMethod, containsKeyMethod, containsValueMethod, entrySetMethod, eventQueue, getMethod, getWrappedMapMethod, isEmptyMethod, keySetMethod, listeners, putMethod, setWrappedMapMethod, sizeMethod, valuesMethod

Constructor Summary

Constructors

Constructor and Description
LockEventMap()
LockEventMap(Map<Key,Value> wrappedMap)
LockEventMap(Map<Key,Value> wrappedMap, Lock lock)
LockEventMap(Map<Key,Value> wrappedMap, Lock lockRead, Lock lockWrite)

Method Summary

Modifier and Type	Method and Description
protected Lock	createLock() Создает блокировку ReentrantLock
protected void	fireQueueEvents() Выполняет уведомления из очереди с учетем блокировки
Lock	getLockRead() Возвращает блокировку на методы Map
Lock	getLockWrite() Возвращает блокировку на методы Map
boolean	isTrackEventLevel() Указывает отслеживать уровень блокировок для рассылки уведомлений.
protected Object	lockRun(Func0 run) Выполнение кода в блокировке
protected Object	lockRun(Func0 run, LockMethod method) Выполнение кода в блокировке
void	setLockRead(Lock lock) Устанваливает блокировку чтения
void	setLockWrite(Lock lock) Устанавливает блокировку записи
void	setTrackEventLevel(boolean trackEventLevel) Указывает отслеживать уровень блокировок для рассылки уведомлений.

Methods inherited from class xyz.cofe.collection.map.BasicEventMap

addEventMapListener, addEventMapListener, addEventToQueue, clear, containsEventMapListener, containsKey, containsValue, createDeleted, createInserted, createUpdated, entrySet, fireDeleted, fireEvent, fireInserted, fireUpdated, get, getListenersHelper, getListenersLock, getWrappedMap, isEmpty, keySet, listenObjectChanged, onChanged, onChanged, onDeleted, onDeleted, onInserted, onInserted, onUpdated, onUpdated, put, putAll, remove, removeEventMapListener, sendNewListOnNewWrapperMap, setWrappedMap, size, values

Methods inherited from class xyz.cofe.collection.map.MapWrapper

equals

Methods inherited from class java.lang.Object

clone, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.Map

compute, computeIfAbsent, computeIfPresent, equals, forEach, getOrDefault, hashCode, merge, putIfAbsent, remove, replace, replace, replaceAll

Field Detail

lockWrite

protected volatile Lock lockWrite

lockRead

protected volatile Lock lockRead

lockLevel

protected final AtomicInteger lockLevel

trackEventLevel

protected volatile boolean trackEventLevel

Constructor Detail

LockEventMap

public LockEventMap()

LockEventMap

public LockEventMap(Map<Key,Value> wrappedMap)

LockEventMap

public LockEventMap(Map<Key,Value> wrappedMap,
                    Lock lock)

LockEventMap

public LockEventMap(Map<Key,Value> wrappedMap,
                    Lock lockRead,
                    Lock lockWrite)

Method Detail

createLock

protected Lock createLock()

Создает блокировку ReentrantLock

Returns:

блокировка

getLockWrite

public Lock getLockWrite()

Возвращает блокировку на методы Map

Returns:

блокировка на методы map

setLockWrite

public void setLockWrite(Lock lock)

Устанавливает блокировку записи

Parameters:

lock - блокировка

getLockRead

public Lock getLockRead()

Возвращает блокировку на методы Map

Returns:

блокировка на методы map

setLockRead

public void setLockRead(Lock lock)

Устанваливает блокировку чтения

Parameters:

lock - блокировка

isTrackEventLevel

public boolean isTrackEventLevel()

Указывает отслеживать уровень блокировок для рассылки уведомлений.

Если указано отслеживать уровень блокировок, то сообщения будут рассылаться, только после того как блокировки будут сняты

Returns:

true - отслеживать

setTrackEventLevel

public void setTrackEventLevel(boolean trackEventLevel)

Указывает отслеживать уровень блокировок для рассылки уведомлений.

Parameters:

trackEventLevel - true - отслеживать

See Also:

isTrackEventLevel()

fireQueueEvents

protected void fireQueueEvents()

Description copied from class: BasicEventMap

Выполняет уведомления из очереди с учетем блокировки

Overrides:

fireQueueEvents in class BasicEventMap<Key,Value>

lockRun

protected Object lockRun(Func0 run,
                         LockMethod method)

Description copied from class: BasicEventMap

Выполнение кода в блокировке

Overrides:

lockRun in class BasicEventMap<Key,Value>

Parameters:

run - код

method - метод map для которого вызывается блокировка

Returns:

Результат функции

lockRun

protected Object lockRun(Func0 run)

Description copied from class: BasicEventMap

Выполнение кода в блокировке

Overrides:

lockRun in class BasicEventMap<Key,Value>

Parameters:

run - код-функция

Returns:

Результат функции