xyz.cofe.cbuffer

Class Fragments

java.lang.Object

xyz.cofe.collection.list.ListWrapper<E>

xyz.cofe.collection.list.BasicEventList<E>

xyz.cofe.collection.list.IndexEventList<E>

xyz.cofe.collection.list.SyncEventList<Fragment>

xyz.cofe.cbuffer.Fragments

All Implemented Interfaces:

Iterable<Fragment>, Collection<Fragment>, List<Fragment>, BulkInsert<Fragment>, EventList<Fragment>, EventListSender<Fragment>, GetListenersHelper

Direct Known Subclasses:

ContentFragments

public class Fragments
extends SyncEventList<Fragment>

Набор фрагментов

Author:

Kamnev Georgiy (nt.gocha@gmail.com)

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	Fragments.Event
static interface	Fragments.Listener

Field Summary

Fields

Modifier and Type	Field and Description
protected Func2<Fragment,Long,Long>	defCreateFragment
protected Func2<List<Fragment>,Fragment,Fragment>	defIntersecResolver
protected static Comparator<Fragment>	defSorter
protected Queue<Fragments.Event>	eventQu
protected ListenersHelper<Fragments.Listener,Fragments.Event>	listeners
protected static Comparator<Fragment>	sorterByBegin
protected static Comparator<Fragment>	sorterByInstanceID
protected static Comparator<Fragment>	sorterBySize
protected AtomicBoolean	syncFireListeners
Func2<List<Fragment>,Fragment,Fragment>	unionIntersecResolver Решение пересечения обьеднением

Fields inherited from class xyz.cofe.collection.list.SyncEventList

sync

Fields inherited from class xyz.cofe.collection.list.BasicEventList

eventQueue, lockLevel

Fields inherited from class xyz.cofe.collection.list.ListWrapper

list

Constructor Summary

Constructors

Constructor and Description
Fragments()
Fragments(Fragments source, Object osync)
Fragments(Iterable<? extends Fragment> source, boolean clone)
Fragments(Iterable<? extends Fragment> source, Object osync)
Fragments(Object osync)

Method Summary

Modifier and Type	Method and Description
Closeable	addListener(Fragments.Listener listener)
Closeable	addListener(Fragments.Listener listener, boolean weakLink)
Fragments	clone()
Fragments	clone(Object osync)
protected Fragment	createFagment(long begin, long end)
List<Fragment>	find(Predicate<Fragment> p) Поиск фрагментов по критерию
List<Fragment>	findHoles(long begin, long end) Поиск дыр в указанном диапазоне
List<Fragment>	findHoles(long fbegin, long fend, Func2<Fragment,Long,Long> fcreateFragment) Поиск дыр в указанном диапазоне
Map<Fragment,Set<Fragment>>	findIntersections() Поиск пересечений
List<Fragment>	findZeroSize() Поиск фрагментов нулей длинны
void	fireEvent(Fragments.Event event)
protected void	fireEventQu()
Set<Fragments.Listener>	getListeners()
Object	getSyncObject()
protected boolean	isEquals(Fragment f1, Fragment f2)
Iterator<Fragment>	iterator()
protected ListenersHelper<Fragments.Listener,Fragments.Event>	listeners()
static Predicate<Fragment>	rangePredicate(long begin, long end)
void	removeIntersections() Удаление пересечений, так же удаляет нулевые фрагменты
void	removeIntersections(Func2<List<Fragment>,Fragment,Fragment> fintersecResolver) Удаление пересечений, так же удаляет нулевые фрагменты
void	removeListener(Fragments.Listener listener)
void	removeSameRange(Fragment fragment)
static Predicate<Fragment>	sizeEqualsPredicate(long size)
void	sort() Сортировка
protected <T> T	syncRun(Func0<T> code) Обновление свойств с учетом блокировок и много поточности.
String	toString()
void	visitEachEachWithoutPosition(Func2<Object,Fragment,Fragment> visitor, Func2<Boolean,Fragment,Fragment> equals) Обход каждый с каждым, без учета позиции в сочетании пар и самого себя.

Methods inherited from class xyz.cofe.collection.list.SyncEventList

lockRun

Methods inherited from class xyz.cofe.collection.list.IndexEventList

add, add0, iterator0, remove, remove, remove0, remove0, removeAll, removeAll0, retainAll, retainAll0

Methods inherited from class xyz.cofe.collection.list.BasicEventList

add, add0, addAll, addAll, addAll0, addAll0, addEventListListener, addEventListListener, addEventToQueue, bulkInsert, clear, clear0, contains, containsAll, containsEventListListener, fireEventListMessage, fireQueueEvents, fireQueueEvents0, get, getListenersHelper, getWrappedList, indexOf, isEmpty, lastIndexOf, listIterator, listIterator, listIterator0, listIterator0, lockRun, onAdded, onAdding, onChanged, onChanged, onChanging, onChanging, onDeleted, onDeleted, onDeleting, onDeleting, onInserted, onInserted, onInserting, onInserting, onRemoved, onRemoving, onUpdated, onUpdated, onUpdating, onUpdating, removeEventListListener, set, set0, setWrappedList, size, subList, subList0, toArray, toArray

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.List

