记录一次ConcurrentModificationException排查

问题背景:

android项目在迭代的过程中,有个获取定位的功能模块,一直有个异常居高不下。
尝试修改了好几版,都没有解决掉这个问题
日志如下:

01-04 19:55:57.770 24194 24194 E AndroidRuntime: FATAL EXCEPTION: main
1501-04 19:55:57.770 24194 24194 E AndroidRuntime: Process: com.**, PID: 24194
1601-04 19:55:57.770 24194 24194 E AndroidRuntime: java.util.ConcurrentModificationException
1701-04 19:55:57.770 24194 24194 E AndroidRuntime: at java.util.ArrayList$Itr.next(ArrayList.java:860)
1801-04 19:55:57.770 24194 24194 E AndroidRuntime: at aiv$b.a(LocationManager.java:124)
1901-04 19:55:57.770 24194 24194 E AndroidRuntime: at com.baidu.location.LocationClient.b(Unknown Source:66)
2001-04 19:55:57.770 24194 24194 E AndroidRuntime: at com.baidu.location.LocationClient.a(Unknown Source:0)
2101-04 19:55:57.770 24194 24194 E AndroidRuntime: at com.baidu.location.LocationClient$a.handleMessage(Unknown Source:171)
2201-04 19:55:57.770 24194 24194 E AndroidRuntime: at android.os.Handler.dispatchMessage(Handler.java:107)
2301-04 19:55:57.770 24194 24194 E AndroidRuntime: at android.os.Looper.loop(Looper.java:227)
2401-04 19:55:57.770 24194 24194 E AndroidRuntime: at android.app.ActivityThread.main(ActivityThread.java:7668)
2501-04 19:55:57.770 24194 24194 E AndroidRuntime: at java.lang.reflect.Method.invoke(Native Method)
2601-04 19:55:57.770 24194 24194 E AndroidRuntime: at com.android.internal.os.RuntimeInit$MethodAndArgsCaller.run(RuntimeInit.java:548)
2701-04 19:55:57.770 24194 24194 E AndroidRuntime: at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:960)

该错误日志其实很熟悉,就是 fail-fast机制(java集合(Collection)中的一种错误机制)。

场景复现:

最原始代码版本:

public final class LocationManager {
    private static final class LocationManagerInstance {
        private static final LocationManager INSTANCE = new LocationManager();
    }

    public static LocationManager getInstance() {
        return LocationManagerInstance.INSTANCE;
    }

    private LocationManager() {
        // do nothing
    }

    private static List<SoftReference<IBdLocationListener>> mWeakReferences = new ArrayList<>();
    //    mILocationListener;
    private static MyLocationListener myListener = new MyLocationListener();

    private LocationClient mLocationClient;

    /**
     * 开始申请 定位
     */
    public void startLocate(IBdLocationListener locationListener, Application application) {
        mLocationClient = new LocationClient(application);
            if (mLocationClient != null) {
                mWeakReferences.add(new SoftReference<>(locationListener));
                if (locationListener != null) {
                    locationListener.startLocation();
                }
                LogUtils.i("start collect location info: thread name:" + Thread.currentThread().getName());
                mLocationClient.start();

            }
    }

    /**
     * 取消注册
     *
     * @param listener
     */
    public void unRegisterListener(IBdLocationListener listener) {
        synchronized (LocationManager.class) {

            if (mWeakReferences == null || mWeakReferences.isEmpty()) {
                return;
            }

            for (int i = mWeakReferences.size() - 1; i >= 0; i--) {
                SoftReference<IBdLocationListener> itemListener = mWeakReferences.get(i);
                if (itemListener != null && itemListener.get() != null && itemListener.get() == listener) {
                    mWeakReferences.remove(i);
                }
            }

        }

    }

