| /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);
|
| PerNameExecutorTest.java | 33 private NamedTaskExecutor mExecutor;
40 mExecutor = new PerNameExecutor(mExecutorFactory);
70 mExecutor.cancelPendingTasks(); // cancel a2
91 mExecutor.execute(a1);
94 mExecutor.close();
96 mExecutor.close();
102 mExecutor.execute(task);
|
| /packages/apps/Dialer/InCallUI/tests/src/com/android/incallui/ringtone/ |
| InCallTonePlayerTest.java | 44 private PausableExecutor mExecutor;
52 mExecutor = new SingleProdThreadExecutor();
53 mInCallTonePlayer = new InCallTonePlayer(mToneGeneratorFactory, mExecutor);
62 mExecutor.ackAllMilestonesForTesting();
71 mExecutor.awaitMilestoneForTesting();
85 mExecutor.awaitMilestoneForTesting();
94 mExecutor.awaitMilestoneForTesting();
101 mExecutor.awaitMilestoneForTesting();
102 mExecutor.ackMilestoneForTesting();
104 mExecutor.ackMilestoneForTesting()
[all...] |
| /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/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();
|
| ConcurrentState.java | 34 private final Executor mExecutor;
38 mExecutor = executor;
47 mExecutor.execute(mListener);
|
| /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;
|
| PipeManager.java | 33 final ExecutorService mExecutor;
42 this.mExecutor = executor;
47 mExecutor.execute(task);
53 mExecutor.execute(task);
118 mExecutor.shutdownNow();
119 return mExecutor.awaitTermination(AWAIT_TERMINATION_TIMEOUT, TimeUnit.MILLISECONDS);
|
| /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));
|
| /frameworks/base/packages/DocumentsUI/tests/src/com/android/documentsui/services/ |
| FileOperationServiceTest.java | 49 private TestScheduledExecutorService mExecutor;
61 mExecutor = new TestScheduledExecutorService();
68 mService.executor = mExecutor;
78 mExecutor.runAll();
88 mExecutor.runAll();
98 mExecutor.runAll();
112 mExecutor.runAll();
120 mExecutor.runAll();
127 mExecutor.assertAlive();
129 mExecutor.runAll()
[all...] |
| /packages/apps/Dialer/InCallUI/src/com/android/incallui/ringtone/ |
| InCallTonePlayer.java | 43 private final PausableExecutor mExecutor;
57 mExecutor = Preconditions.checkNotNull(executor);
80 mExecutor.execute(new Runnable() {
114 * During tests, this will block until the tests call mExecutor.ackMilestone. This call
117 mExecutor.milestone();
121 mExecutor.milestone();
133 mExecutor.milestone();
|
| /packages/apps/Dialer/src/com/android/dialer/util/ |
| AsyncTaskExecutors.java | 87 private final Executor mExecutor;
90 mExecutor = executor;
97 return task.executeOnExecutor(mExecutor, params);
|
| /frameworks/base/packages/SystemUI/src/com/android/systemui/stackdivider/ |
| WindowManagerProxy.java | 62 private final ExecutorService mExecutor = Executors.newSingleThreadExecutor();
181 mExecutor.execute(mResizeRunnable);
185 mExecutor.execute(mDismissRunnable);
189 mExecutor.execute(mMaximizeRunnable);
193 mExecutor.execute(new Runnable() {
218 mExecutor.execute(mDimLayerRunnable);
222 mExecutor.execute(mSwapRunnable);
229 mExecutor.execute(mSetTouchableRegionRunnable);
|
| /packages/apps/Camera2/src/com/android/camera/settings/ |
| SettingObserver.java | 36 private final Executor mExecutor;
40 mExecutor = executor;
45 mExecutor.execute(mRunnable);
|
| /packages/inputmethods/LatinIME/java/src/com/android/inputmethod/dictionarypack/ |
| DictionaryService.java | 113 private ThreadPoolExecutor mExecutor;
127 mExecutor = new ThreadPoolExecutor(1 /* corePoolSize */, 1 /* maximumPoolSize */,
131 mExecutor.allowCoreThreadTimeOut(true);
179 mExecutor.submit(new Runnable() {
|
| /packages/apps/Camera2/src/com/android/camera/processing/imagebackend/ |
| TaskPreviewChainedJpeg.java | 83 TaskImageContainer jpegTask = new TaskCompressImageToJpeg(img, mExecutor,
88 mImageTaskManager.releaseSemaphoreReference(img, mExecutor);
|
| TaskImageContainer.java | 146 final protected Executor mExecutor;
164 mExecutor = otherTask.mExecutor;
186 mExecutor = Executor;
|
| /packages/apps/Gallery2/gallerycommon/src/com/android/gallery3d/util/ |
| ThreadPool.java | 81 private final Executor mExecutor;
88 mExecutor = new ThreadPoolExecutor(
99 mExecutor.execute(w);
|
| /packages/apps/Camera2/src/com/android/camera/one/v2/imagesaver/ |
| JpegImageBackendImageSaver.java | 89 mCrop), mExecutor, taskFlagsSet, mSession,
159 private final Executor mExecutor;
175 mExecutor = Executors.newSingleThreadExecutor();
192 mExecutor = executor;
|
| YuvImageBackendImageSaver.java | 90 mCrop), mExecutor, taskFlagsSet, mSession,
169 private final Executor mExecutor;
184 mExecutor = Executors.newSingleThreadExecutor();
202 mExecutor = executor;
|
