android – ScheduledThreadPoolExecutor用于定期任务(使用Retrofit)只需触发一次而不再重复

我通过App.onCreate()中的scheduledThreadPoolExecutor启动此过程

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

被调用一次(我可以在Logcat中看到),但两个Retrofit回调函数都没有被调用(实际上没有Retrofit调试日志).更重要的是,“从服务器请求通知计数……”永远不会再次打印(即周期性任务没有运行)

我正在使用Retrofit进行其他webservice调用(在用户输入时)并且它们工作正常(我可以在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(),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);