Android性能调优之Copyonwrite_android多线程拷贝文件-程序员宅基地

技术标签: java  android  copyonwrite  Android  

写入时复制(CopyOnWrite)思想
  写入时复制(CopyOnWrite,简称COW)思想是计算机程序设计领域中的一种优化策略。其核心思想是,如果有多个调用者(Callers)同时要求相同的资源(如内存或者是磁盘上的数据存储),他们会共同获取相同的指针指向相同的资源,直到某个调用者视图修改资源内容时,系统才会真正复制一份专用副本(private copy)给该调用者,而其他调用者所见到的最初的资源仍然保持不变。这过程对其他的调用者都是透明的(transparently)。此做法主要的优点是如果调用者没有修改资源,就不会有副本(private copy)被创建,因此多个调用者只是读取操作时可以共享同一份资源。
CopyOnWriteArrayList的实现原理
  在使用CopyOnWriteArrayList之前,我们先阅读其源码了解下它是如何实现的。以下代码是向CopyOnWriteArrayList中add方法的实现(向CopyOnWriteArrayList里添加元素),可以发现在添加的时候是需要加锁的,否则多线程写的时候会Copy出N个副本出来。
复制代码

/**
     * Appends the specified element to the end of this list.
     *
     * @param e element to be appended to this list
     * @return <tt>true</tt> (as specified by {@link Collection#add})
     */
    public boolean add(E e) {
    final ReentrantLock lock = this.lock;
    lock.lock();
    try {
        Object[] elements = getArray();
        int len = elements.length;
        Object[] newElements = Arrays.copyOf(elements, len + 1);
        newElements[len] = e;
        setArray(newElements);
        return true;
    } finally {
        lock.unlock();
    }
    }
    

复制代码
  读的时候不需要加锁,如果读的时候有多个线程正在向CopyOnWriteArrayList添加数据,读还是会读到旧的数据,因为写的时候不会锁住旧的CopyOnWriteArrayList。

public E get(int index) {
    return get(getArray(), index);
}

JDK中并没有提供CopyOnWriteMap,我们可以参考CopyOnWriteArrayList来实现一个,基本代码如下:

复制代码

import java.util.Collection;
import java.util.Map;
import java.util.Set;
 
public class CopyOnWriteMap<K, V> implements Map<K, V>, Cloneable {
    private volatile Map<K, V> internalMap;
 
    public CopyOnWriteMap() {
        internalMap = new HashMap<K, V>();
    }
 
    public V put(K key, V value) {
 
        synchronized (this) {
            Map<K, V> newMap = new HashMap<K, V>(internalMap);
            V val = newMap.put(key, value);
            internalMap = newMap;
            return val;
        }
    }
 
    public V get(Object key) {
        return internalMap.get(key);
    }
 
    public void putAll(Map<? extends K, ? extends V> newData) {
        synchronized (this) {
            Map<K, V> newMap = new HashMap<K, V>(internalMap);
            newMap.putAll(newData);
            internalMap = newMap;
        }
    }
}

复制代码
  实现很简单,只要了解了CopyOnWrite机制,我们可以实现各种CopyOnWrite容器,并且在不同的应用场景中使用。

几个要点
实现了List接口
内部持有一个ReentrantLock lock = new ReentrantLock();
底层是用volatile transient声明的数组 array
读写分离,写时复制出一个新的数组,完成插入、修改或者移除操作后将新数组赋值给array
注:

volatile (挥发物、易变的):变量修饰符,只能用来修饰变量。volatile修饰的成员变量在每次被线程访问时,都强迫从共享内存中重读该成员变量的值。而且,当成员变量发生变 化时,强迫线程将变化值回写到共享内存。这样在任何时刻,两个不同的线程总是看到某个成员变量的同一个值。

transient (暂短的、临时的):修饰符,只能用来修饰字段。在对象序列化的过程中,标记为transient的变量不会被序列化。

增删改查
  1)增

复制代码