    //BDAbstractLocationListener
    public static class MyLocationListener extends BDAbstractLocationListener {
        @Override
        public void onReceiveLocation(BDLocation location) {
                                if (mWeakReferences != null) {

                                    Iterator<SoftReference<IBdLocationListener>> iterator = mWeakReferences.iterator();
                                    while (iterator.hasNext()) {
                                        SoftReference<IBdLocationListener> next = iterator.next();
                                        if (next == null || next.get() == null) {
                                            iterator.remove();
                                            continue;
                                        }
                                        if (next.get() != null) {
                                            next.get().onReceiveLocation(location);
                                        }
                                    }
                                }
                            }
                    });

        }
    }
}

由于是涉及到定位sdk,猜测是多线程没加锁导致的,数据不同步。于是直接加锁尝试解决上线(本身概率性事件,复现概率不是很高)。
修改如下版本:

public final class LocationManager {
    private static final class LocationManagerInstance {
        private static final LocationManager INSTANCE = new LocationManager();
    }

    public static LocationManager getInstance() {
        return LocationManagerInstance.INSTANCE;
    }

    private LocationManager() {
        // do nothing
    }

    private static List<SoftReference<IBdLocationListener>> mWeakReferences = new ArrayList<>();
    //    mILocationListener;
    private static MyLocationListener myListener = new MyLocationListener();

    private LocationClient mLocationClient;

    /**
     * 开始申请 定位
     */
    public void startLocate(IBdLocationListener locationListener, Application application) {
        mLocationClient = new LocationClient(application);
        synchronized (LocationManager.class) {
            if (mLocationClient != null) {
                mWeakReferences.add(new SoftReference<>(locationListener));
                if (locationListener != null) {
                    locationListener.startLocation();
                }
                mLocationClient.start();
            }
        }
    }


    /**
     * 取消注册
     *
     * @param listener
     */
    public void unRegisterListener(IBdLocationListener listener) {
        synchronized (LocationManager.class) {
            if (mWeakReferences == null || mWeakReferences.isEmpty()) {
                return;
            }
            for (int i = mWeakReferences.size() - 1; i >= 0; i--) {
                SoftReference<IBdLocationListener> itemListener = mWeakReferences.get(i);
                if (itemListener != null && itemListener.get() != null && itemListener.get() == listener) {
                    mWeakReferences.remove(i);
                }
            }

        }

    }

    //BDAbstractLocationListener
    public static class MyLocationListener extends BDAbstractLocationListener {
        @Override
        public void onReceiveLocation(BDLocation location) {
                            synchronized (LocationManager.class) {
                                if (mWeakReferences != null) {
                                    Iterator<SoftReference<IBdLocationListener>> iterator = mWeakReferences.iterator();
                                    while (iterator.hasNext()) {
                                        SoftReference<IBdLocationListener> next = iterator.next();
                                        if (next == null || next.get() == null) {
                                            iterator.remove();
                                            continue;
                                        }
                                        if (next.get() != null) {
                                            next.get().onReceiveLocation(location);
                                        }
                                    }
                                }
                            }
        }
    }
}

一直以为是线程不同步导致的,但是发现加上锁之后还是会报这个异常。

思考:

1.难道锁对象不是同一个?(确认过确实是同一个)
2.同一个线程能同时 执行两处代码?(差点颠覆了我这么多年 理论的认知)

哎,经过网上查找资料。确实也是和自己理解的一样:
参考资料:https://www.cnblogs.com/dolphin0520/p/3933551.html

对于该异常的结论:

1.在同一个线程中 确实也会报这个错误:
测试代码如下:

public class Test {
    public static void main(String[] args)  {
        ArrayList<Integer> list = new ArrayList<Integer>();
        list.add(2);
        Iterator<Integer> iterator = list.iterator();
        while(iterator.hasNext()){
            Integer integer = iterator.next();
            if(integer==2)
                list.remove(integer);
        }
    }
}

2.多线程中更会报这个错误:
测试代码如下:

public class Test {
    private static ArrayList<String> testList = new ArrayList<>();

