缓存是ConcurrentHashMap怎么做给个例子

ConcurrentHashMap:
马克- to-win:马克 java社区:防盗版实名手机尾号: 73203。
马克-to-win:ConcurrentHashMap是java1.5的新特性。HashTable在并发环境下效率低的原因: HashTable就一把锁,所有线程竞争。ConcurrentHashMap里面有很多锁,就像数据库里的行级锁一样。改这行,锁这行,不影响别的行。最重要的是:一个线程添加(put)元素,同时另一个线程读数据不会引起ConcurrentModificationException异常。读写可以同时进行,只不过读的有可能不是最新数据。马克-to-win:所以如果需要原子操作时,还得手动加锁。所以我们前面学的锁的理论,照样适用。(见下面的例子)

例 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++) {
(购买完整教程)
            System.out.println("第一个线程要睡觉");
            try {
                Thread.sleep(3);
                System.out.println("第一个线程刚睡完");
            } 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("添加了一对 " + i);
            System.out.println("第二个线程要睡觉觉睡得短,所以很两个线程执行顺序完全不可控,不睡觉就不能混着执行了");
            try {
                Thread.sleep(3);
                System.out.println("第二个线程刚睡完");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}
public class TestConcurBuy_MarkToWin {
    public static void main(String[] args) {
        Map map = new ConcurrentHashMap();
/*下面三种集合都会报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();
    }
}


输出结果:


添加了一对 1
第二个线程要睡觉觉睡得短,所以很两个线程执行顺序完全不可控,不睡觉就不能混着执行了
循环第1次,mapSize is 1
第二个线程刚睡完
添加了一对 2
第二个线程要睡觉觉睡得短,所以很两个线程执行顺序完全不可控,不睡觉就不能混着执行了
看到了 kkk1
看到了 kkk2
第一个线程要睡觉
第二个线程刚睡完
添加了一对 3
第二个线程要睡觉觉睡得短,所以很两个线程执行顺序完全不可控,不睡觉就不能混着执行了
第一个线程刚睡完
循环第2次,mapSize is 3
看到了 kkk3
看到了 kkk1
看到了 kkk2
第一个线程要睡觉
第二个线程刚睡完
添加了一对 4
第二个线程要睡觉觉睡得短,所以很两个线程执行顺序完全不可控,不睡觉就不能混着执行了
第一个线程刚睡完
循环第3次,mapSize is 4
看到了 kkk3
看到了 kkk4
看到了 kkk1
看到了 kkk2
第一个线程要睡觉
第二个线程刚睡完
添加了一对 5
第二个线程要睡觉觉睡得短,所以很两个线程执行顺序完全不可控,不睡觉就不能混着执行了
第一个线程刚睡完
循环第4次,mapSize is 5
看到了 kkk5
看到了 kkk3
看到了 kkk4
看到了 kkk1
看到了 kkk2

。。。。。。。


观察上面的输出结果,mapSize is 1之后,又插入一条,于是输出了两条。也就是说,mapSize的数据不是最新的,也不报错。你心中就应清楚,读的所有数据有可能都不是最新数据。所以如果需要最新数据时,还得手动加锁。