緩存是ConcurrentHashMap怎么做給個(gè)例子

ConcurrentHashMap：
馬克- to-win：馬克 java社區(qū)：防盜版實(shí)名手機(jī)尾號(hào)： 73203。
馬克-to-win：ConcurrentHashMap是java1.5的新特性。HashTable在并發(fā)環(huán)境下效率低的原因： HashTable就一把鎖，所有線程競(jìng)爭(zhēng)。ConcurrentHashMap里面有很多鎖，就像數(shù)據(jù)庫(kù)里的行級(jí)鎖一樣。改這行，鎖這行，不影響別的行。最重要的是：一個(gè)線程添加(put)元素，同時(shí)另一個(gè)線程讀數(shù)據(jù)不會(huì)引起ConcurrentModificationException異常。讀寫可以同時(shí)進(jìn)行，只不過(guò)讀的有可能不是最新數(shù)據(jù)。馬克-to-win：所以如果需要原子操作時(shí)，還得手動(dòng)加鎖。所以我們前面學(xué)的鎖的理論，照樣適用。（見(jiàn)下面的例子）

例 2.2.2.1

package com;
import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
class MulThreMarkToWin extends Thread {
    Map map;
    public MulThreMarkToWin(Map map) {
        this.map = map;
    }
    public void run() {
        for (int i = 1; i <= 30; i++) {
（購(gòu)買完整教程）
            System.out.println("第一個(gè)線程要睡覺(jué)");
            try {
                Thread.sleep(3);
                System.out.println("第一個(gè)線程剛睡完");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

class MulThreMarkToWinInsert extends Thread {
    Map map;
    public MulThreMarkToWinInsert(Map map) {
        this.map = map;
    }
    public void run() {
        for (int i = 1; i <= 30; i++) {
            map.put("kkk" + i, "vvv" + i);
            System.out.println("添加了一對(duì) " + i);
            System.out.println("第二個(gè)線程要睡覺(jué)覺(jué)睡得短，所以很兩個(gè)線程執(zhí)行順序完全不可控，不睡覺(jué)就不能混著執(zhí)行了");
            try {
                Thread.sleep(3);
                System.out.println("第二個(gè)線程剛睡完");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}
public class TestConcurBuy_MarkToWin {
    public static void main(String[] args) {
        Map map = new ConcurrentHashMap();
/*下面三種集合都會(huì)報(bào)ConcurrentModificationException異常*/
//        Map map = Collections.synchronizedMap(new HashMap());
//        Map map = new HashMap();
//        Map map = new Hashtable();
        Thread t1 = new MulThreMarkToWin(map);
        Thread t2 = new MulThreMarkToWinInsert(map);
        t1.start();
        t2.start();
    }
}




輸出結(jié)果：


添加了一對(duì) 1
第二個(gè)線程要睡覺(jué)覺(jué)睡得短，所以很兩個(gè)線程執(zhí)行順序完全不可控，不睡覺(jué)就不能混著執(zhí)行了
循環(huán)第1次，mapSize is 1
第二個(gè)線程剛睡完
添加了一對(duì) 2
第二個(gè)線程要睡覺(jué)覺(jué)睡得短，所以很兩個(gè)線程執(zhí)行順序完全不可控，不睡覺(jué)就不能混著執(zhí)行了
看到了 kkk1
看到了 kkk2
第一個(gè)線程要睡覺(jué)
第二個(gè)線程剛睡完
添加了一對(duì) 3
第二個(gè)線程要睡覺(jué)覺(jué)睡得短，所以很兩個(gè)線程執(zhí)行順序完全不可控，不睡覺(jué)就不能混著執(zhí)行了
第一個(gè)線程剛睡完
循環(huán)第2次，mapSize is 3
看到了 kkk3
看到了 kkk1
看到了 kkk2
第一個(gè)線程要睡覺(jué)
第二個(gè)線程剛睡完
添加了一對(duì) 4
第二個(gè)線程要睡覺(jué)覺(jué)睡得短，所以很兩個(gè)線程執(zhí)行順序完全不可控，不睡覺(jué)就不能混著執(zhí)行了
第一個(gè)線程剛睡完
循環(huán)第3次，mapSize is 4
看到了 kkk3
看到了 kkk4
看到了 kkk1
看到了 kkk2
第一個(gè)線程要睡覺(jué)
第二個(gè)線程剛睡完
添加了一對(duì) 5
第二個(gè)線程要睡覺(jué)覺(jué)睡得短，所以很兩個(gè)線程執(zhí)行順序完全不可控，不睡覺(jué)就不能混著執(zhí)行了
第一個(gè)線程剛睡完
循環(huán)第4次，mapSize is 5
看到了 kkk5
看到了 kkk3
看到了 kkk4
看到了 kkk1
看到了 kkk2

。。。。。。。


觀察上面的輸出結(jié)果，mapSize is 1之后，又插入一條，于是輸出了兩條。也就是說(shuō)，mapSize的數(shù)據(jù)不是最新的，也不報(bào)錯(cuò)。你心中就應(yīng)清楚，讀的所有數(shù)據(jù)有可能都不是最新數(shù)據(jù)。所以如果需要最新數(shù)據(jù)時(shí)，還得手動(dòng)加鎖。