【发布时间】:2020-05-01 15:16:08
【问题描述】:
我正在寻找一种将并行流与 RealmResults 列表一起使用的方法。问题是 Realm 对在线程之间使用 RealmResults 有限制。
这是我想使用的代码:
RealmResults<RealmModel> entitiesDAO = query.findAll();
final ModelMapper modelMapper = new ModelMapper();
final List<In> entities = entitiesDAO.stream().parallel().map(entityDAO -> {
final In entity = modelMapper.map(entityDAO, typeIn);
return entity;
}).collect(toList());
//This code works perfectly without parallel streams:
/*final List<In> entities = entitiesDAO.stream().map(entityDAO -> {
final In entity = modelMapper.map(entityDAO, typeIn);
return entity;
}).collect(toList());*/
【问题讨论】:
标签: android parallel-processing realm java-stream