Package eu.dnetlib.broker.utils

Class LbsQueue<T,K>

java.lang.Object

eu.dnetlib.broker.utils.LbsQueue<T,K>

public class LbsQueue<T,K>
extends Object

Constructor Summary

Constructors

Constructor	Description
LbsQueue(String name, Function<T,K> func, Predicate<K> predicate, int maxElements)

Method Summary

Modifier and Type	Method	Description
Function<T,K>	getFunc()
long	getInvalidRecords()
long	getLostRecords()
String	getName()
Predicate<K>	getPredicate()
long	getSkippedRecords()
boolean	offer(T obj)
void	resetCounters()
long	size()
List<K>	takeList()
K	takeOne()

Methods inherited from class java.lang.Object

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

Constructor Details

LbsQueue

public LbsQueue(String name,
 Function<T,K> func,
 Predicate<K> predicate,
 int maxElements)

Method Details

takeList

public List<K> takeList()

takeOne

public K takeOne()

offer

public boolean offer(T obj)

size

public long size()

getLostRecords

public long getLostRecords()

getSkippedRecords

public long getSkippedRecords()

getInvalidRecords

public long getInvalidRecords()

resetCounters

public void resetCounters()

getName

public String getName()

getPredicate

public Predicate<K> getPredicate()

getFunc

public Function<T,K> getFunc()