Имам нужда от структура от данни, която може ефективно да буферира определен брой елементи в FIFO ред.
Както бе споменато в този въпрос, Apache Commons има CircularFifoBuffer, но за съжаление не е генериран. Някои разклонения съществуват, но не съм сигурен в състоянието им на поддръжка.
Тъй като Guava е основната библиотека за нуждите ми от колекции, се чудя: има ли добра алтернатива в Guava? Ако не, трябва ли да го внедря в моя проект, базиран на CircularFifoBuffer на Apache Commons?
Стартиране на Guava 15.0 - можете да използвате Изгонваща опашка
Не виждам нищо подобно в Guava, но какво ще кажете за ForwardingQueue, изграден около ArrayDeque където проверявате капацитета на add(), offer() и т.н. и remove() стари записи, ако вече е пълен?
ArrayDeque всъщност е много близко до това на CircularFifoBuffer, след като го украсите, за да премахнете най-стария елемент, когато е пълен. Класът няма заключване/синхронизация, което е добре, тъй като не ме интересува безопасността на нишката. Единственият недостатък, който виждам, е, че основният масив може да е по-голям от необходимото, тъй като размерът му трябва да е степен на 2. Но това е преждевременна оптимизация :)
- person Etienne Neveu; 09.01.2013
Commons-Collections with Generics (maven link) е правилният начин, ако искате да използвате Apache Collections с генерични (и съдържа работещ CircularFifoBuffer<E> клас).
От друга страна, както казва @FrankPavageau, можете да използвате своя собствена ForwardingQueue реализация. Наивен подход (с място за допълнителни оптимизации) би бил нещо подобно:
static class BoundedQueue<E> extends ForwardingQueue<E> {
private final Queue<E> delegate;
private final int capacity;
public BoundedQueue(final int capacity) {
this.delegate =
new ArrayDeque<E>(capacity); // specifying initial capacity is optional
this.capacity = capacity;
}
@Override
protected Queue<E> delegate() {
return delegate;
}
@Override
public boolean add(final E element) {
if (size() >= capacity) {
delegate.poll();
}
return delegate.add(element);
}
@Override
public boolean addAll(final Collection<? extends E> collection) {
return standardAddAll(collection);
}
@Override
public boolean offer(final E o) {
return standardOffer(o);
}
}
Употреба:
final BoundedQueue<Integer> boundedQueue = new BoundedQueue<Integer>(3);
boundedQueue.add(1);
System.out.println(boundedQueue); // [1]
boundedQueue.add(2);
System.out.println(boundedQueue); // [1, 2]
boundedQueue.add(3);
System.out.println(boundedQueue); // [1, 2, 3]
boundedQueue.add(4);
System.out.println(boundedQueue); // [2, 3, 4]
boundedQueue.addAll(Arrays.asList(5, 6, 7, 8));
System.out.println(boundedQueue); // [6, 7, 8]
((Queue<Integer>) boundedQueue).offer(9);
System.out.println(boundedQueue); // [7, 8, 9]
CircularFifoBuffer, за да разреша текущия си проблем. Промених зависимостта си от commons-collections:commons-collections:3.2 на net.sourceforge.collections:collections-generic:4.01 след известно търсене (няма много документация). Надявам се обаче официалната генерирана версия на commons-collections да бъде пусната скоро. Като изключим това, би било страхотно, ако такава структура от данни може да бъде добавена към Guava.
- person Etienne Neveu; 09.01.2013
ArrayBlockingQueue на Java предлага циркуляр с фиксиран размер буфер.
ArrayBlockingQueue не прави това. Въпреки това не би трябвало да е твърде трудно да го промените.
- person Tom Anderson; 09.01.2013
ArrayBlockingQueue блокира (оттук и името), докато CircularFifoQueue изпуска най-стария елемент. За да цитирам документа за ArrayBlockingQueue: Attempts to put an element into a full queue will result in the operation blocking
- person Basil Bourque; 11.02.2014
ArrayBlockingQueueще блокира, когато е пълен. - person SimonC schedule 09.01.2013