HomeSort by relevance Sort by last modified time
    Searched defs:mExecutor (Results 1 - 25 of 264) sorted by null

1 2 3 4 5 6 7 8 91011

  /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);
  /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());
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);
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);
  /packages/apps/Dialer/java/com/android/incallui/ringtone/
InCallTonePlayer.java 40 @NonNull private final PausableExecutor mExecutor;
55 mExecutor = Objects.requireNonNull(executor);
76 mExecutor.execute(
112 * During tests, this will block until the tests call mExecutor.ackMilestone. This call
115 mExecutor.milestone();
119 mExecutor.milestone();
131 mExecutor.milestone();
  /external/libmojo/mojo/public/java/bindings/src/org/chromium/mojo/bindings/
AutoCloseableRouter.java 25 private final Executor mExecutor;
37 mExecutor = ExecutorFactory.getExecutorForCurrentThread(core);
104 mExecutor.execute(new Runnable() {
  /packages/apps/DocumentsUI/tests/unit/com/android/documentsui/archives/
TestUtils.java 40 public final ExecutorService mExecutor;
45 mExecutor = executor;
101 mExecutor.execute(
ResourcesProvider.java 64 private ExecutorService mExecutor = null;
69 mExecutor = Executors.newSingleThreadExecutor();
70 mTestUtils = new TestUtils(getContext(), getContext(), mExecutor);
  /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/src/com/android/mtp/
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);
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;
  /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));
  /packages/apps/DocumentsUI/src/com/android/documentsui/archives/
Loader.java 48 private final ExecutorService mExecutor = Executors.newSingleThreadExecutor();
63 mExecutor.submit(this::get);
WriteableArchive.java 60 private final ExecutorService mExecutor = Executors.newSingleThreadExecutor();
233 mExecutor.execute(
287 mExecutor.shutdown();
289 final boolean result = mExecutor.awaitTermination(
  /frameworks/base/core/java/android/net/
NetworkRecommendationProvider.java 88 private final Executor mExecutor;
93 mExecutor = executor;
111 if (mExecutor != null) {
112 mExecutor.execute(command);
  /packages/apps/Dialer/java/com/android/dialer/common/concurrent/
AsyncTaskExecutors.java 79 private final Executor mExecutor;
82 mExecutor = executor;
89 return task.executeOnExecutor(mExecutor, params);
  /external/libmojo/mojo/android/javatests/src/org/chromium/mojo/bindings/
ExecutorFactoryTest.java 29 private Executor mExecutor;
38 mExecutor = ExecutorFactory.getExecutorForCurrentThread(CoreImpl.getInstance());
53 mExecutor.execute(action);
54 mExecutor.execute(action);
73 mExecutor.execute(new Runnable() {
  /packages/apps/Camera2/src/com/android/camera/settings/
SettingObserver.java 36 private final Executor mExecutor;
40 mExecutor = executor;
45 mExecutor.execute(mRunnable);
  /packages/apps/DocumentsUI/tests/unit/com/android/documentsui/services/
FileOperationServiceTest.java 63 private TestScheduledExecutorService mExecutor;
78 mExecutor = new TestScheduledExecutorService();
94 mService.executor = mExecutor;
115 mExecutor.runAll();
127 mExecutor.runAll();
141 mExecutor.runAll();
151 mExecutor.runAll();
159 mExecutor.runAll();
180 mExecutor.runAll();
190 mExecutor.runAll()
    [all...]

Completed in 1252 milliseconds

1 2 3 4 5 6 7 8 91011