如何解决如何在Android Room中使用ExecutorService?
我将ExecutorService与Android Room配合使用,以避免insetAsyncTasks中出现多个。我在这篇帖子中使用的是Debanjan示例:link,但我对其进行了一些修改。
问题是我没有任何异常,但是没有插入任何东西。
DaoAsyncProcessor:
public abstract class DaoAsyncProcessor<T> {
public interface DaoProcessCallback<T>{
void onResult(T result);
}
private DaoProcessCallback daoProcessCallback;
public DaoAsyncProcessor(DaoProcessCallback daoProcessCallback) {
this.daoProcessCallback = daoProcessCallback;
}
protected abstract T doAsync();
public void start(){
new DaoProcessAsyncTask().execute();
}
private class DaoProcessAsyncTask extends AsyncTask<Void,Void,T> {
@Override
protected T doInBackground(Void... params) {
return doAsync();
}
@Override
protected void onPostExecute(T t) {
if(daoProcessCallback != null)
daoProcessCallback.onResult(t);
}
}
}
存储库:
public void createUpdate(final Projects item){
EncertDatabase.databaseWriteExecutor.execute(() ->{
if(item!=null){
if(item.getId()==null){
encertDAO.insert(item);
}
else {
encertDAO.update(item);
}
}else {
Log.e("Krkec","Item was null");
}
});
}
数据库:
public abstract class EncertDatabase extends RoomDatabase {
private static volatile EncertDatabase INSTANCE;
public abstract EncertDAO encertDAO();
private static final int NUMBER_OF_THREADS = 4;
public static final ExecutorService databaseWriteExecutor =
Executors.newFixedThreadPool(NUMBER_OF_THREADS);
public static EncertDatabase getDatabase(final Context context){
if(INSTANCE== null){
synchronized (EncertDatabase.class){
if (INSTANCE ==null){
INSTANCE = Room.databaseBuilder(context.getApplicationContext(),EncertDatabase.class,"encertDatabase").fallbackToDestructiveMigration().build();
}
}
}
return INSTANCE;
}
}
我在做什么错了?
解决方法
使用 setQueryExecutor 将 executor 服务实例分配给 db builder 实例
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。