Home
last modified time | relevance | path

Searched refs:mExecutor (Results 1 – 25 of 57) sorted by relevance

123

/packages/apps/DocumentsUI/tests/unit/com/android/documentsui/services/
DFileOperationServiceTest.java65 private TestScheduledExecutorService mExecutor; field in FileOperationServiceTest
80 mExecutor = new TestScheduledExecutorService(); in setUp()
96 mService.executor = mExecutor; in setUp()
117 mExecutor.runAll(); in tearDown()
129 mExecutor.runAll(); in testRunsCopyJobs()
144 mExecutor.runAll(); in testRunsCopyJobs_AfterExceptionInJobCreation()
154 mExecutor.runAll(); in testRunsCopyJobs_AfterFailure()
162 mExecutor.runAll(); in testRunsCopyJobs_notRunsDeleteJobs()
183 mExecutor.runAll(); in testUpdatesNotification()
193 mExecutor.runAll(); in testStopsUpdatingNotificationAfterFinished()
[all …]
/packages/apps/Camera2/src/com/android/camera/one/v2/commands/
DCameraCommandExecutor.java83 private ExecutorService mExecutor; field in CameraCommandExecutor
105 if (mExecutor == null) { in execute()
107 mExecutor = mExecutorProvider.get(); in execute()
109 checkNotNull(mExecutor); in execute()
110 return mExecutor.submit(new CommandRunnable(command)); in execute()
121 if (mExecutor != null) { in flush()
122 mExecutor.shutdownNow(); in flush()
125 mExecutor = null; in flush()
136 if (mExecutor != null) { in close()
137 mExecutor.shutdownNow(); in close()
[all …]
DRunnableCameraCommand.java24 private final CameraCommandExecutor mExecutor; field in RunnableCameraCommand
28 mExecutor = executor; in RunnableCameraCommand()
34 mExecutor.execute(mCommand); in run()
DResettingRunnableCameraCommand.java34 private final CameraCommandExecutor mExecutor; field in ResettingRunnableCameraCommand
45 mExecutor = executor; in ResettingRunnableCameraCommand()
57 mInProgressCommand = mExecutor.execute(mCommand); in run()
/packages/modules/NetworkStack/src/com/android/server/connectivity/ipmemorystore/
DIpMemoryStoreService.java81 final ExecutorService mExecutor; field in IpMemoryStoreService
125 mExecutor = Executors.newSingleThreadExecutor(); in IpMemoryStoreService()
139 mExecutor.shutdownNow(); in shutdown()
175 mExecutor.execute(() -> { in storeNetworkAttributes()
202 mExecutor.execute(() -> { in storeBlob()
269 mExecutor.execute(() -> { in findL2Key()
301 mExecutor.execute(() -> { in isSameNetwork()
347 mExecutor.execute(() -> { in retrieveNetworkAttributes()
388 mExecutor.execute(() -> { in retrieveBlob()
425 mExecutor.execute(() -> { in delete()
[all …]
/packages/apps/QuickSearchBox/tests/src/com/android/quicksearchbox/util/
DMockNamedTaskExecutor.java29 private final MockExecutor mExecutor = new MockExecutor(); field in MockNamedTaskExecutor
32 mExecutor.execute(task); in execute()
36 mExecutor.cancelPendingTasks(); in cancelPendingTasks()
40 mExecutor.close(); in close()
44 return mExecutor.runNext(); in runNext()
49 expected, mExecutor.countPendingTasks()); in assertPendingTaskCount()
DPerNameExecutorTest.java33 private NamedTaskExecutor mExecutor; field in PerNameExecutorTest
40 mExecutor = new PerNameExecutor(mExecutorFactory); in setUp()
70 mExecutor.cancelPendingTasks(); // cancel a2 in testCancelPendingTasks()
91 mExecutor.execute(a1); in testClose()
94 mExecutor.close(); in testClose()
96 mExecutor.close(); in testClose()
102 mExecutor.execute(task); in addTask()
DSingleThreadNamedTaskExecutorTest.java31 private SingleThreadNamedTaskExecutor mExecutor; field in SingleThreadNamedTaskExecutorTest
37 mExecutor = new SingleThreadNamedTaskExecutor(Executors.defaultThreadFactory()); in setUp()
51 mExecutor.execute(task); in addTask()
/packages/apps/UniversalMediaPlayer/java/com/android/pump/db/
DMediaDb.java45 private final Executor mExecutor; field in MediaDb
83 mExecutor = executor; in MediaDb()
214 mExecutor.execute(mAudioStore::load); in load()
215 mExecutor.execute(mVideoStore::load); in load()
251 mExecutor.execute(() -> { in loadData()
265 mExecutor.execute(() -> { in loadData()
285 mExecutor.execute(() -> { in loadData()
305 mExecutor.execute(() -> { in loadData()
319 mExecutor.execute(() -> { in loadData()
334 mExecutor.execute(() -> { in loadData()
[all …]
/packages/services/Car/car-lib/src/android/car/vms/
DVmsSubscriberManager.java57 private Executor mExecutor; field in VmsSubscriberManager
92 executor = mExecutor; in VmsSubscriberManager()
108 executor = mExecutor; in VmsSubscriberManager()
138 mExecutor = Preconditions.checkNotNull(executor, "executor cannot be null"); in setVmsSubscriberClientCallback()
153 if (mExecutor == null) return; in clearVmsSubscriberClientCallback()
162 mExecutor = null; in clearVmsSubscriberClientCallback()
338 mExecutor = null; in onCarDisconnected()
/packages/apps/ManagedProvisioning/tests/instrumentation/src/com/android/managedprovisioning/ota/
DTaskExecutorTest.java43 private TaskExecutor mExecutor; field in TaskExecutorTest
49 mExecutor = new TaskExecutor(); in setUp()
55 mExecutor.execute(TEST_USER_ID, mTask1); in testExecute_firstTask()
64 mExecutor.execute(TEST_USER_ID, mTask1); in testExecute_twoTask()
70 mExecutor.execute(TEST_USER_ID, mTask2); in testExecute_twoTask()
/packages/services/Car/service/src/com/android/car/systeminterface/
DTimeInterface.java51 private ScheduledExecutorService mExecutor; field in TimeInterface.DefaultImpl
57 executor = mExecutor; in scheduleAction()
60 mExecutor = executor; in scheduleAction()
70 executor = mExecutor; in cancelAllActions()
71 mExecutor = null; in cancelAllActions()
/packages/apps/Camera2/src/com/android/camera/async/
DResettingDelayedExecutor.java29 private final ScheduledExecutorService mExecutor; field in ResettingDelayedExecutor
42 mExecutor = executor; in ResettingDelayedExecutor()
68 mLatestRunRequest = mExecutor.schedule(runnable, mDelay, mDelayUnit); in execute()
79 mExecutor.shutdownNow(); in close()
DExecutorCallback.java34 private final Executor mExecutor; field in ExecutorCallback
42 mExecutor = executor; in ExecutorCallback()
47 mExecutor.execute(new Runnable() { in update()
DConcurrentState.java34 private final Executor mExecutor; field in ConcurrentState.ExecutorListenerPair
38 mExecutor = executor; in ExecutorListenerPair()
47 mExecutor.execute(mListener); in run()
/packages/apps/QuickSearchBox/src/com/android/quicksearchbox/util/
DBatchingNamedTaskExecutor.java34 private final NamedTaskExecutor mExecutor; field in BatchingNamedTaskExecutor
45 mExecutor = executor; in BatchingNamedTaskExecutor()
57 mExecutor.execute(task); in dispatch()
91 mExecutor.close(); in close()
/packages/apps/UniversalMediaPlayer/java/com/android/pump/app/
DGlobalsApplication.java21 private Executor mExecutor; field in GlobalsApplication
58 if (mExecutor == null) { in getExecutor()
60 mExecutor = Executors.newFixedUniqueThreadPool( in getExecutor()
63 return mExecutor; in getExecutor()
/packages/apps/DocumentsUI/tests/unit/com/android/documentsui/clipping/
DUrisSupplierTest.java58 private TestScheduledExecutorService mExecutor; field in UrisSupplierTest
63 mExecutor = new TestScheduledExecutorService(); in setUp()
64 AsyncTask.setDefaultExecutor(mExecutor); in setUp()
126 mExecutor.runAll(); in createWithLongList()
DClipStorageTest.java61 private TestScheduledExecutorService mExecutor; field in ClipStorageTest
73 mExecutor = new TestScheduledExecutorService(); in setUp()
74 AsyncTask.setDefaultExecutor(mExecutor); in setUp()
153 mExecutor.runAll(); in writeAll()
/packages/inputmethods/LatinIME/java/src/com/android/inputmethod/dictionarypack/
DDictionaryService.java113 private ThreadPoolExecutor mExecutor; field in DictionaryService
127 mExecutor = new ThreadPoolExecutor(1 /* corePoolSize */, 1 /* maximumPoolSize */, in onCreate()
131 mExecutor.allowCoreThreadTimeOut(true); in onCreate()
179 mExecutor.submit(new Runnable() { in onStartCommand()
/packages/apps/DocumentsUI/tests/unit/com/android/documentsui/archives/
DWriteableArchiveTest.java46 private ExecutorService mExecutor = null; field in WriteableArchiveTest
54 mExecutor = Executors.newSingleThreadExecutor(); in setUp()
56 InstrumentationRegistry.getContext(), mExecutor); in setUp()
69 mExecutor.shutdown(); in tearDown()
70 assertTrue(mExecutor.awaitTermination(3 /* timeout */, TimeUnit.SECONDS)); in tearDown()
/packages/apps/Camera2/src/com/android/camera/processing/imagebackend/
DTaskImageContainer.java146 final protected Executor mExecutor; field in TaskImageContainer
164 mExecutor = otherTask.mExecutor; in TaskImageContainer()
186 mExecutor = Executor; in TaskImageContainer()
/packages/apps/Car/CompanionDeviceSupport/src/com/android/car/companiondevicesupport/feature/
DLocalFeature.java48 private final Executor mExecutor = Executors.newSingleThreadExecutor(); field in LocalFeature
61 mExecutor); in start()
67 mDeviceCallback, mExecutor); in start()
181 mDeviceCallback, mExecutor);
/packages/services/Car/tests/CarDeveloperOptions/src/com/android/car/developeroptions/network/telephony/
DNetworkScanHelper.java147 private final Executor mExecutor; field in NetworkScanHelper
158 mExecutor = executor; in NetworkScanHelper()
185 mExecutor.execute(new NetworkScanSyncTask( in startNetworkScan()
191 mExecutor, in startNetworkScan()
/packages/apps/Settings/src/com/android/settings/network/telephony/
DNetworkScanHelper.java151 private final Executor mExecutor; field in NetworkScanHelper
162 mExecutor = executor; in NetworkScanHelper()
189 mExecutor.execute(new NetworkScanSyncTask( in startNetworkScan()
194 mExecutor, in startNetworkScan()

123