    public static void main(String[] args) {

        for (int i = 0; i < 10; i++) {

            new Thread(new Runnable() {
                @Override
                public void run() {
                    for (int j = 0; j < 100000; j++) {
                        testList.add("" + j);

                    }
                }
            }).start();
        }


        for (int i = 0; i < 10; i++) {

            new Thread(new Runnable() {
                @Override
                public void run() {

                    for (int j = 0; j < 10000; j++) {

                        for (String s : testList) {

                            System.out.println(s);
                        }
                    }
                }
            }).start();
        }

    }
}

思考:

通过测试以及 网上查阅资料,解决方法无非就是两种(加锁 或者使用 CopyOnWriteArrayList 线程安全的集合),
那为啥我的代码,还是报错呢???哎,苦恼....

最终结论:

经过重新进行了代码逻辑走查,发现:在遍历所有监听器对象并且调用onReceiveLocation方法的时候。该对象的回调中,又会调用unRegisterListener 方法,
查看unRegisterListener方法:发现该方法中会进行 集合的删除操作。
看到这,这不就是单线程中 产生该异常的原因嘛。我擦。。。。尼玛。。。

这种迷惑性比较强的代码,确实有点坑爹。哎,学艺不精啊。。

最终修复版本代码:

public final class LocationManager {
    private static final class LocationManagerInstance {
        private static final LocationManager INSTANCE = new LocationManager();
    }

    public static LocationManager getInstance() {
        return LocationManagerInstance.INSTANCE;
    }

    private LocationManager() {
        // do nothing
    }

    private static List<SoftReference<IBdLocationListener>> mWeakReferences = new ArrayList<>();
    //    mILocationListener;
    private static MyLocationListener myListener = new MyLocationListener();

    private LocationClient mLocationClient;

    /**
     * 开始申请 定位
     */
    public void startLocate(IBdLocationListener locationListener, Application application) {
        mLocationClient = new LocationClient(application);
      
        synchronized (LocationManager.class) {
            if (mLocationClient != null) {
                mWeakReferences.add(new SoftReference<>(locationListener));
                if (locationListener != null) {
                    locationListener.startLocation();
                }
                mLocationClient.start();

            }
        }
    }

    /**
     * 取消注册
     *
     * @param listener
     */
    public void unRegisterListener(IBdLocationListener listener) {
        synchronized (LocationManager.class) {

            if (mWeakReferences == null || mWeakReferences.isEmpty()) {
                return;
            }
            for (int i = mWeakReferences.size() - 1; i >= 0; i--) {
                SoftReference<IBdLocationListener> itemListener = mWeakReferences.get(i);
                if (itemListener != null && itemListener.get() != null && itemListener.get() == listener) {
                    // 在此处不要删除,重置为null。在调用处,使用iterator 遍历的时候,删除
                    mWeakReferences.set(i, null);
                }
            }

        }

    }

    //BDAbstractLocationListener
    public static class MyLocationListener extends BDAbstractLocationListener {
        @Override
        public void onReceiveLocation(BDLocation location) {
                            synchronized (LocationManager.class) {
                                if (mWeakReferences != null) {

                                    Iterator<SoftReference<IBdLocationListener>> iterator = mWeakReferences.iterator();
                                    while (iterator.hasNext()) {
                                        SoftReference<IBdLocationListener> next = iterator.next();
                                        if (next == null || next.get() == null) {
                                            iterator.remove();
                                            continue;
                                        }
                                        if (next.get() != null) {
                                            next.get().onReceiveLocation(location);
                                        }
                                    }
                                }
                            }
        }
    }
}

结论虽然是很简单,但是排查过程中确实是很痛苦的。。。
做一下开发过程中的简单记录吧,加油!!!

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 203,547评论 6 477
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,399评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 150,428评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,599评论 1 274
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,612评论 5 365
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,577评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,941评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,603评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,852评论 1 297
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,605评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,693评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,375评论 4 318
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,955评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,936评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,172评论 1 259
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 43,970评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,414评论 2 342

推荐阅读更多精彩内容