Home
last modified time | relevance | path

Searched refs:newFixedThreadPool (Results 1 – 25 of 45) sorted by relevance

12

/packages/services/Car/tests/carservice_unit_test/src/com/android/car/internal/util/
DConcurrentUtilsTest.java35 ExecutorService service = ConcurrentUtils.newFixedThreadPool(1, "test pool", in testWaitForFutureNoInterruptNormal()
46 ExecutorService service = 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/federatedcompute/src/com/android/federatedcompute/services/common/
DFederatedComputeExecutors.java41 Executors.newFixedThreadPool(
50 Executors.newFixedThreadPool(
/packages/modules/OnDevicePersonalization/src/com/android/ondevicepersonalization/services/
DOnDevicePersonalizationExecutors.java39 MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(
45 MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(
/packages/services/Car/car-lib/src/com/android/car/internal/util/
DConcurrentUtils.java58 public static ExecutorService newFixedThreadPool(int nThreads, String poolName, in newFixedThreadPool() method in ConcurrentUtils
60 return Executors.newFixedThreadPool(nThreads, in newFixedThreadPool()
/packages/modules/RemoteKeyProvisioning/app/src/com/android/rkpdapp/
DThreadPool.java36 public static final ExecutorService EXECUTOR = Executors.newFixedThreadPool(NUMBER_OF_THREADS);
/packages/apps/Camera2/src/com/android/camera/processing/imagebackend/
DImageBackend.java152 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/apps/TvSettings/SettingsAPI/java/com/android/tv/settings/library/util/
DThreadUtils.java90 sThreadExecutor = Executors.newFixedThreadPool( in getThreadExecutor()
/packages/modules/Permission/PermissionController/src/com/android/permissioncontroller/permission/utils/
DAndroidUtils.kt52 val IPC = Executors.newFixedThreadPool(IPC_THREAD_POOL_COUNT).asCoroutineDispatcher()
/packages/apps/Dialer/java/com/android/dialer/common/concurrent/
DDialerExecutorModule.java57 return Executors.newFixedThreadPool( in provideNonUiThreadPool()
/packages/services/Telephony/testapps/TestRcsApp/aosp_test_rcsclient/src/com/android/libraries/rcs/simpleclient/filetransfer/requestexecutor/
DGbaRequestExecutor.java45 MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(4));
/packages/services/Car/tests/EmbeddedKitchenSinkApp/src/com/google/android/car/kitchensink/
DCarWatchdogClient.java60 private final ExecutorService mCallbackExecutor = Executors.newFixedThreadPool(1);
/packages/services/Car/tests/carservice_test/src/com/android/car/
DCarEvsManagerTest.java73 private final ExecutorService mCallbackExecutor = Executors.newFixedThreadPool(1);
/packages/services/Car/tests/EmbeddedKitchenSinkApp/src/com/google/android/car/kitchensink/audio/
DOemCarServiceTestFragment.java55 private final ExecutorService mPool = Executors.newFixedThreadPool(TEST_ITERATIONS);
/packages/apps/Messaging/src/android/support/v7/mms/
DMmsService.java289 mExecutors[i] = Executors.newFixedThreadPool(sThreadPoolSize); in onCreate()
/packages/apps/Contacts/src/com/android/contacts/util/concurrent/
DContactsExecutors.java47 Executors.newFixedThreadPool(CORE_POOL_SIZE));
/packages/modules/HealthFitness/testapps/toolbox/src/com/android/healthconnect/testapps/toolbox/viewmodels/
DPerformanceTestingViewModel.kt100 val workerPool: ExecutorService = Executors.newFixedThreadPool(4) in insertRecordsForPerformanceTestingInParallel()
/packages/apps/Settings/src/com/android/settings/homepage/contextualcards/
DContextualCardLoader.java191 final ExecutorService executor = Executors.newFixedThreadPool(candidates.size()); in filterEligibleCards()
/packages/apps/QuickSearchBox/src/com/android/quicksearchbox/
DQsbApplication.kt162 return Executors.newFixedThreadPool(numThreads, threadFactory) in createExecutorFactory()
/packages/apps/Messaging/src/com/android/messaging/datamodel/media/
DMediaResourceManager.java100 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/
DTzS2PolygonsToTzS2CellUnions.java122 ExecutorService executorService = Executors.newFixedThreadPool(threads); in main()
DTzS2CellUnionsToTzS2Ranges.java120 ExecutorService executorService = Executors.newFixedThreadPool(threads); in main()
/packages/services/Car/tests/CarEvsMultiCameraPreviewApp/src/com/google/android/car/evs/multi/
DCarEvsCameraClient.java81 private final ExecutorService mCallbackExecutor = Executors.newFixedThreadPool(1);
/packages/apps/Settings/tests/unit/src/com/android/settings/network/telephony/
DNetworkScanHelperTest.java93 mNetworkScanExecutor = Executors.newFixedThreadPool(1); in setUp()
/packages/services/Telephony/testapps/TestSliceApp/app/src/main/java/com/google/android/sample/testsliceapp/
DPrioritizeLatency.java69 private final ExecutorService mFixedThreadPool = Executors.newFixedThreadPool(3);
/packages/modules/Virtualization/demo/java/com/android/microdroid/demo/
DMainActivity.java162 mExecutorService = Executors.newFixedThreadPool(4); in run()

12