Package java.util.concurrent

Examples of java.util.concurrent.ConcurrentHashMap$KeySpliterator


  Set entries = backingFile.getRecords();
        int eSize = entries.size();
        int mSize = this.size();
        if (eSize > mSize) {
            recordMap = new ConcurrentHashMap(eSize);
        } else {
            recordMap = new ConcurrentHashMap(mSize);
        }

  Iterator iter = entries.iterator();
  while (iter.hasNext()) {
      VRecordMap record = (VRecordMap)iter.next();
View Full Code Here


    private File backingFile = null;

    // when instantiated, all data are loaded
    PropertiesStore() {
        propMap = new ConcurrentHashMap(64);
    }
View Full Code Here

    /**
     * When instantiated, all interests are loaded.
     */
    InterestStore() {
        interestMap = new ConcurrentHashMap(256);
    }
View Full Code Here

    private InMemoryStore parent = null;

    // when instantiated, all data are loaded
    DestinationStore(InMemoryStore p) {
  this.parent = p;
        dstMap = new ConcurrentHashMap(64);
    }
View Full Code Here

    public FullIdentityMap() {}
   
    public FullIdentityMap(int size) {
        super(size);
        cacheKeys = new ConcurrentHashMap(size);
    }
View Full Code Here

        cacheKeys = new ConcurrentHashMap(size);
    }

    public FullIdentityMap(int size, ClassDescriptor descriptor) {
        super(size, descriptor);
        cacheKeys = new ConcurrentHashMap(size);
    }
View Full Code Here

     * INTERNAL:
     * Clones itself.
     */
    public Object clone() {
        FullIdentityMap clone = (FullIdentityMap)super.clone();
        clone.setCacheKeys(new ConcurrentHashMap(getCacheKeys().size()));

        for (Iterator cacheKeysIterator = getCacheKeys().values().iterator(); cacheKeysIterator.hasNext();) {
            CacheKey key = (CacheKey)((CacheKey)cacheKeysIterator.next()).clone();
            clone.getCacheKeys().put(key, key);
        }
View Full Code Here

                clearPreallocationHandler();
            }
            throw ex;
        }
        if (atLeastOneSequenceShouldUsePreallocation) {
            setLocks(new ConcurrentHashMap(20));
        }
        createSequencingCallbackFactory();
        if(getOwnerSession().hasExternalTransactionController()) {
            getOwnerSession().getExternalTransactionController().initializeSequencingListeners();
        }
View Full Code Here

            this.identityMaps = new HashMap();
        } else if (session.isIsolatedClientSession()) {
            this.identityMaps = new HashMap();
            this.queryResults = new HashMap();
        } else {
            this.identityMaps = new ConcurrentHashMap();
            this.queryResults = new ConcurrentHashMap();
        }
    }
View Full Code Here

     */
    public Object clone() {
        IdentityMapManager manager = null;
        try {
            manager = (IdentityMapManager)super.clone();
            manager.setIdentityMaps(new ConcurrentHashMap());
            for (Iterator iterator = this.identityMaps.entrySet().iterator(); iterator.hasNext();) {
                Map.Entry entry = (Map.Entry)iterator.next();
                manager.identityMaps.put((Class)entry.getKey(), (IdentityMap)((IdentityMap)entry.getValue()).clone());
            }
        } catch (CloneNotSupportedException exception) {
View Full Code Here

TOP

Related Classes of java.util.concurrent.ConcurrentHashMap$KeySpliterator

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.