equals, hashCode, replaceAll, sort, spliterator

Methods inherited from interface java.util.Collection

parallelStream, removeIf, stream

Methods inherited from interface java.lang.Iterable

forEach

Field Detail

listeners

protected ListenersHelper<Fragments.Listener,Fragments.Event> listeners

eventQu

protected Queue<Fragments.Event> eventQu

syncFireListeners

protected final AtomicBoolean syncFireListeners

sorterByBegin

protected static final Comparator<Fragment> sorterByBegin

sorterBySize

protected static final Comparator<Fragment> sorterBySize

sorterByInstanceID

protected static final Comparator<Fragment> sorterByInstanceID

defSorter

protected static final Comparator<Fragment> defSorter

defCreateFragment

protected Func2<Fragment,Long,Long> defCreateFragment

unionIntersecResolver

public final Func2<List<Fragment>,Fragment,Fragment> unionIntersecResolver

Решение пересечения обьеднением

defIntersecResolver

protected final Func2<List<Fragment>,Fragment,Fragment> defIntersecResolver

Constructor Detail

Fragments

public Fragments()

Fragments

public Fragments(Object osync)

Fragments

public Fragments(Iterable<? extends Fragment> source,
                 boolean clone)

Fragments

public Fragments(Iterable<? extends Fragment> source,
                 Object osync)

Fragments

public Fragments(Fragments source,
                 Object osync)

Method Detail

getSyncObject

public final Object getSyncObject()

clone

public Fragments clone()

Overrides:

clone in class Object

clone

public Fragments clone(Object osync)

listeners

protected ListenersHelper<Fragments.Listener,Fragments.Event> listeners()

getListeners

public Set<Fragments.Listener> getListeners()

addListener

public Closeable addListener(Fragments.Listener listener)

addListener

public Closeable addListener(Fragments.Listener listener,
                             boolean weakLink)

removeListener

public void removeListener(Fragments.Listener listener)

fireEvent

public void fireEvent(Fragments.Event event)

fireEventQu

protected void fireEventQu()

syncRun

protected <T> T syncRun(Func0<T> code)

Обновление свойств с учетом блокировок и много поточности. Нужно, чтоб listeners вызывались после снятия блокировки.

Type Parameters:

T - Тип результата

Parameters:

code - Код обновления свойств

Returns:

Результат

iterator

public Iterator<Fragment> iterator()

Specified by:

iterator in interface Iterable<Fragment>

Specified by:

iterator in interface Collection<Fragment>

Specified by:

iterator in interface List<Fragment>

Overrides:

iterator in class IndexEventList<Fragment>

removeSameRange

public void removeSameRange(Fragment fragment)

toString

public String toString()

Overrides:

toString in class ListWrapper<Fragment>

sizeEqualsPredicate

public static Predicate<Fragment> sizeEqualsPredicate(long size)

rangePredicate

public static Predicate<Fragment> rangePredicate(long begin,
                                                 long end)

find

public List<Fragment> find(Predicate<Fragment> p)

Поиск фрагментов по критерию

Parameters:

p - критерий

Returns:

найденые фрагменты

sort

public void sort()

Сортировка

findZeroSize

public List<Fragment> findZeroSize()

Поиск фрагментов нулей длинны

Returns:

нулевой длины элементы

createFagment

protected Fragment createFagment(long begin,
                                 long end)

isEquals

protected boolean isEquals(Fragment f1,
                           Fragment f2)

visitEachEachWithoutPosition

public void visitEachEachWithoutPosition(Func2<Object,Fragment,Fragment> visitor,
                                         Func2<Boolean,Fragment,Fragment> equals)

Обход каждый с каждым, без учета позиции в сочетании пар и самого себя.
пример:
исходно[a, b, c, d]
вызовы
visitor( a, b )
visitor( a, с )
visitor( a, d )
visitor( b, c )
visitor( b, d )
visitor( c, d )

Parameters:

visitor - Функция приемник пар

equals - Функция сравнения на равенство

findIntersections

public Map<Fragment,Set<Fragment>> findIntersections()

Поиск пересечений

Returns:

пересечения

findHoles

public List<Fragment> findHoles(long begin,
                                long end)

Поиск дыр в указанном диапазоне

Parameters:

begin - начало диапазона

end - конец диапазона искл.

Returns:

Фрагменты соответ дырам

findHoles

public List<Fragment> findHoles(long fbegin,
                                long fend,
                                Func2<Fragment,Long,Long> fcreateFragment)

Поиск дыр в указанном диапазоне

Parameters:

fbegin - начало диапазона

fend - конец диапазона искл.

fcreateFragment - Создание фрагмента

Returns:

Фрагменты соответ дырам

removeIntersections

public void removeIntersections()

Удаление пересечений, так же удаляет нулевые фрагменты

removeIntersections

public void removeIntersections(Func2<List<Fragment>,Fragment,Fragment> fintersecResolver)

Удаление пересечений, так же удаляет нулевые фрагменты

Parameters:

fintersecResolver - способ решения пересечений