Я не знал, как правильно озаглавить свой вопрос, так как я не уверен, что здесь не так, поэтому я опубликую свой код с объяснением того, чего я пытаюсь достичь ..
У меня есть служба, которая запускает и отправляет событие каждую секунду. Мне нужно несколько проверок в этом процессе, каждая из которых выполняется через определенный промежуток времени, например. Каждую секунду я получаю значения атрибутов устройства, каждый 2 секунды я получаю «currentBox», каждые 5 секунд я проверяю подключение к сети и каждый час я пытаюсь войти в систему ..
это код:
private void startAutoUpdate() {
long current = System.currentTimeMillis();
if (!connectivityHelper.isConnectedMobile() && !connectivityHelper.isConnectedEthernet() && !connectivityHelper.isConnectedWifi()) {
eventBus.post(new Event(new ObjectConnectivity(connectivityHelper.isOnline(), null), Event.EVENT_TYPE_CONNECTIVITY_EVENT));
}
boolean localReset = false; // maybe force was set after this started!!
if (clearETags)
localReset = true;
try {
try {
if (localReset) {
attributeValueRepository.clearETag();
attributeValueRepository.clear();
attributeValueRepository.fetchMeteoAttr();
} else if (canUpdate(getResources().getInteger(R.integer.weather_update_delay)))
attributeValueRepository.fetchMeteoAttr();
} catch (Exception e) {
Log.d(TAG, "fail to load meteo attributes");
}
attributeValueRepository.fetchAll();
Log.d("AVTEST", "Fetch all");
try {
if (localReset) {
deviceStateRepository.clearETag();
deviceStateRepository.clear();
deviceStateRepository.fetchAll();
} else if (canUpdate(getResources().getInteger(R.integer.state_update_delay)))
deviceStateRepository.fetchAll();
} catch (Exception e) {
Log.d(TAG, "fail to load deviceStateRepository");
}
try {
if ((current - lastBoxCall) > 2000) {
currentBox = restTemplate.getRemoteOnlyCopy().getForObject("v2/box", Box.class);
if (currentBox != null) {
newSyncDate = df.format(currentBox.getSyncDate());
if (syncDate == null) {
syncDate = df.format(currentBox.getSyncDate());
} else {
if (!newSyncDate.equals(syncDate)) {
eventBus.post(new Event(null, Event.EVENT_TYPE_REFRESH_REQUEST));
syncDate = newSyncDate;
}
}
}
lastBoxCall = current;
Log.d("AVTEST", "Fetch current box");
}
} catch (Exception e) {
e.printStackTrace();
}
try {
if ((current - lastNetworkCall) > 5000) {
if (connectivityHelper.isConnectedEthernet() || connectivityHelper.isConnectedWifi()) {
try {
int timeoutMs = 1500;
Socket sock = new Socket();
SocketAddress sockaddr = new InetSocketAddress("8.8.8.8", 53);
sock.connect(sockaddr, timeoutMs);
sock.close();
isOnline = true;
showNotification(true);
} catch (IOException e) {
isOnline = false;
showNotification(false);
}
connectivityHelper.setIsOnline(isOnline);
eventBus.post(new Event(isOnline, Event.EVENT_CONNECTION));
} else {
connectivityHelper.setIsOnline(false);
showNotification(false);
}
lastNetworkCall = current;
Log.d("AVTEST", "Check network connection");
}
} catch (Exception e) {
e.printStackTrace();
}
try {
if ((current - lastLoginCall) > 3600000) {
restTemplate.login(restTemplate.getUsername(), restTemplate.getPassword(), restTemplate.getSerial());
}
lastLoginCall = current;
Log.d("AVTEST", "Relogin");
} catch (Exception e) {
Log.e(TAG, e.getMessage() != null ? e.getMessage() : "relogin error");
}
if (localReset) {
clearETags = false;
}
errorCount = 0;
previousCall = System.currentTimeMillis();
eventBus.post(new Event(null, Event.EVENT_TYPE_AUTO_UPDATER_SERVICE));
eventBus.post(new Event(new ObjectConnectivity(connectivityHelper.isOnline(), null), Event.EVENT_TYPE_CONNECTIVITY_EVENT));
} catch (Exception e) {
Log.d(TAG, "", e);
}
}
Итак, суть в том, что виджеты на моем экране должны обновляться после каждого события (каждую секунду), но по какой-то причине они иногда задерживаются, поэтому я отлаживал их. Я узнал, что этот раздел вызывает задержку:
try {
if ((current - lastLoginCall) > 3600000) {
restTemplate.login(restTemplate.getUsername(), restTemplate.getPassword(), restTemplate.getSerial());
}
lastLoginCall = current;
Log.d("AVTEST", "Relogin");
} catch (Exception e) {
Log.e(TAG, e.getMessage() != null ? e.getMessage() : "relogin error");
}
Я посмотрел в Android Monitor, и это поток:
D/AVTEST: Fetch all
D/AVTEST: Fetch current box
D/AVTEST: Check network connection
D/AVTEST: Relogin
D/AVTEST: Home screen types update
D/AVTEST: Push logic: key: 2130968946, value: ViewHolder{3cec115 position=0 id=-1, oldPos=-1, pLpos:-1}
Последние два не из этого сервиса, но сейчас это не имеет значения, дело в том, что журнал останавливается перед «Relogin» примерно на 15 секунд, а затем продолжается ... Это слишком тяжелый расчет или как?
((current - lastLoginCall) > 3600000)