| /packages/apps/Settings/src/com/android/settings/fuelgauge/utils/ |
| D | LifecycleAwareExecutorFactory.kt | 22 import java.util.concurrent.ExecutorService in <lambda>()
34 fun newSingleThreadExecutor(lifecycle: Lifecycle?): ExecutorService { in <lambda>()
40 fun newFixedThreadPool(lifecycle: Lifecycle?, nThreads: Int): ExecutorService { in <lambda>()
46 fun newCachedThreadPool(lifecycle: Lifecycle?): ExecutorService { in <lambda>()
52 private fun ExecutorService.autoShutdown(lifecycle: Lifecycle?) { in <lambda>() method
|
| /packages/apps/Dialer/java/com/android/dialer/common/concurrent/ |
| D | DialerExecutorModule.java | 32 import java.util.concurrent.ExecutorService;
56 static ExecutorService provideNonUiThreadPool() { in provideNonUiThreadPool()
90 static ExecutorService provideUiThreadPool() {
91 return (ExecutorService) AsyncTask.THREAD_POOL_EXECUTOR;
114 static ListeningExecutorService provideLightweightExecutor(@UiParallel ExecutorService delegate) {
122 @NonUiParallel ExecutorService delegate) {
|
| D | DefaultDialerExecutorFactory.java | 33 import java.util.concurrent.ExecutorService;
41 private final ExecutorService nonUiThreadPool;
43 private final ExecutorService uiThreadPool;
48 @NonUiParallel ExecutorService nonUiThreadPool, in DefaultDialerExecutorFactory()
50 @UiParallel ExecutorService uiThreadPool, in DefaultDialerExecutorFactory()
196 @NonNull ExecutorService executorService, @Nullable InputT input) { in executeOnCustomExecutorService()
247 @NonNull ExecutorService executorService, @Nullable InputT input) { in executeOnCustomExecutorService()
|
| /packages/apps/UniversalMediaPlayer/java/com/android/pump/concurrent/ |
| D | Executors.java | 26 import java.util.concurrent.ExecutorService;
62 public static @NonNull ExecutorService newFixedUniqueThreadPool(int nThreads) { in newFixedUniqueThreadPool()
67 public static @NonNull ExecutorService newFixedUniqueThreadPool(int nThreads, in newFixedUniqueThreadPool()
73 public static @NonNull ExecutorService newCachedUniqueThreadPool() { in newCachedUniqueThreadPool()
78 public static @NonNull ExecutorService newCachedUniqueThreadPool( in newCachedUniqueThreadPool()
|
| /packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/common/ |
| D | RetryStrategyFactory.java | 22 import java.util.concurrent.ExecutorService;
28 private final ExecutorService mExecutorService;
30 private RetryStrategyFactory(boolean isRetryStrategyEnabled, ExecutorService executorService) { in RetryStrategyFactory()
37 boolean isAdServicesRetryStrategyEnabled, ExecutorService executorService) { in createInstance()
|
| D | RetryStrategyImpl.java | 29 import java.util.concurrent.ExecutorService;
33 private final ExecutorService mExecutorService;
35 public RetryStrategyImpl(int numberOfRetryAttempts, @NonNull ExecutorService executorService) { in RetryStrategyImpl()
|
| /packages/modules/AppSearch/framework/java/external/android/app/appsearch/ |
| D | AppSearchEnvironment.java | 30 import java.util.concurrent.ExecutorService;
47 @NonNull ExecutorService createExecutorService( in createExecutorService()
56 @NonNull ExecutorService createSingleThreadExecutor(); in createSingleThreadExecutor()
59 @NonNull ExecutorService createCachedThreadPoolExecutor(); in createCachedThreadPoolExecutor()
|
| /packages/modules/AppSearch/framework/java/android/app/appsearch/ |
| D | FrameworkAppSearchEnvironment.java | 28 import java.util.concurrent.ExecutorService;
65 public ExecutorService createExecutorService( in createExecutorService()
77 public ExecutorService createSingleThreadExecutor() { in createSingleThreadExecutor()
84 public ExecutorService createCachedThreadPoolExecutor() { in createCachedThreadPoolExecutor()
|
| /packages/apps/Messaging/src/android/support/v7/mms/ |
| D | MmsService.java | 29 import java.util.concurrent.ExecutorService;
241 private ExecutorService[] mExecutors = new ExecutorService[2];
304 for (ExecutorService executor : mExecutors) { in onDestroy()
382 final ExecutorService executor = getRequestExecutor(request); in retainService()
451 private ExecutorService getRequestExecutor(final MmsRequest request) { in getRequestExecutor()
|
| /packages/services/Car/tests/CarLibUnitTest/src/com/android/car/internal/util/ |
| D | ConcurrentUtilsTest.java | 28 import java.util.concurrent.ExecutorService;
35 ExecutorService service = ConcurrentUtils.newFixedThreadPool(1, "test pool", in testWaitForFutureNoInterruptNormal()
57 ExecutorService service = ConcurrentUtils.newFixedThreadPool(1, "test pool", in testWaitForFutureNoInterruptRuntimeException()
69 ExecutorService service = ConcurrentUtils.newFixedThreadPool(1, "test pool", in testWaitForCountDownNoInterruptNormal()
|
| /packages/modules/AppSearch/service/java/com/android/server/appsearch/util/ |
| D | ExecutorManager.java | 45 import java.util.concurrent.ExecutorService;
64 public static ExecutorService createDefaultExecutorService() { in createDefaultExecutorService()
87 private final Map<UserHandle, ExecutorService> mPerUserExecutorsLocked = new ArrayMap<>();
122 ExecutorService executor; in shutDownAndRemoveUserExecutor()
288 ExecutorService executor = mPerUserExecutorsLocked.get(userHandle); in getOrCreateUserExecutorLocked()
304 ExecutorService executor = mPerUserExecutorsLocked.get(userHandle); in getOrCreateUserRateLimitedExecutorLocked()
|
| D | RateLimitedExecutor.java | 33 import java.util.concurrent.ExecutorService;
39 public class RateLimitedExecutor implements ExecutorService {
41 private final ExecutorService mExecutor;
66 @NonNull ExecutorService executor, @NonNull AppSearchRateLimitConfig rateLimitConfig) { in RateLimitedExecutor()
102 public ExecutorService getExecutor() { in getExecutor()
|
| /packages/apps/Camera2/src/com/android/camera/one/v2/commands/ |
| D | CameraCommandExecutor.java | 31 import java.util.concurrent.ExecutorService;
79 private final Provider<ExecutorService> mExecutorProvider;
83 private ExecutorService mExecutor;
88 Provider<ExecutorService> threadPoolExecutor) { in CameraCommandExecutor()
|
| /packages/apps/Camera2/src/com/android/camera/device/ |
| D | Camera2ActionProvider.java | 25 import java.util.concurrent.ExecutorService;
34 private final ExecutorService mBackgroundRunner;
38 ExecutorService backgroundRunner, Logger.Factory logFactory) { in Camera2ActionProvider()
|
| D | CameraModuleHelper.java | 26 import java.util.concurrent.ExecutorService;
40 ExecutorService backgroundRunner = Executors.newSingleThreadExecutor(); in providePortabilityActionProvider()
49 ExecutorService backgroundRunner = Executors.newSingleThreadExecutor(); in provideCamera2ActionProvider()
|
| D | PortabilityCameraActionProvider.java | 27 import java.util.concurrent.ExecutorService;
35 private final ExecutorService mBackgroundRunner;
40 ExecutorService backgroundRunner, in PortabilityCameraActionProvider()
|
| /packages/modules/AppSearch/service/java/com/android/server/appsearch/appsindexer/ |
| D | AppOpenEventIndexerUserInstance.java | 37 import java.util.concurrent.ExecutorService;
75 private final ExecutorService mSingleThreadedExecutor;
94 ExecutorService singleThreadedExecutor = in createInstance()
109 @NonNull ExecutorService executorService) in createInstance()
139 @NonNull ExecutorService singleThreadedExecutor, in AppOpenEventIndexerUserInstance()
|
| D | AppsIndexerUserInstance.java | 41 import java.util.concurrent.ExecutorService;
81 private final ExecutorService mSingleThreadedExecutor;
103 ExecutorService singleThreadedExecutor = in createInstance()
114 @NonNull ExecutorService executorService) in createInstance()
139 @NonNull ExecutorService singleThreadedExecutor, in AppsIndexerUserInstance()
|
| /packages/apps/TvSettings/SettingsAPI/java/com/android/tv/settings/library/util/ |
| D | ThreadUtils.java | 23 import java.util.concurrent.ExecutorService;
31 private static volatile ExecutorService sThreadExecutor;
88 private static synchronized ExecutorService getThreadExecutor() { in getThreadExecutor()
|
| /packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/adselection/ |
| D | ReportEventDisabledImpl.java | 34 import java.util.concurrent.ExecutorService;
45 @NonNull ExecutorService lightweightExecutorService, in ReportEventDisabledImpl()
46 @NonNull ExecutorService backgroundExecutorService, in ReportEventDisabledImpl()
|
| /packages/apps/Settings/src/com/android/settings/network/ims/ |
| D | ImsQueryController.java | 29 import java.util.concurrent.ExecutorService;
76 final ExecutorService executor = Executors.newSingleThreadExecutor(); in isEnabledByPlatform()
102 final ExecutorService executor = Executors.newSingleThreadExecutor(); in isServiceStateReady()
|
| /packages/modules/Connectivity/tests/integration/src/com/android/server/net/integrationtests/ |
| D | NetworkStackInstrumentationService.kt | 28 import java.util.concurrent.ExecutorService in <lambda>()
49 private val networkMonitorExecutorServices = mutableListOf<ExecutorService>() in <lambda>()
75 fun onNetworkMonitorExecutorServiceCreated(executorService: ExecutorService) { in <lambda>()
|
| /packages/modules/HealthFitness/tests/cts/phr/src/android/healthconnect/cts/phr/apis/ |
| D | CreateMedicalDataSourceCtsTest.java | 72 import java.util.concurrent.ExecutorService;
117 ExecutorService executor = Executors.newSingleThreadExecutor(); in testCreateMedicalDataSource_migrationInProgress_apiBlocked()
264 ExecutorService executor = Executors.newSingleThreadExecutor(); in testCreateMedicalDataSource_succeeds()
298 ExecutorService executor = Executors.newSingleThreadExecutor(); in testCreateMedicalDataSource_maxNumberOfSources_succeeds()
314 ExecutorService executor = Executors.newSingleThreadExecutor(); in testCreateMedicalDataSource_moreThanAllowedMax_throws()
328 ExecutorService executor = Executors.newSingleThreadExecutor(); in testCreateMedicalDataSource_duplicateDisplayName_throws()
356 ExecutorService executor = Executors.newSingleThreadExecutor(); in testCreateMedicalDataSource_duplicateDisplayNameFromSeparatePackages_succeeds()
|
| /packages/apps/DocumentsUI/tests/functional/com/android/documentsui/archives/ |
| D | TestUtils.java | 27 import java.util.concurrent.ExecutorService;
36 public final ExecutorService mExecutor;
38 public TestUtils(Context targetContext, Context testContext, ExecutorService executor) { in TestUtils()
|
| /packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/stable/ |
| D | ProcessStableFlagsLogger.java | 32 import java.util.concurrent.ExecutorService;
42 private final ExecutorService mExecutor;
47 ProcessStableFlagsStatsdLogger statsdLogger, ExecutorService executor) { in ProcessStableFlagsLogger()
|