ScheduledThreadPoolExecutor für eine periodische Aufgabe (mit Retrofit), die nur einmal und nie wieder ausgelöst wird

Ich habe den folgenden Code zum Abrufen der ungelesenen Benachrichtigungsanzahl alle X Sekunden von einem Server

Ich starte diesen Prozess über ScheduledThreadPoolExecutor in der App.onCreate () und

Log.d("XXX", "Requesting Notification count from server ...");

wird einmal aufgerufen (ich sehe es in Logcat), aber keine der beiden Retrofit-Rückruffunktionen wird aufgerufen (und tatsächlich keine Retrofit-Debug-Protokolle). Darüber hinaus wird die Meldung "Anzahl der angeforderten Benachrichtigungen vom Server ..." nie mehr gedruckt (d. H. Die periodische Aufgabe wird nicht ausgeführt).

Ich verwende Retrofit auch für andere Webservice-Aufrufe (nach Benutzereingabe) und sie funktionieren einwandfrei (ich kann die eingehenden und ausgehenden Anfragen / Antworten im Logcat sehen)

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");
                }
            });

        }
    }


}
Der Nachrüstteil des Codes ist hier:
    @POST("/notification/notification_count/")
    void getNotificationCount(Callback<NotificationCount> callback);

Antworten auf die Frage(4)

Ihre Antwort auf die Frage