| /packages/services/Car/tests/carservice_unit_test/src/com/android/car/internal/util/ |
| D | ConcurrentUtilsTest.java | 35 ExecutorService service = ConcurrentUtils.newFixedThreadPool(1, "test pool", in testWaitForFutureNoInterruptNormal()
46 ConcurrentUtils.newFixedThreadPool(1, "test pool", in testWaitForFutureNoInterruptInterrupted()
57 ExecutorService service = ConcurrentUtils.newFixedThreadPool(1, "test pool", in testWaitForFutureNoInterruptRuntimeException()
69 ExecutorService service = ConcurrentUtils.newFixedThreadPool(1, "test pool", in testWaitForCountDownNoInterruptNormal()
|
| /packages/modules/OnDevicePersonalization/src/com/android/ondevicepersonalization/services/ |
| D | OnDevicePersonalizationExecutors.java | 41 Executors.newFixedThreadPool(
51 Executors.newFixedThreadPool(
60 MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(
66 MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(
|
| /packages/services/Car/car-lib/src/com/android/car/internal/util/ |
| D | ConcurrentUtils.java | 58 public static ExecutorService newFixedThreadPool(int nThreads, String poolName, in newFixedThreadPool() method in ConcurrentUtils
60 return Executors.newFixedThreadPool(nThreads, in newFixedThreadPool()
|
| /packages/modules/OnDevicePersonalization/federatedcompute/src/com/android/federatedcompute/services/common/ |
| D | FederatedComputeExecutors.java | 41 Executors.newFixedThreadPool(
50 Executors.newFixedThreadPool(
|
| /packages/providers/MediaProvider/src/com/android/providers/media/photopicker/sync/ |
| D | WorkManagerInitializer.java | 68 .newFixedThreadPool(WORK_MANAGER_THREAD_POOL_SIZE); in ensureWorkManagerExecutor()
|
| /packages/apps/TvSettings/SettingsAPI/java/com/android/tv/settings/library/util/ |
| D | ThreadUtils.java | 90 sThreadExecutor = Executors.newFixedThreadPool( in getThreadExecutor()
|
| /packages/apps/Camera2/src/com/android/camera/processing/imagebackend/ |
| D | ImageBackend.java | 152 mThreadPoolFast = Executors.newFixedThreadPool(NUM_THREADS_FAST, new FastThreadFactory()); in ImageBackend()
153 mThreadPoolAverage = Executors.newFixedThreadPool(NUM_THREADS_AVERAGE, in ImageBackend()
155 mThreadPoolSlow = Executors.newFixedThreadPool(NUM_THREADS_SLOW, new SlowThreadFactory()); in ImageBackend()
|
| /packages/modules/Permission/PermissionController/src/com/android/permissioncontroller/permission/utils/ |
| D | AndroidUtils.kt | 50 val IPC = Executors.newFixedThreadPool(IPC_THREAD_POOL_COUNT).asCoroutineDispatcher()
|
| /packages/modules/AdServices/shared/libraries/device-side/java/com/android/adservices/shared/testing/common/ |
| D | SingletonTester.java | 49 this(expect, Executors.newFixedThreadPool(numberThreads), numberCalls); in SingletonTester()
|
| /packages/services/Telephony/testapps/TestRcsApp/aosp_test_rcsclient/src/com/android/libraries/rcs/simpleclient/filetransfer/requestexecutor/ |
| D | GbaRequestExecutor.java | 45 MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(4));
|
| /packages/apps/Dialer/java/com/android/dialer/common/concurrent/ |
| D | DialerExecutorModule.java | 57 return Executors.newFixedThreadPool( in provideNonUiThreadPool()
|
| /packages/modules/DeviceLock/DeviceLockController/tests/robolectric/src/com/android/devicelockcontroller/policy/ |
| D | ProvisionStateControllerThreadSafetyTest.java | 71 ExecutorService executorService = Executors.newFixedThreadPool(NUMBER_OF_THREADS); in setNextStateForEvent_shouldSetStateOnlyOnce_whenMultithreading()
|
| /packages/modules/AdServices/adservices/tests/unittest/service-core/src/com/android/adservices/service/kanon/ |
| D | KAnonSignJoinBackgroundJobWorkerTest.java | 58 private final ExecutorService mExecutorService = Executors.newFixedThreadPool(8);
|
| /packages/services/Car/tests/EmbeddedKitchenSinkApp/src/com/google/android/car/kitchensink/ |
| D | CarWatchdogClient.java | 60 private final ExecutorService mCallbackExecutor = Executors.newFixedThreadPool(1);
|
| /packages/services/Car/tests/carservice_test/src/com/android/car/ |
| D | CarEvsManagerTest.java | 70 private final ExecutorService mCallbackExecutor = Executors.newFixedThreadPool(1);
|
| /packages/apps/Settings/src/com/android/settings/notification/modes/ |
| D | IconLoader.java | 68 this(Executors.newFixedThreadPool(4)); in IconLoader()
|
| /packages/services/Car/tests/EmbeddedKitchenSinkApp/src/com/google/android/car/kitchensink/audio/ |
| D | OemCarServiceTestFragment.java | 55 private final ExecutorService mPool = Executors.newFixedThreadPool(TEST_ITERATIONS);
|
| /packages/apps/Messaging/src/android/support/v7/mms/ |
| D | MmsService.java | 289 mExecutors[i] = Executors.newFixedThreadPool(sThreadPoolSize); in onCreate()
|
| /packages/apps/Contacts/src/com/android/contacts/util/concurrent/ |
| D | ContactsExecutors.java | 47 Executors.newFixedThreadPool(CORE_POOL_SIZE));
|
| /packages/apps/Settings/src/com/android/settings/homepage/contextualcards/ |
| D | ContextualCardLoader.java | 190 final ExecutorService executor = Executors.newFixedThreadPool(candidates.size()); in filterEligibleCards()
|
| /packages/apps/QuickSearchBox/src/com/android/quicksearchbox/ |
| D | QsbApplication.kt | 162 return Executors.newFixedThreadPool(numThreads, threadFactory) in createExecutorFactory()
|
| /packages/modules/HealthFitness/testapps/toolbox/src/com/android/healthconnect/testapps/toolbox/viewmodels/ |
| D | PerformanceTestingViewModel.kt | 100 val workerPool: ExecutorService = Executors.newFixedThreadPool(4) in insertRecordsForPerformanceTestingInParallel()
|
| /packages/services/Car/tests/CarEvsMultiCameraPreviewApp/src/com/google/android/car/evs/multi/ |
| D | CarEvsCameraClient.java | 82 private final ExecutorService mCallbackExecutor = Executors.newFixedThreadPool(1);
|
| /packages/apps/Messaging/src/com/android/messaging/datamodel/media/ |
| D | MediaResourceManager.java | 100 private static final Executor MEDIA_LOADING_EXECUTOR = Executors.newFixedThreadPool(10);
|
| /packages/modules/GeoTZ/data_pipeline/src/main/java/com/android/timezone/location/data_pipeline/steps/ |
| D | TzS2PolygonsToTzS2CellUnions.java | 122 ExecutorService executorService = Executors.newFixedThreadPool(threads); in main()
|