| /packages/apps/QuickSearchBox/tests/src/com/android/quicksearchbox/util/ |
| MockNamedTaskExecutor.java | 29 private final MockExecutor mExecutor = new MockExecutor();
32 mExecutor.execute(task);
36 mExecutor.cancelPendingTasks();
40 mExecutor.close();
44 return mExecutor.runNext();
49 expected, mExecutor.countPendingTasks());
|
| SingleThreadNamedTaskExecutorTest.java | 31 private SingleThreadNamedTaskExecutor mExecutor;
37 mExecutor = new SingleThreadNamedTaskExecutor(Executors.defaultThreadFactory());
51 mExecutor.execute(task);
|
| /packages/apps/Camera2/src/com/android/camera/one/v2/commands/ |
| RunnableCameraCommand.java | 24 private final CameraCommandExecutor mExecutor;
28 mExecutor = executor;
34 mExecutor.execute(mCommand);
|
| CameraCommandExecutor.java | 83 private ExecutorService mExecutor;
105 if (mExecutor == null) {
107 mExecutor = mExecutorProvider.get();
109 checkNotNull(mExecutor);
110 return mExecutor.submit(new CommandRunnable(command));
121 if (mExecutor != null) {
122 mExecutor.shutdownNow();
125 mExecutor = null;
136 if (mExecutor != null) {
137 mExecutor.shutdownNow()
[all...] |
| ResettingRunnableCameraCommand.java | 34 private final CameraCommandExecutor mExecutor;
45 mExecutor = executor;
57 mInProgressCommand = mExecutor.execute(mCommand);
|
| /packages/apps/ManagedProvisioning/tests/instrumentation/src/com/android/managedprovisioning/ota/ |
| TaskExecutorTest.java | 42 private TaskExecutor mExecutor;
48 mExecutor = new TaskExecutor();
54 mExecutor.execute(TEST_USER_ID, mTask1);
63 mExecutor.execute(TEST_USER_ID, mTask1);
69 mExecutor.execute(TEST_USER_ID, mTask2);
|
| /frameworks/support/work/workmanager/src/main/java/androidx/work/ |
| Configuration.java | 41 private final Executor mExecutor;
47 if (builder.mExecutor == null) {
48 mExecutor = createDefaultExecutor();
50 mExecutor = builder.mExecutor;
61 return mExecutor;
120 Executor mExecutor;
129 mExecutor = executor;
189 mExecutor = executor;
|
| /packages/apps/Camera2/src/com/android/camera/async/ |
| ExecutorCallback.java | 34 private final Executor mExecutor;
42 mExecutor = executor;
47 mExecutor.execute(new Runnable() {
|
| ResettingDelayedExecutor.java | 29 private final ScheduledExecutorService mExecutor;
42 mExecutor = executor;
68 mLatestRunRequest = mExecutor.schedule(runnable, mDelay, mDelayUnit);
79 mExecutor.shutdownNow();
|
| /frameworks/base/telephony/java/android/telephony/mbms/ |
| InternalStreamingServiceCallback.java | 27 private final Executor mExecutor;
33 mExecutor = executor;
42 mExecutor.execute(new Runnable() {
61 mExecutor.execute(new Runnable() {
80 mExecutor.execute(new Runnable() {
99 mExecutor.execute(new Runnable() {
118 mExecutor.execute(new Runnable() {
|
| InternalDownloadSessionCallback.java | 27 private final Executor mExecutor;
34 mExecutor = executor;
43 mExecutor.execute(new Runnable() {
62 mExecutor.execute(new Runnable() {
81 mExecutor.execute(new Runnable() {
|
| InternalStreamingSessionCallback.java | 27 private final Executor mExecutor;
34 mExecutor = executor;
43 mExecutor.execute(new Runnable() {
63 mExecutor.execute(new Runnable() {
82 mExecutor.execute(new Runnable() {
|
| InternalDownloadProgressListener.java | 28 private final Executor mExecutor;
35 mExecutor = executor;
46 mExecutor.execute(new Runnable() {
|
| InternalDownloadStatusListener.java | 29 private final Executor mExecutor;
35 mExecutor = executor;
45 mExecutor.execute(new Runnable() {
|
| /frameworks/base/core/java/android/hardware/camera2/impl/ |
| CallbackProxies.java | 40 private final Executor mExecutor;
45 mExecutor = checkNotNull(executor, "executor must not be null");
53 mExecutor.execute(() -> mCallback.onConfigured(session));
64 mExecutor.execute(() -> mCallback.onConfigureFailed(session));
74 mExecutor.execute(() -> mCallback.onReady(session));
84 mExecutor.execute(() -> mCallback.onActive(session));
94 mExecutor.execute(() -> mCallback.onCaptureQueueEmpty(session));
104 mExecutor.execute(() -> mCallback.onClosed(session));
114 mExecutor.execute(() -> mCallback.onSurfacePrepared(session, surface));
|
| /packages/services/Car/service/src/com/android/car/systeminterface/ |
| TimeInterface.java | 45 private final ScheduledExecutorService mExecutor = newSingleThreadScheduledExecutor();
49 mExecutor.scheduleAtFixedRate(r, delayMs, delayMs, TimeUnit.MILLISECONDS);
54 mExecutor.shutdownNow();
|
| /frameworks/base/packages/MtpDocumentsProvider/src/com/android/mtp/ |
| RootScanner.java | 58 ExecutorService mExecutor;
82 if (mExecutor == null) {
84 mExecutor = Executors.newSingleThreadExecutor();
91 mExecutor.execute(mCurrentTask);
100 if (mExecutor == null) {
103 mExecutor.shutdownNow();
105 if (!mExecutor.awaitTermination(AWAIT_TERMINATION_TIMEOUT, TimeUnit.MILLISECONDS)) {
110 mExecutor = null;
|
| /cts/common/device-side/util/tests/src/com/android/compatibility/common/util/ |
| BusinessLogicDeviceExecutorTest.java | 68 private BusinessLogicExecutor mExecutor;
73 mExecutor = new BusinessLogicDeviceExecutor(mContext, this);
83 mExecutor.invokeMethod(METHOD_1);
90 mExecutor.invokeMethod(OTHER_METHOD_1);
98 mExecutor.invokeMethod(METHOD_2, ARG_STRING_1, ARG_STRING_2);
107 mExecutor.invokeMethod(METHOD_3, ARG_STRING_1);
116 mExecutor.invokeMethod(METHOD_4, ARG_STRING_1);
125 mExecutor.invokeMethod(METHOD_5, ARG_STRING_1, ARG_STRING_2);
134 mExecutor.invokeMethod(METHOD_5);
142 mExecutor.invokeMethod(METHOD_6, ARG_STRING_1, ARG_STRING_2)
[all...] |
| /test/suite_harness/common/host-side/util/tests/src/com/android/compatibility/common/util/ |
| BusinessLogicHostExecutorTest.java | 70 private BusinessLogicExecutor mExecutor;
76 mExecutor = new BusinessLogicHostExecutor(mMockDevice, mMockBuild, this);
86 mExecutor.invokeMethod(METHOD_1);
93 mExecutor.invokeMethod(OTHER_METHOD_1);
101 mExecutor.invokeMethod(METHOD_2, ARG_STRING_1, ARG_STRING_2);
110 mExecutor.invokeMethod(METHOD_3, ARG_STRING_1);
119 mExecutor.invokeMethod(METHOD_4, ARG_STRING_1);
128 mExecutor.invokeMethod(METHOD_5, ARG_STRING_1, ARG_STRING_2);
137 mExecutor.invokeMethod(METHOD_5);
145 mExecutor.invokeMethod(METHOD_6, ARG_STRING_1, ARG_STRING_2)
[all...] |
| /device/google/cuttlefish_common/guest/monitoring/vsoc_service/java/com/android/google/gce/gceservice/ |
| GceService.java | 43 private final JobExecutor mExecutor = new JobExecutor();
66 mWifiManager = new GceWifiManager(this, mExecutor);
68 mExecutor.schedule(mLocationServices);
69 mExecutor.schedule(mPackageVerifier);
70 mExecutor.schedule(mConsentEnforcer);
71 mExecutor.schedule(mWifiManager);
72 mExecutor.schedule(mBluetoothChecker);
75 // mExecutor.schedule(mTombstoneChecker);
77 mExecutor.schedule(mBootReporter,
125 mExecutor.schedule(mConnChecker)
[all...] |
| /frameworks/base/core/java/android/service/euicc/ |
| EuiccService.java | 168 private ThreadPoolExecutor mExecutor;
183 mExecutor = new ThreadPoolExecutor(
197 mExecutor.allowCoreThreadTimeOut(true);
203 mExecutor.shutdownNow();
406 mExecutor.execute(new Runnable() {
422 mExecutor.execute(new Runnable() {
438 mExecutor.execute(new Runnable() {
457 mExecutor.execute(new Runnable() {
475 mExecutor.execute(new Runnable() {
493 mExecutor.execute(new Runnable()
[all...] |
| /frameworks/base/core/java/android/net/ |
| NetworkRecommendationProvider.java | 89 private final Executor mExecutor;
94 mExecutor = executor;
112 if (mExecutor != null) {
113 mExecutor.execute(command);
|
| /frameworks/support/lifecycle/livedata/src/main/java/androidx/lifecycle/ |
| ComputableLiveData.java | 43 private final Executor mExecutor;
65 mExecutor = executor;
69 mExecutor.execute(mRefreshRunnable);
130 mExecutor.execute(mRefreshRunnable);
|
| /packages/apps/QuickSearchBox/src/com/android/quicksearchbox/util/ |
| BatchingNamedTaskExecutor.java | 34 private final NamedTaskExecutor mExecutor;
36 /** Queue of tasks waiting to be dispatched to mExecutor **/
45 mExecutor = executor;
57 mExecutor.execute(task);
91 mExecutor.close();
|
| /frameworks/base/packages/MtpDocumentsProvider/tests/src/com/android/mtp/ |
| PipeManagerTest.java | 33 private ExecutorService mExecutor;
40 mExecutor = Executors.newSingleThreadExecutor();
42 mPipeManager = new PipeManager(mDatabase, mExecutor);
83 mExecutor.shutdown();
84 assertTrue(mExecutor.awaitTermination(1000, TimeUnit.MILLISECONDS));
97 mExecutor.shutdown();
98 assertTrue(mExecutor.awaitTermination(1000, TimeUnit.MILLISECONDS));
|
