Searched refs:singleThreadedExecutor (Results 1 – 3 of 3) sorted by relevance
98 ExecutorService singleThreadedExecutor = in createInstance() local100 return createInstance(userContext, appsDir, appsIndexerConfig, singleThreadedExecutor); in createInstance()134 @NonNull ExecutorService singleThreadedExecutor, in AppsIndexerUserInstance() argument139 mSingleThreadedExecutor = Objects.requireNonNull(singleThreadedExecutor); in AppsIndexerUserInstance()
116 ExecutorService singleThreadedExecutor = in createInstance() local119 userContext, contactsDir, contactsIndexerConfig, singleThreadedExecutor); in createInstance()163 @NonNull ExecutorService singleThreadedExecutor) { in ContactsIndexerUserInstance() argument169 mSingleThreadedExecutor = Objects.requireNonNull(singleThreadedExecutor); in ContactsIndexerUserInstance()
135 ThreadPoolExecutor singleThreadedExecutor = in testHandleMultipleNotifications_onlyOneDeltaUpdateCanBeScheduledAndRun() local140 mConfigForTest, singleThreadedExecutor); in testHandleMultipleNotifications_onlyOneDeltaUpdateCanBeScheduledAndRun()156 long totalTaskAfterFirstDeltaUpdate = singleThreadedExecutor.getTaskCount(); in testHandleMultipleNotifications_onlyOneDeltaUpdateCanBeScheduledAndRun()169 assertThat(singleThreadedExecutor.getTaskCount()).isEqualTo( in testHandleMultipleNotifications_onlyOneDeltaUpdateCanBeScheduledAndRun()183 ThreadPoolExecutor singleThreadedExecutor = in testHandleNotificationDuringUpdate_oneAdditionalUpdateWillBeRun() local188 mConfigForTest, singleThreadedExecutor); in testHandleNotificationDuringUpdate_oneAdditionalUpdateWillBeRun()201 long totalTaskAfterFirstDeltaUpdate = singleThreadedExecutor.getTaskCount(); in testHandleNotificationDuringUpdate_oneAdditionalUpdateWillBeRun()209 assertThat(singleThreadedExecutor.getTaskCount()).isEqualTo( in testHandleNotificationDuringUpdate_oneAdditionalUpdateWillBeRun()217 assertThat(singleThreadedExecutor.getActiveCount()).isEqualTo(1); in testHandleNotificationDuringUpdate_oneAdditionalUpdateWillBeRun()