public boolean add(E e) {
    final ReentrantLock lock = this.lock;
    //获得锁
    lock.lock();
    try {
        Object[] elements = getArray();
        int len = elements.length;
        //复制一个新的数组
        Object[] newElements = Arrays.copyOf(elements, len + 1);
        //插入新值
        newElements[len] = e;
        //将新的数组指向原来的引用
        setArray(newElements);
        return true;
    } finally {
        //释放锁
        lock.unlock();
    }
}

   
public void add(int index, E element) {
    final ReentrantLock lock = this.lock;
    lock.lock();
    try {
        Object[] elements = getArray();
        int len = elements.length;
        if (index > len || index < 0)
            throw new IndexOutOfBoundsException("Index: "+index+
                                                ", Size: "+len);
        Object[] newElements;
        int numMoved = len - index;
        if (numMoved == 0)
            newElements = Arrays.copyOf(elements, len + 1);
        else {
            newElements = new Object[len + 1];
            System.arraycopy(elements, 0, newElements, 0, index);
            System.arraycopy(elements, index, newElements, index + 1,
                             numMoved);
        }
        newElements[index] = element;
        setArray(newElements);
    } finally {
        lock.unlock();
    }
}

复制代码
  2)删

复制代码

public E remove(int index) {
    final ReentrantLock lock = this.lock;
    //获得锁
    lock.lock();
    try {
        Object[] elements = getArray();
        int len = elements.length;
        E oldValue = get(elements, index);
        int numMoved = len - index - 1;
        if (numMoved == 0)
            //如果删除的元素是最后一个,直接复制该元素前的所有元素到新的数组
            setArray(Arrays.copyOf(elements, len - 1));
        else {
            //创建新的数组
            Object[] newElements = new Object[len - 1];
            //将index+1至最后一个元素向前移动一格
            System.arraycopy(elements, 0, newElements, 0, index);
            System.arraycopy(elements, index + 1, newElements, index,
                             numMoved);
            setArray(newElements);
        }
        return oldValue;
    } finally {
        lock.unlock();
    }
}

复制代码
3)改

复制代码

public E set(int index, E element) {
    final ReentrantLock lock = this.lock;
    //获得锁
    lock.lock();
    try {
        Object[] elements = getArray();
        E oldValue = get(elements, index);

        if (oldValue != element) {
            int len = elements.length;
            //创建新数组
            Object[] newElements = Arrays.copyOf(elements, len);
            //替换元素
            newElements[index] = element;
            //将新数组指向原来的引用
            setArray(newElements);
        } else {
            // Not quite a no-op; ensures volatile write semantics
            setArray(elements);
        }
        return oldValue;
    } finally {
        //释放锁
        lock.unlock();
    }
}

复制代码
4)查

//直接获取index对应的元素
public E get(int index) {return get(getArray(), index);}
private E get(Object[] a, int index) {return (E) a[index];}
CopyOnWrite的应用场景
  CopyOnWrite并发容器用于读多写少的并发场景。比如白名单,黑名单,商品类目的访问和更新场景,假如我们有一个搜索网站,用户在这个网站的搜索框中,输入关键字搜索内容,但是某些关键字不允许被搜索。这些不能被搜索的关键字会被放在一个黑名单当中,黑名单每天晚上更新一次。当用户搜索时,会检查当前关键字在不在黑名单当中,如果在,则提示不能搜索。实现代码如下:

复制代码

import java.util.Map;
 
import com.ifeve.book.forkjoin.CopyOnWriteMap;
 
/**
 * 黑名单服务
 *
 * @author fangtengfei
 *
 */
public class BlackListServiceImpl {
 
    private static CopyOnWriteMap<String, Boolean> blackListMap = new CopyOnWriteMap<String, Boolean>(
            1000);
 
    public static boolean isBlackList(String id) {
        return blackListMap.get(id) == null ? false : true;
    }
 
    public static void addBlackList(String id) {
        blackListMap.put(id, Boolean.TRUE);
    }
 
    /**
     * 批量添加黑名单
     *
     * @param ids
     */
    public static void addBlackList(Map<String,Boolean> ids) {
        blackListMap.putAll(ids);
    }
 
}

复制代码
代码很简单,但是使用CopyOnWriteMap需要注意两件事情:

1. 减少扩容开销。根据实际需要,初始化CopyOnWriteMap的大小,避免写时CopyOnWriteMap扩容的开销。

2. 使用批量添加。因为每次添加,容器每次都会进行复制,所以减少添加次数,可以减少容器的复制次数。如使用上面代码里的addBlackList方法。

CopyOnWrite的缺点 
CopyOnWrite容器有很多优点,但是同时也存在两个问题,即内存占用问题和数据一致性问题。所以在开发的时候需要注意一下。

