package org.hsqldb.lib;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantReadWriteLock;
import org.hsqldb.map.BaseHashMap;
public class IntKeyHashMapConcurrent extends BaseHashMap {
Set keySet;
Collection values;
ReentrantReadWriteLock lock = new ReentrantReadWriteLock(true);
ReentrantReadWriteLock.ReadLock readLock = lock.readLock();
ReentrantReadWriteLock.WriteLock writeLock = lock.writeLock();
public IntKeyHashMapConcurrent() {
this(8);
}
public IntKeyHashMapConcurrent(int initialCapacity)
throws IllegalArgumentException {
super(initialCapacity, BaseHashMap.intKeyOrValue,
BaseHashMap.objectKeyOrValue, false);
}
public Lock getWriteLock() {
return writeLock;
}
public Object get(int key) {
try {
readLock.lock();
int lookup = getLookup(key);
if (lookup != -1) {
return objectValueTable[lookup];
}
return null;
} finally {
readLock.unlock();
}
}
public Object put(int key, Object value) {
try {
writeLock.lock();
return super.addOrRemove(key, 0, null, value, false);
} finally {
writeLock.unlock();
}
}
public boolean containsValue(Object value) {
try {
readLock.lock();
return super.containsValue(value);
} finally {
readLock.unlock();
}
}
public Object remove(int key) {
try {
writeLock.lock();
return super.addOrRemove(key, 0, null, null, true);
} finally {
writeLock.unlock();
}
}
public boolean containsKey(int key) {
try {
readLock.lock();
return super.containsKey(key);
} finally {
readLock.unlock();
}
}
public int getOrderedMatchCount(int[] array) {
int i = 0;
try {
readLock.lock();
for (; i < array.length; i++) {
if (!super.containsKey(array[i])) {
break;
}
}
return i;
} finally {
readLock.unlock();
}
}
public Set keySet() {
if (keySet == null) {
keySet = new KeySet();
}
return keySet;
}
public Collection values() {
if (values == null) {
values = new Values();
}
return values;
}
class KeySet implements Set {
public Iterator iterator() {
return IntKeyHashMapConcurrent.this.new BaseHashIterator(true);
}
public int size() {
return IntKeyHashMapConcurrent.this.size();
}
public boolean contains(Object o) {
throw new UnsupportedOperationException();
}
public Object get(Object key) {
throw new UnsupportedOperationException();
}
public boolean add(Object value) {
throw new UnsupportedOperationException();
}
public boolean addAll(Collection c) {
throw new UnsupportedOperationException();
}
public boolean remove(Object o) {
throw new UnsupportedOperationException();
}
public boolean isEmpty() {
return size() == 0;
}
public void clear() {
IntKeyHashMapConcurrent.this.clear();
}
}
class Values implements Collection {
public Iterator iterator() {
return IntKeyHashMapConcurrent.this.new BaseHashIterator(false);
}
public int size() {
return IntKeyHashMapConcurrent.this.size();
}
public boolean contains(Object o) {
throw new UnsupportedOperationException();
}
public boolean add(Object value) {
throw new UnsupportedOperationException();
}
public boolean addAll(Collection c) {
throw new UnsupportedOperationException();
}
public boolean remove(Object o) {
throw new UnsupportedOperationException();
}
public boolean isEmpty() {
return size() == 0;
}
public void clear() {
IntKeyHashMapConcurrent.this.clear();
}
}
}