package com.fastbee.base.util;

import lombok.Data;

import java.util.concurrent.ConcurrentHashMap;

/**
 * concurrentMap存储类
 * @author bill
 */
@Data
public abstract class ConcurrentStorage<K,V> implements Storage<K,V>{

    private volatile ConcurrentHashMap<K,V> map;

    public ConcurrentStorage(){
        this(new ConcurrentHashMap<K,V>());
    }

    public ConcurrentStorage(ConcurrentHashMap<K,V> map){
        this.map = map;
    }


    @Override
    public V push(K key, V value) {
        return map.put(key,value);
    }

    @Override
    public V pop(K key) {
        return map.get(key);
    }

    @Override
    public V remove(K key) {
        return map.remove(key);
    }

    @Override
    public boolean isContains(Object key) {
        return map.containsKey(key);
    }

    @Override
    public Object getStorage() {
        return this.map;
    }


}