内存占用问题。因为CopyOnWrite的写时复制机制,所以在进行写操作的时候,内存里会同时驻扎两个对象的内存,旧的对象和新写入的对象(注意:在复制的时候只是复制容器里的引用,只是在写的时候会创建新对象添加到新容器里,而旧容器的对象还在使用,所以有两份对象内存)。如果这些对象占用的内存比较大,比如说200M左右,那么再写入100M数据进去,内存就会占用300M,那么这个时候很有可能造成频繁的Yong GC和Full GC。之前我们系统中使用了一个服务由于每晚使用CopyOnWrite机制更新大对象,造成了每晚15秒的Full GC,应用响应时间也随之变长。

针对内存占用问题,可以通过压缩容器中的元素的方法来减少大对象的内存消耗,比如,如果元素全是10进制的数字,可以考虑把它压缩成36进制或64进制。或者不使用CopyOnWrite容器,而使用其他的并发容器,如ConcurrentHashMap。

数据一致性问题。CopyOnWrite容器只能保证数据的最终一致性,不能保证数据的实时一致性。所以如果你希望写入的的数据,马上能读到,请不要使用CopyOnWrite容器。

CopyOnWriteArrayList为什么并发安全且性能比Vector好
 我知道Vector是增删改查方法都加了synchronized,保证同步,但是每个方法执行的时候都要去获得锁,性能就会大大下降,而CopyOnWriteArrayList 只是在增删改上加锁,但是读不加锁,在读方面的性能就好于Vector,CopyOnWriteArrayList支持读多写少的并发情况。

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/kururunga/article/details/111469010

智能推荐

python+opencv实现人脸识别笔记三(训练模型+保存模型)_tensorflow实现人脸识别(3)--------对人脸样本进行训练,保存人脸识别模型-程序员宅基地

文章浏览阅读6.9k次,点赞8次,收藏81次。一在进行训练之前,我们首先需要对图片进行修改,使其长宽相等。新建 训练模型.pyimport tensorflow as tfimport cv2import numpy as npimport osimport randomimport sysfrom sklearn.model_selection import train_test_splitmy_faces_path ..._tensorflow实现人脸识别(3)--------对人脸样本进行训练,保存人脸识别模型

Unity | AssetBundle资源包的加密与解密(恺撒加密)_游戏ab加密文件解包教程-程序员宅基地

