dendi-wang/thingsboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Performance Improvement on start

Browse Source
This commit is contained in:
Andrew Shvayka 2019-11-26 12:49:11 +02:00
parent 81e6cccac9
commit 42a15097c6
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
application/src/main/java/org/thingsboard/server/service/state/DefaultDeviceStateService.java
View File

@ -135,6 +135,8 @@ public class DefaultDeviceStateService implements DeviceStateService {
@Getter @Getter
private int initFetchPackSize; private int initFetchPackSize;
private volatile boolean clusterUpdatePending = false;
private ListeningScheduledExecutorService queueExecutor; private ListeningScheduledExecutorService queueExecutor;
private ConcurrentMap<TenantId, Set<DeviceId>> tenantDevices = new ConcurrentHashMap<>(); private ConcurrentMap<TenantId, Set<DeviceId>> tenantDevices = new ConcurrentHashMap<>();
private ConcurrentMap<DeviceId, DeviceStateData> deviceStates = new ConcurrentHashMap<>(); private ConcurrentMap<DeviceId, DeviceStateData> deviceStates = new ConcurrentHashMap<>();
@ -192,8 +194,11 @@ public class DefaultDeviceStateService implements DeviceStateService {
@Override @Override
public void onClusterUpdate() { public void onClusterUpdate() {
if (!clusterUpdatePending) {
clusterUpdatePending = true;
queueExecutor.submit(this::onClusterUpdateSync); queueExecutor.submit(this::onClusterUpdateSync);
} }
}
@Override @Override
public void onRemoteMsg(ServerAddress serverAddress, byte[] data) { public void onRemoteMsg(ServerAddress serverAddress, byte[] data) {
@ -220,6 +225,7 @@ public class DefaultDeviceStateService implements DeviceStateService {
} }
private void onClusterUpdateSync() { private void onClusterUpdateSync() {
clusterUpdatePending = false;
List<Tenant> tenants = tenantService.findTenants(new TextPageLink(Integer.MAX_VALUE)).getData(); List<Tenant> tenants = tenantService.findTenants(new TextPageLink(Integer.MAX_VALUE)).getData();
for (Tenant tenant : tenants) { for (Tenant tenant : tenants) {
List<ListenableFuture<DeviceStateData>> fetchFutures = new ArrayList<>(); List<ListenableFuture<DeviceStateData>> fetchFutures = new ArrayList<>();