|
|
|
@ -74,11 +74,7 @@ public abstract class TbAbstractDataSubCtx<T extends AbstractDataQuery<? extends |
|
|
|
|
|
|
|
@Override |
|
|
|
protected synchronized void update() { |
|
|
|
long start = System.currentTimeMillis(); |
|
|
|
PageData<EntityData> newData = findEntityData(); |
|
|
|
long end = System.currentTimeMillis(); |
|
|
|
stats.getRegularQueryInvocationCnt().incrementAndGet(); |
|
|
|
stats.getRegularQueryTimeSpent().addAndGet(end - start); |
|
|
|
Map<EntityId, EntityData> oldDataMap; |
|
|
|
if (data != null && !data.getData().isEmpty()) { |
|
|
|
oldDataMap = data.getData().stream().collect(Collectors.toMap(EntityData::getEntityId, Function.identity(), (a, b) -> a)); |
|
|
|
|