当前位置：网站首页>再见SharedPreferences，你好MMKV！

再见SharedPreferences，你好MMKV！

2022-04-21 18:11:00 【InfoQ】

public?boolean?commit()?{

//?在当前线程将数据保存到mMap中

MemoryCommitResult?mcr?=?commitToMemory();

SharedPreferencesImpl.this.enqueueDiskWrite(mcr,?null);

try?{

//?如果是在singleThreadPool中执行写入操作，通过await()暂停主线程，直到写入操作完成。

// commit的同步性就是通过这里完成的。

mcr.writtenToDiskLatch.await();

}?catch?(InterruptedException?e)?{

return?false;

}

*?回调的时机：

*?1.?commit是在内存和硬盘操作均结束时回调

*?2.?apply是内存操作结束时就进行回调

notifyListeners(mcr);

return?mcr.writeToDiskResult;

}

如上所示

commit有返回值，表示修改是否提交成功。

commit提交是同步的，直到磁盘操作成功后才会完成。

所以当数据量比较大时，使用commit很可能引起ANR。

Apply导致的ANR

commit是同步的，同时SP也提供了异步的apply。

apply是将修改数据原子提交到内存, 而后异步真正提交到硬件磁盘, 而commit是同步的提交到硬件磁盘，因此，在多个并发的提交commit的时候，他们会等待正在处理的commit保存到磁盘后在操作，从而降低了效率。

而apply只是原子的提交到内容，后面有调用apply的函数的将会直接覆盖前面的内存数据，这样从一定程度上提高了很多效率。

但是apply同样会引起ANR的问题。

public?void?apply(

Android开源项目《ali1024.coding.net/public/P7/Android/git》

)?{

final?long?startTime?=?System.currentTimeMillis();

final?MemoryCommitResult?mcr?=?commitToMemory();

final?Runnable?awaitCommit?=?new?Runnable()?{

@Override

public?void?run()?{

mcr.writtenToDiskLatch.await();?//?等待

......

}

};

//?将?awaitCommit?添加到队列?QueuedWork?中

QueuedWork.addFinisher(awaitCommit);

Runnable?postWriteRunnable?=?new?Runnable()?{

@Override

public?void?run()?{

awaitCommit.run();

QueuedWork.removeFinisher(awaitCommit);

}

};

SharedPreferencesImpl.this.enqueueDiskWrite(mcr,?postWriteRunnable);

}

将一个?awaitCommit?的?Runnable?任务，添加到队列?QueuedWork?中，在awaitCommit中会调用?await()?方法等待，在?handleStopService?、handleStopActivity?等等生命周期会以这个作为判断条件，等待任务执行完毕。

将一个?postWriteRunnable?的?Runnable?写任务，通过enqueueDiskWrite?方法，将写入任务加入到队列中，而写入任务在一个线程中执行。

为了保证异步任务及时完成，当生命周期处于?handleStopService()?、handlePauseActivity()?、?handleStopActivity()?的时候会调用QueuedWork.waitToFinish()?会等待写入任务执行完毕。

private?static?final?ConcurrentLinkedQueue<Runnable>?sPendingWorkFinishers?=

new?ConcurrentLinkedQueue<Runnable>();

public?static?void?waitToFinish()?{

Runnable?toFinish;

while?((toFinish?=?sPendingWorkFinishers.poll())?!=?null)?{

toFinish.run();?//?相当于调用?

mcr.writtenToDiskLatch.await()

?方法

}

sPendingWorkFinishers?是?ConcurrentLinkedQueue?实例，apply?方法会将写入任务添加到?sPendingWorkFinishers队列中，在单个线程的线程池中执行写入任务，线程的调度并不由程序来控制，也就是说当生命周期切换的时候，任务不一定处于执行状态。

toFinish.run()?方法，相当于调用?mcr.writtenToDiskLatch.await()?方法，会一直等待。

waitToFinish()?方法就做了一件事，会一直等待写入任务执行完毕，其它什么都不做，当有很多写入任务，会依次执行，当文件很大时，效率很低，造成 ANR 就不奇怪了。

所以当数据量比较大时，apply也会造成ANR。

getXXX() 导致ANR

不仅是写入操作，所有?getXXX()?方法都是同步的，在主线程调用?get?方法，必须等待 SP 加载完毕，也有可能导致ANR。调用?getSharedPreferences()?方法，最终会调用SharedPreferencesImpl#startLoadFromDisk()?方法开启一个线程异步读取数据。

private?final?Object?mLock?=?new?Object();

private?bool

《Android学习笔记总结+最新移动架构视频+大厂安卓面试真题+项目实战源码讲义》开源

ean?mLoaded?=?false;

private?void?startLoadFromDisk()?{

synchronized?(mLock)?{

mLoaded?=?false;

}

new?Thread("SharedPreferencesImpl-load")?{

public?void?run()?{

loadFromDisk();

}