標(biāo)簽：java

CurrentHashMap更新

提要：

• CurrentHashMap的線程安全罗丰？
  • 多個(gè)線程對(duì)currentHashMap讀取的時(shí)候不會(huì)破壞其數(shù)據(jù)結(jié)構(gòu)比默，
    • 也就是說讀寫的時(shí)候是線程安全的；
  • 但是操作數(shù)據(jù)的順序需要額外的同步處理漠趁，保證同步代碼操作的原子性

原子更新

lambda表達(dá)式函數(shù)表示要執(zhí)行的同步代碼熏兄，
使用compute原子更新，保證（獲取-計(jì)算-更新）同步代碼的原子性

private ConcurrentHashMap<String,Integer> map=new ConcurrentHashMap<>();
public CurrentHashMapTest(){
    map.put("55555",5);
    map.put("666666",6);
    map.put("7777777",7);
}

/**
 * java 8提供了很多用于原子更新的方法
 * 函數(shù)運(yùn)行時(shí)其他一些更新映射的操作可能會(huì)被阻塞
 */
private void atomicUpdate(){
    String word="55555";
    //接受一個(gè)函數(shù)叭莫，參數(shù)為鍵及其關(guān)聯(lián)的值，若不存在鍵烁试，則值為null雇初；
    //函數(shù)返回更新后的值；
    map.compute(word,(k,v)->{
        return null==v?1:v+1;
    });
    //存在時(shí)才更新值减响，參數(shù)為value
    map.computeIfPresent(word,(k,v)->v+1);
    //不存在時(shí)才計(jì)算新值靖诗，參數(shù)為key
    map.computeIfAbsent(word,(k)->1);
    //k不存在郭怪，返回初始值；
    // k存在呻畸，調(diào)用函數(shù)對(duì)初始值和舊值計(jì)算返回
    map.merge(
            word,//key
            1,//初始
            (existingValue,newValue)->existingValue+newValue
    );
}

批量數(shù)據(jù)操作

返回結(jié)果的時(shí)候除非可以確保沒有其他值修改移盆，否則應(yīng)該作為近似值
(tip：可能在你計(jì)算到值還未返回的時(shí)候已經(jīng)有其他線程修改了數(shù)據(jù))
(如何保證悼院？鎖定數(shù)據(jù))

private void batchOperation(){
    //search()查找,reduce()聚合伤为，foreach()遍歷應(yīng)用
    //以上三個(gè)方法都有針對(duì)key,value,k&v,entry四個(gè)版本
    //第一個(gè)參數(shù)為并行閥值，超過該數(shù)量則并行處理
    //search()方法查找到第一個(gè)則返回
    map.search(1,(k,v)->{
        if(k.endsWith("5")&&v>4){
            return k;
        }else{
            return null;
        }
    });
    //foreach()遍歷數(shù)據(jù)据途，應(yīng)用函數(shù)處理
    //1.對(duì)每個(gè)數(shù)據(jù)項(xiàng)默認(rèn)應(yīng)用
    map.forEach(1,(k,v)->{
        LOGGER.info(k+"`s length is"+v);
    });
    //2.先使用轉(zhuǎn)換器函數(shù)绞愚，再對(duì)結(jié)果應(yīng)用消費(fèi)者函數(shù)
    map.forEach(1,
            (k,v)->k+"`s length is"+v,//轉(zhuǎn)換器可作為一個(gè)過濾器，如果返回null颖医，則不應(yīng)用消費(fèi)者函數(shù)
            (str)->LOGGER.info(str));
    //reduce()對(duì)數(shù)據(jù)執(zhí)行累加操作位衩，返回結(jié)果
    map.reduceValues(1,
            v->Integer.valueOf(v),//轉(zhuǎn)換器
            Integer::sum);//聚合操作
    //reduce***ToLong/Integer/Double(),提供int，long熔萧，double原始類型的輸出糖驴；
}

線程安全的Set

/**
 * 獲取一個(gè)大的，線程安全的Set
 */
private void setView(){
    //返回一個(gè)線程安全的Set,實(shí)際上是對(duì)ConcurrentHashMap<K,Boolean>的封裝
    Set<String> keys=map.newKeySet();
    Set<String> keySet=ConcurrentHashMap.<String>newKeySet();
    //delete,無法添加add（因?yàn)闆]有值）
    keys.remove("55555");
    //參數(shù)提供了一個(gè)默認(rèn)值佛致，如果添加一個(gè)鍵贮缕，對(duì)應(yīng)的值不存在，則使用默認(rèn)值
    keys=map.keySet(1);
    //add
    keys.add("7777777");
}