xyz.cofe.cxconsole.cp

Class AbstractCLEntry

java.lang.Object

xyz.cofe.cxconsole.cp.AbstractCLEntry

All Implemented Interfaces:

SetSync, ScnChanged<AbstractCLEntry,Long>

Direct Known Subclasses:

FileEntry, UrlEntry

public class AbstractCLEntry
extends Object
implements ScnChanged<AbstractCLEntry,Long>, SetSync

Путь к классам в ClassLoader

Author:

georgiy

Field Summary

Fields

Modifier and Type	Field and Description
protected String	label Указывает отображаемую метку
protected LongScnChangedSupport<AbstractCLEntry>	scnChangedSupport Поддержка SCN номеров
protected Object	sync Объект для синхронизации

Constructor Summary

Constructors

Constructor and Description
AbstractCLEntry() Конструктор по умолчанию
AbstractCLEntry(AbstractCLEntry sample) Конструктор копирования

Method Summary

Modifier and Type	Method and Description
void	addScnChangedEvent(ScnChangedEvent<AbstractCLEntry,Long> ev) Добавляет уведомление в очередь
Closeable	addScnChangedListener(ScnChanedListener<AbstractCLEntry,Long> listener) Добавляет подписчика на изменения
Closeable	addScnChangedListener(ScnChanedListener<AbstractCLEntry,Long> listener, boolean weakLink) Добавляет подписчика на изменения
Object	compareAndSetSync(Object cmp, Object newSyncObj) Указывает объект для синхронизации, если текущее значение совпадает с указанным
void	fireScnChanged(Long old, Long cur) Уведомляет подписчиков о измении SCN минуя очередь уведомлений
void	fireScnChangedEvent(ScnChangedEvent<AbstractCLEntry,Long> event)
void	fireScnChangedEvents() Рассылает уведомления из очереди
String	getLabel() Указывает отображаемую метку
ConcurrentLinkedQueue<ScnChangedEvent<AbstractCLEntry,Long>>	getScnChangedEventQueue() Возвращает очередь уведомлений
Set<ScnChanedListener<AbstractCLEntry,Long>>	getScnChangedListeners() Возвращает активных подписчиков
Object	getSync() Возвращает объект синхроназции
boolean	hasScnChangedListener(ScnChanedListener<AbstractCLEntry,Long> listener) Проверяет что указанный подписчик имеется в списках рассылки
Pair<Long,Long>	nextscn() Генерирует новый номер SCN.
Pair<Long,Long>	nextscn(boolean addEvent, boolean fireEvent) Генерирует новый номер SCN
void	removeAllScnChangedListeners() Удаляет всех подписчиков
void	removeScnChangedListener(ScnChanedListener<AbstractCLEntry,Long> listener) Удаляет подписчика от уведомлений
Long	scn() Возвращает текущий номер изменений
void	setLabel(String path) Указывает отображаемую метку Если указан sync объект, то он используется в блоке synchronized()
void	setSync(Object sync) Указывает объект для синхронизации

Methods inherited from class java.lang.Object

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

Field Detail

scnChangedSupport

protected final LongScnChangedSupport<AbstractCLEntry> scnChangedSupport

Поддержка SCN номеров

sync

protected volatile Object sync

Объект для синхронизации

label

protected String label

Указывает отображаемую метку

Constructor Detail

AbstractCLEntry

public AbstractCLEntry()

Конструктор по умолчанию

AbstractCLEntry

public AbstractCLEntry(AbstractCLEntry sample)

Конструктор копирования

Parameters:

sample - образец для копирования

Method Detail

scn

public Long scn()

Description copied from interface: ScnChanged

Возвращает текущий номер изменений

Specified by:

scn in interface ScnChanged<AbstractCLEntry,Long>

Returns:

текущий номер изменения

nextscn

public Pair<Long,Long> nextscn(boolean addEvent,
                               boolean fireEvent)

Генерирует новый номер SCN

Parameters:

addEvent - true - добавляет извещение в очередь

fireEvent - true - рассылает накопленные собщения из очереди

Returns:

Предыдущий и текущий номер SCN

nextscn

public Pair<Long,Long> nextscn()

Генерирует новый номер SCN.

