ScheduledThreadPoolExecutor для периодической задачи (с использованием Retrofit), запускается один раз и никогда больше
У меня есть следующий код для опроса счетчика непрочитанных уведомлений каждые X секунд с сервера
Я запускаю этот процесс через ScheduledThreadPoolExecutor в App.onCreate () и
Log.d("XXX", "Requesting Notification count from server ...");
вызывается один раз (я вижу в Logcat), но ни одна из двух функций обратного вызова Retrofit не вызывается (и фактически нет журналов отладки Retrofit). Более того, «Запрос количества уведомлений с сервера ....» никогда больше не печатается (то есть периодическая задача не выполняется)
Я использую Retrofit и для других вызовов веб-сервисов (при вводе пользователем), и они работают нормально (я вижу входящие и исходящие запросы / ответы в logcat)
public class App extends Application {
private ScheduledExecutorService scheduleTaskExecutor;
...
@Override
public void onCreate() {
super.onCreate();
//region Set up the periodic notification count listener task
scheduleTaskExecutor= Executors.newScheduledThreadPool(2);
scheduleTaskExecutor.scheduleAtFixedRate(new PeriodicNotifCountFetchTask(), 0, 5, TimeUnit.SECONDS);
//endregion
}
class PeriodicNotifCountFetchTask implements Runnable {
@Override
public void run() {
Log.d("XXX", "Requesting Notification count from server ...");
EMRestClient.getmEMRestService().getNotificationCount(new Callback<NotificationCount>() {
@Override
public void success(NotificationCount response, Response unused) {
int unreadNotifCount = response.getCount();
Log.d("XXX", "Successfully fetched notification count, unread = " + response.getCount());
if (unreadNotifCount>0){
// call listener to repaint menu
for (NewNotificationListener x :notifListeners){
x.onNewNotificationReceived(response.getCount());
}
}
}
@Override
public void failure(RetrofitError error) {
Log.d("XXX", "Failed to fetch notification count from server");
}
});
}
}
}
Модифицированная часть кода находится здесь: @POST("/notification/notification_count/")
void getNotificationCount(Callback<NotificationCount> callback);