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

protected

IdentityArchiveServiceImpl.WriteQueue()

Method Summary

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()