Если уровень вложенности scn( Runnable ) - нулевой (нет вложенных блоков), то рассылает накопленные собщения из очереди.

Если уровень вложенности scn( Runnable ) - больше нуля, то просто добавляет извещения в очередь.

Returns:

Предыдущий и текущий номер SCN

hasScnChangedListener

public boolean hasScnChangedListener(ScnChanedListener<AbstractCLEntry,Long> listener)

Description copied from interface: ScnChanged

Проверяет что указанный подписчик имеется в списках рассылки

Specified by:

hasScnChangedListener in interface ScnChanged<AbstractCLEntry,Long>

Parameters:

listener - подписчик

Returns:

true - подписчик имеется в списках рассылки

getScnChangedListeners

public Set<ScnChanedListener<AbstractCLEntry,Long>> getScnChangedListeners()

Description copied from interface: ScnChanged

Возвращает активных подписчиков

Specified by:

getScnChangedListeners in interface ScnChanged<AbstractCLEntry,Long>

Returns:

подписчики

addScnChangedListener

public Closeable addScnChangedListener(ScnChanedListener<AbstractCLEntry,Long> listener)

Description copied from interface: ScnChanged

Добавляет подписчика на изменения

Specified by:

addScnChangedListener in interface ScnChanged<AbstractCLEntry,Long>

Parameters:

listener - подписчик

Returns:

Интерфейс отписки от уведомлений

addScnChangedListener

public Closeable addScnChangedListener(ScnChanedListener<AbstractCLEntry,Long> listener,
                                       boolean weakLink)

Description copied from interface: ScnChanged

Добавляет подписчика на изменения

Specified by:

addScnChangedListener in interface ScnChanged<AbstractCLEntry,Long>

Parameters:

listener - подписчик

weakLink - true - добавить подписчика на weak ссылку / false - как hard ссылку

Returns:

Интерфейс отписки от уведомлений

removeScnChangedListener

public void removeScnChangedListener(ScnChanedListener<AbstractCLEntry,Long> listener)

Description copied from interface: ScnChanged

Удаляет подписчика от уведомлений

Specified by:

removeScnChangedListener in interface ScnChanged<AbstractCLEntry,Long>

Parameters:

listener - подписчик

removeAllScnChangedListeners

public void removeAllScnChangedListeners()

Description copied from interface: ScnChanged

Удаляет всех подписчиков

Specified by:

removeAllScnChangedListeners in interface ScnChanged<AbstractCLEntry,Long>

fireScnChangedEvent

public void fireScnChangedEvent(ScnChangedEvent<AbstractCLEntry,Long> event)

getScnChangedEventQueue

public ConcurrentLinkedQueue<ScnChangedEvent<AbstractCLEntry,Long>> getScnChangedEventQueue()

Возвращает очередь уведомлений

Returns:

Очередь уведомлений

addScnChangedEvent

public void addScnChangedEvent(ScnChangedEvent<AbstractCLEntry,Long> ev)

Добавляет уведомление в очередь

Parameters:

ev - уведомление

fireScnChangedEvents

public void fireScnChangedEvents()

Рассылает уведомления из очереди

fireScnChanged

public void fireScnChanged(Long old,
                           Long cur)

Уведомляет подписчиков о измении SCN минуя очередь уведомлений

Parameters:

old - предыдущее значение SCN

cur - текущее значение SCN

setSync

public void setSync(Object sync)

Указывает объект для синхронизации

Specified by:

setSync in interface SetSync

Parameters:

sync - объект синхронизации

compareAndSetSync

public Object compareAndSetSync(Object cmp,
                                Object newSyncObj)

Указывает объект для синхронизации, если текущее значение совпадает с указанным

Specified by:

compareAndSetSync in interface SetSync

Parameters:

cmp - Объект для сравнения

newSyncObj - новый объект синхронизации, если cmp совпадает с текущим значением

Returns:

Установленное/текущее значение

getSync

public Object getSync()

Возвращает объект синхроназции

Specified by:

getSync in interface SetSync

Returns:

объект синхронизации

getLabel

public String getLabel()

Указывает отображаемую метку

Returns:

метка

setLabel

public void setLabel(String path)

Указывает отображаемую метку Если указан sync объект, то он используется в блоке synchronized()

Parameters:

path - метка