Searched refs:mExecutor (Results 1 – 7 of 7) sorted by relevance
| /tools/tradefederation/core/tests/src/com/android/tradefed/util/executor/ |
| D | ParallelDeviceExecutorTest.java | 40 private ParallelDeviceExecutor<Boolean> mExecutor; field in ParallelDeviceExecutorTest
52 mExecutor = new ParallelDeviceExecutor<>(mDevices); in setUp()
69 List<Boolean> results = mExecutor.invokeAll(callableTasks, 1, TimeUnit.SECONDS); in testSimpleExecution()
89 List<Boolean> results = mExecutor.invokeAll(callableTasks, 1, TimeUnit.SECONDS); in testExecution_errors()
91 assertTrue(mExecutor.hasErrors()); in testExecution_errors()
92 assertEquals(2, mExecutor.getErrors().size()); in testExecution_errors()
93 assertTrue(mExecutor.getErrors().get(0).getMessage().contains("one")); in testExecution_errors()
94 assertTrue(mExecutor.getErrors().get(1).getMessage().contains("two")); in testExecution_errors()
|
| /tools/tradefederation/core/src/com/android/tradefed/util/ |
| D | FileIdleMonitor.java | 43 private ScheduledExecutorService mExecutor; field in FileIdleMonitor
70 if (mExecutor == null) { in start()
71 mExecutor = mExecutorSupplier.get(); in start()
78 if (mExecutor != null) { in stop()
79 mExecutor.shutdownNow(); in stop()
80 mExecutor = null; in stop()
116 mExecutor.schedule(this::checkIfIdle, delay.toMillis(), TimeUnit.MILLISECONDS); in scheduleCheck()
|
| /tools/tradefederation/core/tests/src/com/android/tradefed/util/ |
| D | FileIdleMonitorTest.java | 44 private ScheduledExecutorService mExecutor; field in FileIdleMonitorTest
49 mExecutor = mock(ScheduledExecutorService.class); in setUp()
61 verify(mExecutor, times(1)) in testSchedulesCheckIfNoTimestamp()
76 verify(mExecutor, times(1)) in testSchedulesCheckIfTimeoutNotReached()
91 verify(mExecutor, times(1)) in testExecutesCallbackIfTimeoutExceeded()
120 return new FileIdleMonitor(() -> mExecutor, TIMEOUT, mCallback, files); in createMonitor()
|
| /tools/apksig/src/main/java/com/android/apksig/util/ |
| D | RunnablesExecutor.java | 35 final ExecutorService mExecutor =
50 mExecutor.execute(task);
56 mExecutor.shutdownNow();
|
| /tools/tradefederation/core/clearcut_client/com/android/tradefed/clearcut/ |
| D | ClearcutClient.java | 75 private ScheduledThreadPoolExecutor mExecutor; field in ClearcutClient
114 mExecutor = new ScheduledThreadPoolExecutor(1); in ClearcutClient()
122 mExecutor.scheduleAtFixedRate( in ClearcutClient()
159 if (mExecutor != null) { in stop()
160 mExecutor.setRemoveOnCancelPolicy(true); in stop()
161 mExecutor.shutdown(); in stop()
162 mExecutor = null; in stop()
|
| /tools/apksig/src/main/java/com/android/apksig/internal/util/ |
| D | VerityTreeBuilder.java | 80 private final ExecutorService mExecutor = field in VerityTreeBuilder
93 mExecutor.shutdownNow(); in close()
260 mExecutor.execute(task); in digestDataByChunks()
|
| /tools/apksig/src/main/java/com/android/apksig/ |
| D | DefaultApkSignerEngine.java | 158 private RunnablesExecutor mExecutor = RunnablesExecutor.MULTI_THREADED; field in DefaultApkSignerEngine
521 mExecutor = executor; in setExecutor()
862 mExecutor, in outputZipSectionsInternal()
876 mExecutor, in outputZipSectionsInternal()
|