Serialized Form
Package edu.emory.mathcs.util |
readObject
private void readObject(java.io.ObjectInputStream s)
throws java.io.IOException,
java.lang.ClassNotFoundException
- Reconstitute the ArrayList instance from a stream (that is,
deserialize it).
writeObject
private void writeObject(java.io.ObjectOutputStream s)
throws java.io.IOException
- Save the state of the instance to a stream (that
is, serialize it).
- Serial Data:
- The length of the array backing the instance is
emitted (int), followed by all of its elements (each an
Object) in the proper order.
java.io.IOException
size
int size
- The number of elements in the priority queue.
comparator
java.util.Comparator comparator
- The comparator, or null if priority queue uses elements'
natural ordering.
Package edu.emory.mathcs.util.concurrent |
items
java.lang.Object[] items
- The queued items
count
int count
- Number of items in the queue
lock
ReentrantLock lock
- Main lock guarding all access
notEmpty
Condition notEmpty
- Condition for waiting takes
notFull
Condition notFull
- Condition for waiting puts
readObject
private void readObject(java.io.ObjectInputStream s)
throws java.io.IOException,
java.lang.ClassNotFoundException
- Reconstitute the ConcurrentHashMap
instance from a stream (i.e.,
deserialize it).
writeObject
private void writeObject(java.io.ObjectOutputStream s)
throws java.io.IOException
- Save the state of the ConcurrentHashMap
instance to a stream (i.e.,
serialize it).
- Serial Data:
- the key (Object) and value (Object)
for each key-value mapping, followed by a null pair.
The key-value mappings are emitted in no particular order.
java.io.IOException
segmentMask
int segmentMask
- Mask value for indexing into segments. The upper bits of a
key's hash code are used to choose the segment.
segmentShift
int segmentShift
- Shift value for indexing within segments.
segments
ConcurrentHashMap.Segment[] segments
- The segments, each of which is a specialized hash table
readObject
private void readObject(java.io.ObjectInputStream s)
throws java.io.IOException,
java.lang.ClassNotFoundException
- Reconstitute the list from a stream (i.e., deserialize it).
writeObject
private void writeObject(java.io.ObjectOutputStream s)
throws java.io.IOException
- Save the state of the list to a stream (i.e., serialize it).
- Serial Data:
- The length of the array backing the list is emitted
(int), followed by all of its elements (each an Object)
in the proper order.
java.io.IOException
al
CopyOnWriteArrayList al
readObject
private void readObject(java.io.ObjectInputStream s)
throws java.io.IOException,
java.lang.ClassNotFoundException
- Reconstitute this queue instance from a stream (that is,
deserialize it).
writeObject
private void writeObject(java.io.ObjectOutputStream s)
throws java.io.IOException
- Save the state to a stream (that is, serialize it).
- Serial Data:
- The capacity is emitted (int), followed by all of
its elements (each an Object) in the proper order,
followed by a null
java.io.IOException
putGuard_
java.lang.Object putGuard_
- Helper monitor. Ensures that only one put at a time executes.
takeGuard_
java.lang.Object takeGuard_
- Helper monitor. Protects and provides wait queue for takes
capacity_
int capacity_
- Number of elements allowed
writeObject
private void writeObject(java.io.ObjectOutputStream s)
throws java.io.IOException
- Save the state to a stream (that is, serialize it). This
merely wraps default serialization within lock. The
serialization strategy for items is left to underlying
Queue. Note that locking is not needed on deserialization, so
readObject is not defined, just relying on default.
q
PriorityQueue q
lock
ReentrantLock lock
notEmpty
Condition notEmpty
impl
Semaphore.Impl impl
qlock
ReentrantLock qlock
- Lock protecting both wait queues
waitingProducers
SynchronousQueue.WaitQueue waitingProducers
- Queue holding waiting puts
waitingConsumers
SynchronousQueue.WaitQueue waitingConsumers
- Queue holding waiting takes
index
int index
- the index of this unit
name
java.lang.String name
- name of this unit
Package edu.emory.mathcs.util.concurrent.locks |
impl
ReentrantLock.Impl impl
activeReaders_
int activeReaders_
activeWriter_
java.lang.Thread activeWriter_
waitingReaders_
int waitingReaders_
waitingWriters_
int waitingWriters_
readerLock_
ReentrantReadWriteLock.ReaderLock readerLock_
writerLock_
ReentrantReadWriteLock.WriterLock writerLock_
writeHolds_
int writeHolds_
- Number of acquires on write lock by activeWriter_ thread
readers_
java.util.HashMap readers_
- Number of acquires on read lock by any reader thread
Package edu.emory.mathcs.util.concurrent.atomic |
value
int value
value
int value
array
int[] array
value
long value
array
long[] array
value
java.lang.Object value
array
java.lang.Object[] array
Package edu.emory.mathcs.util.concurrent.helpers |