文章浏览阅读5.1k次。一、创建预制体:用Sphere与Cube临时创建了一个物体,就叫Sphere吧;二、将这个预制体Sphere打包成assetbundle包,具体介绍可点击这里进行参考(是我之前写的文章);选中Sphere预制体,设置AssetBundle名称为myab; 点击Unity菜单栏AssetBundle/AssetBundle_Window按钮。附上本次打AB包的相关代码(此代码需要放在Edi..._游戏ab加密文件解包教程

Registered university fake degree from buydegree8.com.buy fake diploma. degree-程序员宅基地

文章浏览阅读96次。Best Phony Anglia Ruskin University Diploma sample.Fake Anglia Ruskin University DiplomaPhony Anglia Ruskin University Diploma .jpgBest Phony Anglia Ruskin University Diploma sample.Fake Anglia Rusk..._buy fake degree

软考-计算机网络概论-海明码(HC)与循环冗余校验码(CRC)的计算_crchch-程序员宅基地

文章浏览阅读722次。海明码海明码-利用奇偶性来检错和纠错的校验方法。其在数据位之间的特定位置插入k个校验位,通过扩大码距来实现检错和纠错。设数据位是n位,校验位是k位,则n和k必须满足:2^k-1>=n+k。设数据为01101001根据2^n的那一列存放校验位的规则,可以共需3个校验位。12 11 10 9 8 7 6 5 4 3 2 1 0 1 1 0 1 0 0 1 信息位 _ _ _ _ ..._crchch

Keepalived的脑裂问题与解决_如何解决keepalived脑裂问题?-程序员宅基地

文章浏览阅读991次。Keepalived的脑裂问题与解决目录脑裂产生的原因:常见的解决方案:1、什么是脑裂2、解决keepalived脑裂问题3、曾经碰到的一个keepalived脑裂的问题(如果启用了iptables,不设置"系统接收VRRP协议"的规则,就会出现脑裂)4、预防keepalived脑裂问题5、推荐自己写脚本Keepalived的作用是检测服务器的状态,如果有一台web服务器宕机,或工作出现故障,Keepalived将检测到,并将有故障的服务器从系统中剔除,同时使用其他服务器_如何解决keepalived脑裂问题?

Qt5.4以上版本使用MySQL数据库(避免各种坑)_qt5.4.0连接的mysql数据库最高版本-程序员宅基地

文章浏览阅读9.3k次,点赞2次,收藏3次。[0]为什么要强调5.4以上版本呢?因为我的Qt是这个版本,它已经装好了MySQL驱动.其他版本的不清楚.[1]安装Qt的时候我们一定要勾选源码,或者全部安装也可以,这样才会有Src目录,这是接下来要用到的.[2]安装MySQL的时候不要用默认安装的路径,那个里面有空格(比如/program[ 我是空格]files/…),Qt好像不能识别.[3]最好使用.zip的MySQL进行安装,用命令行配置安装_qt5.4.0连接的mysql数据库最高版本

随便推点

SpringBoot中@Autowired爆红原理及解决方案_spring 构造注入 参数可能为空 ,构造参数 爆红-程序员宅基地

文章浏览阅读1.2w次,点赞16次,收藏44次。SpringBoot中的service层经常需要将mapper注入进来,但是注入一个mapper接口时经常会爆红代码: @Autowired private UserMapper userMapper;图片:爆红的原因是@Autowired是Spring的注解,提示找不到对他的bean,因为你没有显示的将userMapper注入到Spring容器中去管理。解决方案1这种情况..._spring 构造注入 参数可能为空 ,构造参数 爆红

三面腾讯,已拿offer!绝对干货分享_腾讯资深开发三面分享-程序员宅基地

文章浏览阅读41次。说明Java生鲜电商平台中由于采用了微服务架构进行业务的处理,买家,卖家,配送,销售,供应商等进行服务化,但是不可避免存在分布式事务的问题。业界有很多的解决方案,对此我相信大家都百度一下子就有很多,但是我巨人大哥想说的是:微服务架构中应当尽量避免分布式事务。下面就是来讨论下,分布式事务中主要聚焦于强一致性和最终一致性的解决方案。经过我自己的梳理,手绘了整个Spring5的架构脑图这份Spring5的架构脑图我总共是将其整个知识分为以下6个部分:1、Spring框架介绍2、IOC容器3、A_腾讯资深开发三面分享

uniapp的map组件实现轨迹回放(小程序)_uniapp的map轨迹回放-程序员宅基地

文章浏览阅读8k次,点赞6次,收藏25次。<map style="width: 100%; height: 100vh;" id="myMap" :latitude="latitude" :include-points="markers" :longitude="longitude" :polyline="polyline" :markers="markers" ></map>首先使用uniapp的map组件,根据后端给的数据来设置对应属性:latitude、longitu_uniapp的map轨迹回放

微信小程序 录音文件格式silk 坑_silk格式-程序员宅基地

文章浏览阅读2.1w次。不好意思,误导大家了,这种将silk解密的方式只是在小程序测试的时候可以,上线以后这种方法是不行的,还是需要使用解密转码。参见:https://github.com/kn007/silk-v3-decoder微信小程序的录音文件就是个坑。。。录音文件为silk格式,说是silk其实是base64加密后的webm格式,只需将其转为webm格式即可。我在解决问题的过程中,学到了_silk格式

python中,json.load()和json.loads()的区别-程序员宅基地

文章浏览阅读1.2k次。相同点:两者都是转换成字典格式输出不同点:其中json.load()方法是从json文件读取json,传入的是文件对象。with open(file_path, 'r', encoding='utf-8') as f: # 传入的是一个文件对象; ret: 结果是一个字典 ret = json.load(f)json.loads()方法是直接读取json数据,传入的是json格式的字符串ret = json.loads('{'key1':'value1','key2':'val_json.load()和json.loads()的区别

Blender自定义导入插件的编写_blender 导入py插件-程序员宅基地

文章浏览阅读1.9k次。Blender自定义导入插件的编写背景在阅读《3D Game Engine Design》随书源码时,发现有大量的自定义的后缀为txt的模型文件。而且在其它书籍,如OpenGL红宝书中,也有类似的自定义模型数据,所以产生了将其加载到Blender来渲染的想法。此插件的功能就是加载定义模型文件。软件版本Blender: 2.81 (sub 16)OS: Windows 10 x64插件的安装打开路径为: Edit / Preferences… / Add-ons点击[Install._blender 导入py插件