Package org.jruby.javasupport.util

Class ObjectProxyCache.Segment<T,A>

java.lang.Object

java.util.concurrent.locks.ReentrantLock

org.jruby.javasupport.util.ObjectProxyCache.Segment<T,A>

All Implemented Interfaces:

Serializable, Lock

Enclosing class:

ObjectProxyCache<T,A>

static class ObjectProxyCache.Segment<T,A>
extends ReentrantLock

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final ObjectProxyCache<T,A>	cache
(package private) ObjectProxyCache.Entry<T>[]	entryTable
(package private) final ReferenceQueue<Object>	referenceQueue
(package private) int	tableSize
(package private) int	threshold

Constructor Summary

Constructors

Constructor	Description
Segment(int capacity, ObjectProxyCache<T,A> cache)

Method Summary

Modifier and Type	Method	Description
private int	count()
private void	expunge()
(package private) T	get(Object object, int hash)
(package private) T	getOrCreate(Object object, int hash, A allocator)
(package private) static final <T, A> ObjectProxyCache.Segment<T,A>[]	newArray(int size)
(package private) void	put(Object object, int hash, T proxy)
private ObjectProxyCache.Entry<T>[]	rehash()
private void	remove(ObjectProxyCache.Entry<T>[] table, int hash, ObjectProxyCache.Entry<T> e)

Methods inherited from class java.util.concurrent.locks.ReentrantLock

getHoldCount, getOwner, getQueuedThreads, getQueueLength, getWaitingThreads, getWaitQueueLength, hasQueuedThread, hasQueuedThreads, hasWaiters, isFair, isHeldByCurrentThread, isLocked, lock, lockInterruptibly, newCondition, toString, tryLock, tryLock, unlock

Methods inherited from class java.lang.Object

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

Field Details

cache

final ObjectProxyCache<T,A> cache

referenceQueue

final ReferenceQueue<Object> referenceQueue

entryTable

volatile ObjectProxyCache.Entry<T>[] entryTable

tableSize

int tableSize

threshold

int threshold

Constructor Details

Segment

Segment(int capacity,
 ObjectProxyCache<T,A> cache)

Method Details

expunge

private void expunge()

remove

private void remove(ObjectProxyCache.Entry<T>[] table,
 int hash,
 ObjectProxyCache.Entry<T> e)

count

private int count()

rehash

private ObjectProxyCache.Entry<T>[] rehash()

put

void put(Object object,
 int hash,
 T proxy)

getOrCreate

T getOrCreate(Object object,
 int hash,
 A allocator)

get

T get(Object object,
 int hash)

newArray

static final <T,
A> ObjectProxyCache.Segment<T,A>[] newArray(int size)