org.kuali.rice.kim.service.impl

Class IdentityArchiveServiceImpl.WriteQueue

java.lang.Object

org.kuali.rice.kim.service.impl.IdentityArchiveServiceImpl.WriteQueue

Enclosing class:

IdentityArchiveServiceImpl

protected static class IdentityArchiveServiceImpl.WriteQueue
extends Object

A class encapsulating a ConcurrentLinkedQueue and an AtomicInteger to provide fast offer(enqueue)/poll(dequeue) and size checking. Size may be approximate due to concurrent activity, but for our purposes that is fine.

Author:

Kuali Rice Team (rice.collab@kuali.org)

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	IdentityArchiveServiceImpl.WriteQueue()

Method Summary

Methods

Modifier and Type	Method and Description
int	offerAndGetSize(EntityDefault entity)
protected EntityDefault	poll()

Methods inherited from class java.lang.Object

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

Constructor Detail

IdentityArchiveServiceImpl.WriteQueue

protected IdentityArchiveServiceImpl.WriteQueue()

Method Detail

offerAndGetSize

public int offerAndGetSize(EntityDefault entity)

poll

protected EntityDefault poll()