org.gluu.credmanager.misc.ExpirationMap< K, V > クラステンプレート

org.gluu.credmanager.misc.ExpirationMap< K, V > 連携図

公開メンバ関数
	ExpirationMap ()
	ExpirationMap (long timeWindow, int maxEntries)
void	put (K key, V value)
V	get (K key)
Pair< V, Boolean >	getWithExpired (K key, long instant)
V	remove (K key)

非公開メンバ関数
void	initMap (long timeWindow, int maxEntries)
void	reduceMap ()

非公開変数類
long	lastCleaning
long	timeWindow
int	maxEntries
ConcurrentHashMap< K, Pair< V, Long > >	map = new ConcurrentHashMap<>()

静的非公開変数類
static final long	TIME_WINDOW_DEFAULT = 120000L
static final int	MAX_STORED_ENTRIES = 1000

詳解

著者

jgomer

構築子と解体子

ExpirationMap() [1/2]

org.gluu.credmanager.misc.ExpirationMap< K, V >.ExpirationMap ( )

inline

                           {
        initMap(TIME_WINDOW_DEFAULT, MAX_STORED_ENTRIES);
    }

ExpirationMap() [2/2]

org.gluu.credmanager.misc.ExpirationMap< K, V >.ExpirationMap ( long  timeWindow, int  maxEntries  )

inline

                                                          {
        initMap(timeWindow, maxEntries);
    }

関数詳解

get()

V org.gluu.credmanager.misc.ExpirationMap< K, V >.get ( K  key )

inline

                        {
        return map.get(key).getX();
    }

getWithExpired()

Pair<V, Boolean> org.gluu.credmanager.misc.ExpirationMap< K, V >.getWithExpired ( K  key, long  instant  )

inline

                                                                {
        Pair<V, Long> pair = map.get(key);
        return pair == null ? null : new Pair<>(pair.getX(), instant - pair.getY() > timeWindow);
    }

initMap()

void org.gluu.credmanager.misc.ExpirationMap< K, V >.initMap ( long  timeWindow, int  maxEntries  )

inlineprivate

                                                          {
        this.timeWindow = timeWindow;
        this.maxEntries = maxEntries;
        map = new ConcurrentHashMap<>();
        lastCleaning = System.currentTimeMillis();
    }

put()

void org.gluu.credmanager.misc.ExpirationMap< K, V >.put ( K  key, V  value  )

inline

                                    {
        map.put(key, new Pair<>(value, System.currentTimeMillis()));
        reduceMap();
    }

reduceMap()

void org.gluu.credmanager.misc.ExpirationMap< K, V >.reduceMap ( )

inlineprivate

                             {

        long now = System.currentTimeMillis();
        if (now - lastCleaning > timeWindow && map.size() > maxEntries) {
            lastCleaning = now;
            List<K> removals = new ArrayList<>();

            for (K key : map.keySet()) {
                if (now - map.get(key).getY() > timeWindow) {
                    removals.add(key);
                }
            }
            //Apply all removals consecutively
            for (K key : removals) {
                map.remove(key);
            }

        }
        /*
        //no parallelism in the search, grab the first key that matches the condition
        String aKey = map.searchKeys(Long.MAX_VALUE, key -> (now - map.get(key) > TIME_WINDOW_DEFAULT) ? key : null);
        map.remove(aKey);
        */
    }

remove()

V org.gluu.credmanager.misc.ExpirationMap< K, V >.remove ( K  key )

inline

                           {
        Pair<V, Long> pair = map.remove(key);
        return pair == null ? null : pair.getX();
    }

メンバ詳解

lastCleaning

long org.gluu.credmanager.misc.ExpirationMap< K, V >.lastCleaning

private

map

ConcurrentHashMap<K, Pair<V, Long> > org.gluu.credmanager.misc.ExpirationMap< K, V >.map = new ConcurrentHashMap<>()

private

MAX_STORED_ENTRIES

final int org.gluu.credmanager.misc.ExpirationMap< K, V >.MAX_STORED_ENTRIES = 1000

staticprivate

maxEntries

int org.gluu.credmanager.misc.ExpirationMap< K, V >.maxEntries

private

TIME_WINDOW_DEFAULT

final long org.gluu.credmanager.misc.ExpirationMap< K, V >.TIME_WINDOW_DEFAULT = 120000L

staticprivate

timeWindow

long org.gluu.credmanager.misc.ExpirationMap< K, V >.timeWindow

private

---

このクラス詳解は次のファイルから抽出されました:

• D:/AppData/OpenId/gluu/src/cred-manager/app/src/main/java/org/gluu/credmanager/misc/ExpirationMap.java