标签：java
CurrentHashMap更新
提要：
- CurrentHashMap的线程安全？
- 多个线程对currentHashMap读取的时候不会破坏其数据结构，
- 也就是说读写的时候是线程安全的；
- 但是操作数据的顺序需要额外的同步处理，保证同步代码操作的原子性
- 多个线程对currentHashMap读取的时候不会破坏其数据结构，
原子更新
lambda表达式函数表示要执行的同步代码，
使用compute原子更新，保证（获取-计算-更新）同步代码的原子性
private ConcurrentHashMap<String,Integer> map=new ConcurrentHashMap<>();
public CurrentHashMapTest(){
map.put("55555",5);
map.put("666666",6);
map.put("7777777",7);
}
/**
* java 8提供了很多用于原子更新的方法
* 函数运行时其他一些更新映射的操作可能会被阻塞
*/
private void atomicUpdate(){
String word="55555";
//接受一个函数，参数为键及其关联的值，若不存在键，则值为null；
//函数返回更新后的值；
map.compute(word,(k,v)->{
return null==v?1:v+1;
});
//存在时才更新值，参数为value
map.computeIfPresent(word,(k,v)->v+1);
//不存在时才计算新值，参数为key
map.computeIfAbsent(word,(k)->1);
//k不存在，返回初始值；
// k存在，调用函数对初始值和旧值计算返回
map.merge(
word,//key
1,//初始
(existingValue,newValue)->existingValue+newValue
);
}
批量数据操作
返回结果的时候除非可以确保没有其他值修改，否则应该作为近似值
(tip：可能在你计算到值还未返回的时候已经有其他线程修改了数据)
(如何保证？锁定数据)
private void batchOperation(){
//search()查找,reduce()聚合，foreach()遍历应用
//以上三个方法都有针对key,value,k&v,entry四个版本
//第一个参数为并行阀值，超过该数量则并行处理
//search()方法查找到第一个则返回
map.search(1,(k,v)->{
if(k.endsWith("5")&&v>4){
return k;
}else{
return null;
}
});
//foreach()遍历数据，应用函数处理
//1.对每个数据项默认应用
map.forEach(1,(k,v)->{
LOGGER.info(k+"`s length is"+v);
});
//2.先使用转换器函数，再对结果应用消费者函数
map.forEach(1,
(k,v)->k+"`s length is"+v,//转换器可作为一个过滤器，如果返回null，则不应用消费者函数
(str)->LOGGER.info(str));
//reduce()对数据执行累加操作，返回结果
map.reduceValues(1,
v->Integer.valueOf(v),//转换器
Integer::sum);//聚合操作
//reduce***ToLong/Integer/Double(),提供int，long，double原始类型的输出；
}
线程安全的Set
/**
* 获取一个大的，线程安全的Set
*/
private void setView(){
//返回一个线程安全的Set,实际上是对ConcurrentHashMap<K,Boolean>的封装
Set<String> keys=map.newKeySet();
Set<String> keySet=ConcurrentHashMap.<String>newKeySet();
//delete,无法添加add（因为没有值）
keys.remove("55555");
//参数提供了一个默认值，如果添加一个键，对应的值不存在，则使用默认值
keys=map.keySet(1);
//add
keys.add("7777777");
}