public abstract class ImportStatementAbstract extends Object implements ScnChanged<AbstractCLEntry,Long>, SetSync
| Modifier and Type | Field and Description |
|---|---|
protected LongScnChangedSupport<AbstractCLEntry> |
scnChangedSupport |
protected Object |
sync |
| Constructor and Description |
|---|
ImportStatementAbstract() |
| 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) |
void |
fireScnChangedEvent(ScnChangedEvent<AbstractCLEntry,Long> event) |
void |
fireScnChangedEvents() |
ConcurrentLinkedQueue<ScnChangedEvent<AbstractCLEntry,Long>> |
getScnChangedEventQueue() |
Set<ScnChanedListener<AbstractCLEntry,Long>> |
getScnChangedListeners()
Возвращает активных подписчиков
|
Object |
getSync()
Возвращает объект синхроназции
|
boolean |
hasScnChangedListener(ScnChanedListener<AbstractCLEntry,Long> listener)
Проверяет что указанный подписчик имеется в списках рассылки
|
Pair<Long,Long> |
nextscn() |
Pair<Long,Long> |
nextscn(boolean addEvent,
boolean fireEvent) |
void |
removeAllScnChangedListeners()
Удаляет всех подписчиков
|
void |
removeScnChangedListener(ScnChanedListener<AbstractCLEntry,Long> listener)
Удаляет подписчика от уведомлений
|
Long |
scn()
Возвращает текущий номер изменений
|
void |
setSync(Object sync)
Указывает объект для синхронизации
|
protected volatile Object sync
protected final LongScnChangedSupport<AbstractCLEntry> scnChangedSupport
public void setSync(Object sync)
SetSyncpublic Object compareAndSetSync(Object cmp, Object newSyncObj)
SetSynccompareAndSetSync in interface SetSynccmp - Объект для сравненияnewSyncObj - новый объект синхронизации, если cmp совпадает с текущим значениемpublic Object getSync()
SetSyncpublic Long scn()
ScnChangedscn in interface ScnChanged<AbstractCLEntry,Long>public boolean hasScnChangedListener(ScnChanedListener<AbstractCLEntry,Long> listener)
ScnChangedhasScnChangedListener in interface ScnChanged<AbstractCLEntry,Long>listener - подписчикpublic Set<ScnChanedListener<AbstractCLEntry,Long>> getScnChangedListeners()
ScnChangedgetScnChangedListeners in interface ScnChanged<AbstractCLEntry,Long>public Closeable addScnChangedListener(ScnChanedListener<AbstractCLEntry,Long> listener)
ScnChangedaddScnChangedListener in interface ScnChanged<AbstractCLEntry,Long>listener - подписчикpublic Closeable addScnChangedListener(ScnChanedListener<AbstractCLEntry,Long> listener, boolean weakLink)
ScnChangedaddScnChangedListener in interface ScnChanged<AbstractCLEntry,Long>listener - подписчикweakLink - true - добавить подписчика на weak ссылку / false - как hard ссылкуpublic void removeScnChangedListener(ScnChanedListener<AbstractCLEntry,Long> listener)
ScnChangedremoveScnChangedListener in interface ScnChanged<AbstractCLEntry,Long>listener - подписчикpublic void removeAllScnChangedListeners()
ScnChangedremoveAllScnChangedListeners in interface ScnChanged<AbstractCLEntry,Long>public void fireScnChangedEvent(ScnChangedEvent<AbstractCLEntry,Long> event)
public ConcurrentLinkedQueue<ScnChangedEvent<AbstractCLEntry,Long>> getScnChangedEventQueue()
public void addScnChangedEvent(ScnChangedEvent<AbstractCLEntry,Long> ev)
public void fireScnChangedEvents()
Copyright © 2018. All rights reserved.