Home
last modified time | relevance | path

Searched refs:Executors (Results 1 – 25 of 641) sorted by relevance

12345678910>>...26

/packages/modules/OnDevicePersonalization/tests/cts/endtoend/src/com/android/ondevicepersonalization/cts/e2e/
DCtsOdpManagerTests.java54 import java.util.concurrent.Executors;
131 Executors.newSingleThreadExecutor(), in testExecuteThrowsIfComponentNameMissing()
147 Executors.newSingleThreadExecutor(), in testExecuteThrowsIfParamsMissing()
179 Executors.newSingleThreadExecutor(), in testExecuteThrowsIfReceiverMissing()
195 Executors.newSingleThreadExecutor(), in testExecuteThrowsIfPackageNameMissing()
211 Executors.newSingleThreadExecutor(), in testExecuteThrowsIfClassNameMissing()
224 Executors.newSingleThreadExecutor(), in testExecuteReturnsIllegalStateIfServiceNotEnrolled()
239 Executors.newSingleThreadExecutor(), in testExecuteReturnsNameNotFoundIfServiceNotInstalled()
255 Executors.newSingleThreadExecutor(), in testExecuteReturnsClassNotFoundIfServiceClassNotFound()
270 Executors.newSingleThreadExecutor(), in testExecuteNoOp()
[all …]
DRequestSurfacePackageTests.java64 import java.util.concurrent.Executors;
152 Executors.newSingleThreadExecutor(), in testRequestSurfacePackageSuccess()
203 Executors.newSingleThreadExecutor(), in testRequestSurfacePackageThrowsIfSurfacePackageTokenMissing()
222 Executors.newSingleThreadExecutor(), in testRequestSurfacePackageThrowsIfSurfaceViewHostTokenMissing()
241 Executors.newSingleThreadExecutor(), in testRequestSurfacePackageThrowsIfInvalidDisplayId()
260 Executors.newSingleThreadExecutor(), in testRequestSurfacePackageThrowsIfInvalidWidth()
279 Executors.newSingleThreadExecutor(), in testRequestSurfacePackageThrowsIfInvalidHeight()
317 Executors.newSingleThreadExecutor(), in testRequestSurfacePackageThrowsIfOutcomeReceiverMissing()
345 Executors.newSingleThreadExecutor(), in runExecute()
/packages/apps/Launcher3/tests/multivalentTests/src/com/android/launcher3/util/
DCancellableTaskTest.kt59 Executors.VIEW_PREINFLATION_EXECUTOR, in submitJob()
65 Executors.UI_HELPER_EXECUTOR.execute(underTest) in submitJob()
82 Executors.UI_HELPER_EXECUTOR.submit { lock.lock() } in run_and_cancel_cancelTaskAndCallback()
99 Executors.VIEW_PREINFLATION_EXECUTOR.submit { lock.lock() } in run_and_cancel_cancelCallback()
101 awaitExecutorCompleted(Executors.UI_HELPER_EXECUTOR) in run_and_cancel_cancelCallback()
107 awaitExecutorCompleted(Executors.VIEW_PREINFLATION_EXECUTOR) in run_and_cancel_cancelCallback()
128 awaitExecutorCompleted(Executors.UI_HELPER_EXECUTOR) in awaitAllExecutorCompleted()
129 awaitExecutorCompleted(Executors.VIEW_PREINFLATION_EXECUTOR) in awaitAllExecutorCompleted()
DModelTestExtensions.kt31 TestUtil.runOnExecutorSync(Executors.MODEL_EXECUTOR) { in <lambda>()
39 TestUtil.runOnExecutorSync(Executors.MAIN_EXECUTOR) { forceReload() } in <lambda>()
46 TestUtil.runOnExecutorSync(Executors.MAIN_EXECUTOR) { addCallbacksAndLoad(mockCb) } in <lambda>()
47 TestUtil.runOnExecutorSync(Executors.MODEL_EXECUTOR) {} in <lambda>()
48 TestUtil.runOnExecutorSync(Executors.MAIN_EXECUTOR) {} in <lambda>()
49 TestUtil.runOnExecutorSync(Executors.MAIN_EXECUTOR) { removeCallbacks(mockCb) } in <lambda>()
73 TestUtil.runOnExecutorSync(Executors.MODEL_EXECUTOR) { in <lambda>()
/packages/modules/DeviceLock/DeviceLockController/tests/robolectric/src/com/android/devicelockcontroller/policy/
DUserRestrictionsPolicyHandlerTest.java54 import java.util.concurrent.Executors;
78 Executors.newSingleThreadExecutor()); in onProvisionInProgressDebug_withoutKioskPackageName_shouldThrowException()
94 Executors.newSingleThreadExecutor()); in onProvisionInProgress_withoutKioskPackageName_shouldThrowException()
115 Executors.newSingleThreadExecutor()); in onProvisionInProgressDebug_withSetExpectedUserRestrictions()
139 Executors.newSingleThreadExecutor()); in onProvisionInProgress_withSetExpectedUserRestrictions()
164 Executors.newSingleThreadExecutor()); in onProvisionInProgress_withDisableOutgoingCallShouldSetExpectedUserRestrictions()
189 Executors.newSingleThreadExecutor()); in onProvisionInProgress_withDisallowUnknownSourcesShouldSetExpectedUserRestrictions()
215 Executors.newSingleThreadExecutor()); in onProvisionInProgress_withDebuggingAllowed_shouldNotDisallowDebuggingFeatures()
236 Executors.newSingleThreadExecutor()); in onLockedDebug_withDisableOutgoingCallShouldSetExpectedUserRestrictions()
263 Executors.newSingleThreadExecutor()); in onLocked_withDisableOutgoingCallShouldSetExpectedUserRestrictions()
[all …]
/packages/modules/OnDevicePersonalization/src/com/android/ondevicepersonalization/services/
DOnDevicePersonalizationExecutors.java32 import java.util.concurrent.Executors;
41 Executors.newFixedThreadPool(
51 Executors.newFixedThreadPool(
60 MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(
66 MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(
72 MoreExecutors.listeningDecorator(Executors.newCachedThreadPool(
77 MoreExecutors.listeningDecorator(Executors.newScheduledThreadPool(
/packages/apps/UniversalMediaPlayer/java/com/android/pump/db/
DMediaDb.java27 import com.android.pump.concurrent.Executors;
88 Executors.uiThreadExecutor().execute(() -> addAudios(audios)); in MediaDb()
93 Executors.uiThreadExecutor().execute(() -> addArtists(artists)); in MediaDb()
98 Executors.uiThreadExecutor().execute(() -> addAlbums(albums)); in MediaDb()
103 Executors.uiThreadExecutor().execute(() -> addGenres(genres)); in MediaDb()
108 Executors.uiThreadExecutor().execute(() -> addPlaylists(playlists)); in MediaDb()
115 Executors.uiThreadExecutor().execute(() -> addMovies(movies)); in MediaDb()
120 Executors.uiThreadExecutor().execute(() -> addSeries(series)); in MediaDb()
125 Executors.uiThreadExecutor().execute(() -> addEpisodes(episodes)); in MediaDb()
130 Executors.uiThreadExecutor().execute(() -> addOthers(others)); in MediaDb()
[all …]
/packages/apps/Launcher3/tests/src/com/android/launcher3/model/
DModelMultiCallbacksTest.java35 import com.android.launcher3.util.Executors;
85 Executors.MAIN_EXECUTOR.execute(() -> mModelHelper.getModel().addCallbacksAndLoad(cb1)); in testTwoCallbacks_loadedTogether()
94 Executors.MAIN_EXECUTOR.execute(() -> mModelHelper.getModel().addCallbacksAndLoad(cb2)); in testTwoCallbacks_loadedTogether()
105 Executors.MAIN_EXECUTOR.execute(() -> mModelHelper.getModel().removeCallbacks(cb2)); in testTwoCallbacks_loadedTogether()
125 Executors.MAIN_EXECUTOR.execute(() -> mModelHelper.getModel().addCallbacksAndLoad(cb1)); in testTwoCallbacks_receiveUpdates()
126 Executors.MAIN_EXECUTOR.execute(() -> mModelHelper.getModel().addCallbacksAndLoad(cb2)); in testTwoCallbacks_receiveUpdates()
147 Executors.MAIN_EXECUTOR.execute(() -> mModelHelper.getModel().removeCallbacks(cb2)); in testTwoCallbacks_receiveUpdates()
158 Executors.MAIN_EXECUTOR.submit(() -> { }).get(); in waitForLoaderAndTempMainThread()
159 Executors.MODEL_EXECUTOR.submit(() -> { }).get(); in waitForLoaderAndTempMainThread()
160 Executors.MAIN_EXECUTOR.submit(() -> { }).get(); in waitForLoaderAndTempMainThread()
/packages/modules/AdServices/adservices/tests/cts/ui/gaux/alreadyenrolledchannel/src/com/android/adservices/tests/ui/gaux/alreadyenrolledchannel/
DGaUxAlreadyEnrolledChannelTest.java44 import java.util.concurrent.Executors;
104 Executors.newCachedThreadPool(), in setUp()
150 adServicesStates, Executors.newCachedThreadPool(), mCallback); in testGaRowAdIdEnabled()
157 adServicesStates, Executors.newCachedThreadPool(), mCallback); in testGaRowAdIdEnabled()
182 adServicesStates, Executors.newCachedThreadPool(), mCallback); in testGaRowAdIdDisabled()
189 adServicesStates, Executors.newCachedThreadPool(), mCallback); in testGaRowAdIdDisabled()
214 adServicesStates, Executors.newCachedThreadPool(), mCallback); in testGaEuAdIdEnabled()
221 adServicesStates, Executors.newCachedThreadPool(), mCallback); in testGaEuAdIdEnabled()
244 adServicesStates, Executors.newCachedThreadPool(), mCallback); in testGaEuAdIdDisabled()
251 adServicesStates, Executors.newCachedThreadPool(), mCallback); in testGaEuAdIdDisabled()
/packages/modules/AdServices/adservices/tests/cts/ui/gaux/debugchannel/src/com/android/adservices/tests/ui/gaux/debugchannel/
DGaUxDebugChannelTest.java40 import java.util.concurrent.Executors;
116 Executors.newCachedThreadPool(), in testApiDisabled()
155 Executors.newCachedThreadPool(), in testEntryPointDisabled()
183 Executors.newCachedThreadPool(), in testFromEntryPointRequest()
210 Executors.newCachedThreadPool(), in testNonAdultAccount()
240 Executors.newCachedThreadPool(), in testGaRowAdIdEnabled()
269 Executors.newCachedThreadPool(), in testGaRowAdIdDisabled()
298 Executors.newCachedThreadPool(), in testGaEuAdIdEnabled()
325 Executors.newCachedThreadPool(), in testGaEuAdIdDisabled()
/packages/modules/HealthFitness/tests/cts/utils/HealthConnectTestUtils/src/android/healthconnect/cts/utils/
DTestUtils.java175 import java.util.concurrent.Executors;
204 .getChangeLogToken(request, Executors.newSingleThreadExecutor(), receiver); in getChangeLogToken()
263 unmodifiableList(records), Executors.newSingleThreadExecutor(), receiver); in insertRecords()
292 unmodifiableList(records), Executors.newSingleThreadExecutor(), receiver); in updateRecords()
305 .getChangeLogs(changeLogsRequest, Executors.newSingleThreadExecutor(), receiver); in getChangeLogs()
313 getHealthConnectManager().aggregate(request, Executors.newSingleThreadExecutor(), receiver); in getAggregateResponse()
325 getHealthConnectManager().aggregate(request, Executors.newSingleThreadExecutor(), receiver); in getAggregateResponse()
337 request, duration, Executors.newSingleThreadExecutor(), receiver); in getAggregateResponseGroupByDuration()
348 request, period, Executors.newSingleThreadExecutor(), receiver); in getAggregateResponseGroupByPeriod()
372 .readRecords(request, Executors.newSingleThreadExecutor(), receiver); in getReadRecordsResponse()
[all …]
/packages/modules/AdServices/adservices/apk/tests/engonly/gaux/alreadyenrolledchannel/src/com/android/adservices/tests/ui/gaux/alreadyenrolledchannel/
DExtGaUxAlreadyEnrolledChannelRowTest.java45 import java.util.concurrent.Executors;
105 Executors.newCachedThreadPool(), in setUp()
147 adServicesStates, Executors.newCachedThreadPool(), mCallback); in testGaRowAdIdEnabled()
154 adServicesStates, Executors.newCachedThreadPool(), mCallback); in testGaRowAdIdEnabled()
177 adServicesStates, Executors.newCachedThreadPool(), mCallback); in testGaRowAdIdDisabled()
184 adServicesStates, Executors.newCachedThreadPool(), mCallback); in testGaRowAdIdDisabled()
DExtGaUxAlreadyEnrolledChannelEuTest.java45 import java.util.concurrent.Executors;
105 Executors.newCachedThreadPool(), in setUp()
146 adServicesStates, Executors.newCachedThreadPool(), mCallback); in testGaEuAdIdEnabled()
153 adServicesStates, Executors.newCachedThreadPool(), mCallback); in testGaEuAdIdEnabled()
174 adServicesStates, Executors.newCachedThreadPool(), mCallback); in testGaEuAdIdDisabled()
181 adServicesStates, Executors.newCachedThreadPool(), mCallback); in testGaEuAdIdDisabled()
/packages/modules/AdServices/adservices/apk/tests/engonly/gaux/debugchannel/src/com/android/adservices/tests/ui/gaux/debugchannel/
DExtGaUxDebugChannelRowTest.java43 import java.util.concurrent.Executors;
118 Executors.newCachedThreadPool(), in testEntryPointDisabled()
142 Executors.newCachedThreadPool(), in testFromEntryPointRequest()
165 Executors.newCachedThreadPool(), in testNonAdultAccount()
191 Executors.newCachedThreadPool(), in testGaRowAdIdEnabled()
216 Executors.newCachedThreadPool(), in testGaRowAdIdDisabled()
DExtGaUxDebugChannelEuTest.java43 import java.util.concurrent.Executors;
118 Executors.newCachedThreadPool(), in testEntryPointDisabled()
142 Executors.newCachedThreadPool(), in testFromEntryPointRequest()
165 Executors.newCachedThreadPool(), in testNonAdultAccount()
190 Executors.newCachedThreadPool(), in testGaEuAdIdEnabled()
213 Executors.newCachedThreadPool(), in testGaEuAdIdDisabled()
/packages/modules/OnDevicePersonalization/tests/frameworktests/src/android/adservices/ondevicepersonalization/
DOnDevicePersonalizationManagerTest.java55 import java.util.concurrent.Executors;
99 Executors.newSingleThreadExecutor(), in testExecuteSuccess()
117 Executors.newSingleThreadExecutor(), in testExecuteUnknownError()
134 Executors.newSingleThreadExecutor(), in testExecuteServiceError()
152 Executors.newSingleThreadExecutor(), in testExecuteErrorWithCode()
175 Executors.newSingleThreadExecutor(), in testExecuteErrorWithMessage()
191 Executors.newSingleThreadExecutor(), in testExecuteCatchesIaeFromService()
207 Executors.newSingleThreadExecutor(), in testExecuteCatchesNpeFromService()
223 Executors.newSingleThreadExecutor(), in testExecuteCatchesOtherExceptions()
DOnDevicePersonalizationSystemEventManagerTest.java46 import java.util.concurrent.Executors;
67 Executors.newSingleThreadExecutor(), in testnotifyMeasurementEventSuccess()
82 Executors.newSingleThreadExecutor(), in testnotifyMeasurementEventError()
98 Executors.newSingleThreadExecutor(), in testnotifyMeasurementEventPropagatesIae()
112 Executors.newSingleThreadExecutor(), in testnotifyMeasurementEventPropagatesNpe()
125 Executors.newSingleThreadExecutor(), in testnotifyMeasurementEventCatchesExceptions()
/packages/modules/HealthFitness/tests/cts/hostsidetests/healthconnect/HealthConnectTestHelper/src/android/healthconnect/cts/testhelper/
DHealthConnectServiceLogsTests.java67 import java.util.concurrent.Executors;
171 Executors.newSingleThreadExecutor(), in testHealthConnectReadRecords()
197 Executors.newSingleThreadExecutor(), in testHealthConnectReadRecordsError()
226 Executors.newSingleThreadExecutor(), in testHealthConnectGetChangeLogTokenError()
262 Executors.newSingleThreadExecutor(), in testHealthConnectGetChangeLogs()
285 Executors.newSingleThreadExecutor(), in testHealthConnectGetChangeLogsError()
310 Executors.newSingleThreadExecutor(), in testHealthConnectAggregatedData()
335 Executors.newSingleThreadExecutor(), in testHealthConnectAggregatedDataError()
368 Executors.newSingleThreadExecutor(), in getChangeLogToken()
392 Executors.newSingleThreadExecutor(), in updateRecords()
/packages/modules/AdServices/adservices/tests/cts/ui/gaux/graduationchannel/src/com/android/adservices/tests/ui/gaux/graduationchannel/
DGaUxGraduationChannelTest.java42 import java.util.concurrent.Executors;
101 Executors.newCachedThreadPool(), in setUp()
148 mCommonManager.enableAdServices(u18States, Executors.newCachedThreadPool(), mCallback); in testRowU18ToGaAdIdEnabled()
163 mCommonManager.enableAdServices(adultStates, Executors.newCachedThreadPool(), mCallback); in testRowU18ToGaAdIdEnabled()
191 mCommonManager.enableAdServices(u18States, Executors.newCachedThreadPool(), mCallback); in testRowU18ToBetaAdIdEnabled()
206 mCommonManager.enableAdServices(adultStates, Executors.newCachedThreadPool(), mCallback); in testRowU18ToBetaAdIdEnabled()
/packages/modules/AdServices/adservices/tests/cts/ui/gaux/rpostotachannel/src/com/android/adservices/tests/ui/gaux/rpostotachannel/
DGaUxRvcPostOTAChannelTest.java41 import java.util.concurrent.Executors;
120 mCommonManager.enableAdServices(adultStates, Executors.newCachedThreadPool(), mCallback); in testU18ToGAForRPostOTA_optInMsmt()
133 mCommonManager.enableAdServices(adultStates, Executors.newCachedThreadPool(), mCallback); in testU18ToGAForRPostOTA_optInMsmt()
139 mCommonManager.enableAdServices(adultStates, Executors.newCachedThreadPool(), mCallback); in testU18ToGAForRPostOTA_optInMsmt()
178 mCommonManager.enableAdServices(adultStates, Executors.newCachedThreadPool(), mCallback); in testU18ToGAForRPostOTA_optOutMsmt()
199 mCommonManager.enableAdServices(adultStates, Executors.newCachedThreadPool(), mCallback); in testU18ToGAForRPostOTA_optOutMsmt()
/packages/apps/Launcher3/quickstep/src/com/android/quickstep/util/
DGestureExclusionManager.kt28 import com.android.launcher3.util.Executors
50 Executors.MAIN_EXECUTOR.execute { in onSystemGestureExclusionChanged()
65 Executors.UI_HELPER_EXECUTOR.execute { in addListener()
85 Executors.UI_HELPER_EXECUTOR.execute { in removeListener()
/packages/modules/OnDevicePersonalization/tests/frameworktests/src/com/android/ondevicepersonalization/internal/util/
DByteArrayParceledSliceTest.java38 import java.util.concurrent.Executors;
64 Executors.newSingleThreadExecutor().submit(() -> service.echo( in runTest()
80 Executors.newSingleThreadExecutor().submit(() -> service.echo( in runTestForNullArray()
97 Executors.newSingleThreadExecutor().submit(() -> service.echo( in runTestForEmptyArray()
126 Executors.newSingleThreadExecutor().submit(() -> run(input, callback)); in echo()
/packages/modules/AdServices/adservices/tests/cts/ui/rvcux/alreadyenrolledchannel/src/com/android/adservices/tests/ui/rvcux/alreadyenrolledchannel/
DRvcUxAlreadyEnrolledChannelTest.java44 import java.util.concurrent.Executors;
125 adServicesStates, Executors.newCachedThreadPool(), mCallback); in testU18NotificationDisplayedForRvcUX_row()
133 adServicesStates, Executors.newCachedThreadPool(), mCallback); in testU18NotificationDisplayedForRvcUX_row()
166 adServicesStates, Executors.newCachedThreadPool(), mCallback); in testU18NotificationDisplayedForRvcUX_eu()
173 adServicesStates, Executors.newCachedThreadPool(), mCallback); in testU18NotificationDisplayedForRvcUX_eu()
/packages/modules/OnDevicePersonalization/federatedcompute/src/com/android/federatedcompute/services/common/
DFederatedComputeExecutors.java31 import java.util.concurrent.Executors;
41 Executors.newFixedThreadPool(
50 Executors.newFixedThreadPool(
60 Executors.newCachedThreadPool(
/packages/modules/Uwb/tests/cts/tests/src/android/uwb/cts/
DUwbManagerTest.java98 import java.util.concurrent.Executors;
170 Executors.newSingleThreadExecutor(), adapterStateCallback); in setUwbEnabledAndWaitForCompletion()
459 Executors.newSingleThreadExecutor(), in testProvisionProfileAdfByScriptWithoutUwbPrivileged()
521 Executors.newSingleThreadExecutor(), cb); in testRegisterVendorUciCallbackWithoutUwbPrivileged()
540 Executors.newSingleThreadExecutor(), cb); in testUnregisterVendorUciCallbackWithoutUwbPrivileged()
573 Executors.newSingleThreadExecutor(), cb); in testInvalidCallbackUnregisterVendorUciCallback()
763 Executors.newSingleThreadExecutor(), in testOpenRangingSessionWithInvalidChipId()
784 Executors.newSingleThreadExecutor(), in testOpenRangingSessionWithChipIdWithBadParams()
812 Executors.newSingleThreadExecutor(), in testOpenRangingSessionWithInvalidChipIdWithBadParams()
838 Executors.newSingleThreadExecutor(), in testOpenRangingSessionWithoutUwbPrivileged()
[all …]

12345678910>>...26