Home
last modified time | relevance | path

Searched refs:Runnable (Results 1 – 25 of 683) sorted by relevance

12345678910>>...28

/external/guava/guava-testlib/test/com/google/common/testing/anotherpackage/
DForwardingWrapperTesterTest.java65 tester.testForwarding(Runnable.class, in testVoidMethodForwarding()
66 new Function<Runnable, Runnable>() { in testVoidMethodForwarding()
67 @Override public Runnable apply(final Runnable runnable) { in testVoidMethodForwarding()
74 tester.testForwarding(Runnable.class, in testToStringForwarding()
75 new Function<Runnable, Runnable>() { in testToStringForwarding()
76 @Override public Runnable apply(final Runnable runnable) { in testToStringForwarding()
87 assertFailure(Runnable.class, new Function<Runnable, Runnable>() { in testFailsToForwardToString()
88 @Override public Runnable apply(final Runnable runnable) { in testFailsToForwardToString()
100 assertFailure(Runnable.class, new Function<Runnable, Runnable>() { in testFailsToForwardHashCode()
101 @Override public Runnable apply(final Runnable runnable) { in testFailsToForwardHashCode()
[all …]
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DKeepAliveManagerTest.java74 ArgumentCaptor<Runnable> sendPingCaptor = ArgumentCaptor.forClass(Runnable.class); in sendKeepAlivePings()
77 Runnable sendPing = sendPingCaptor.getValue(); in sendKeepAlivePings()
83 .when(scheduler).schedule(isA(Runnable.class), isA(Long.class), isA(TimeUnit.class)); in sendKeepAlivePings()
88 verify(scheduler, times(2)).schedule(isA(Runnable.class), delayCaptor.capture(), in sendKeepAlivePings()
97 verify(scheduler, times(3)).schedule(isA(Runnable.class), delayCaptor.capture(), in sendKeepAlivePings()
110 .when(scheduler).schedule(isA(Runnable.class), isA(Long.class), isA(TimeUnit.class)); in keepAlivePingDelayedByIncomingData()
114 ArgumentCaptor<Runnable> sendPingCaptor = ArgumentCaptor.forClass(Runnable.class); in keepAlivePingDelayedByIncomingData()
117 Runnable sendPing = sendPingCaptor.getValue(); in keepAlivePingDelayedByIncomingData()
129 verify(scheduler, times(2)).schedule(isA(Runnable.class), delayCaptor.capture(), in keepAlivePingDelayedByIncomingData()
171 ArgumentCaptor<Runnable> sendPingCaptor = ArgumentCaptor.forClass(Runnable.class); in onTransportTerminationCancelsShutdownFuture()
[all …]
DSerializeReentrantCallsDirectExecutorTest.java44 executor.execute(new Runnable() { in reentrantCallsShouldBeSerialized()
47 executor.execute(new Runnable() { in reentrantCallsShouldBeSerialized()
50 executor.execute(new Runnable() { in reentrantCallsShouldBeSerialized()
58 executor.execute(new Runnable() { in reentrantCallsShouldBeSerialized()
76 executor.execute(new Runnable() { in exceptionShouldNotCancelQueuedTasks()
79 executor.execute(new Runnable() { in exceptionShouldNotCancelQueuedTasks()
86 executor.execute(new Runnable() { in exceptionShouldNotCancelQueuedTasks()
109 executor.execute(new Runnable() { in executeCanBeRepeated()
115 executor.execute(new Runnable() { in executeCanBeRepeated()
131 executor.execute(new Runnable() { in interruptDoesNotAffectExecution()
[all …]
DSerializingExecutorTest.java40 private class AddToRuns implements Runnable {
59 public void execute(Runnable command) { in resumable()
107 executor.execute(new Runnable() { in reentrant()
122 executor.execute(new Runnable() { in testFirstRunnableThrows()
142 executor.execute(new Runnable() { in lastRunnableThrows()
165 public void execute(Runnable r) { in firstExecuteThrows()
200 executor.execute(new Runnable() { in testDirectReentrant()
213 private Runnable runnable;
216 public void execute(Runnable r) { in execute()
225 Runnable r = runnable; in drain()
[all …]
DFakeClock.java46 public boolean shouldAccept(Runnable command) {
73 public final Runnable command;
76 ScheduledTask(long dueTimeNanos, Runnable command) { in ScheduledTask()
117 @Override public ScheduledFuture<?> schedule(Runnable cmd, long delay, TimeUnit unit) { in schedule()
124 Runnable command, long initialDelay, long period, TimeUnit unit) { in scheduleAtFixedRate()
129 Runnable command, long initialDelay, long delay, TimeUnit unit) { in scheduleWithFixedDelay()
167 @Override public List<Runnable> shutdownNow() { in shutdownNow()
175 @Override public Future<?> submit(Runnable task) { in submit()
179 @Override public <T> Future<T> submit(Runnable task, T result) { in submit()
183 @Override public void execute(Runnable command) { in execute()
[all …]
DConnectivityStateManagerTest.java61 state.notifyWhenStateChanged(new Runnable() { in registerCallbackBeforeStateChanged()
83 state.notifyWhenStateChanged(new Runnable() { in registerCallbackAfterStateChanged()
100 state.notifyWhenStateChanged(new Runnable() { in callbackOnlyCalledOnTransition()
114 Runnable callback = new Runnable() { in callbacksAreOneShot()
151 state.notifyWhenStateChanged(new Runnable() { in multipleCallbacks()
158 state.notifyWhenStateChanged(new Runnable() { in multipleCallbacks()
165 state.notifyWhenStateChanged(new Runnable() { in multipleCallbacks()
194 private Runnable newRecursiveCallback(final Executor executor) { in newRecursiveCallback()
195 return new Runnable() { in newRecursiveCallback()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DDelayedStream.java55 private List<Runnable> pendingCalls = new ArrayList<>();
64 delayOrExecute(new Runnable() { in setMaxInboundMessageSize()
78 delayOrExecute(new Runnable() { in setMaxOutboundMessageSize()
89 delayOrExecute(new Runnable() { in setDeadline()
123 List<Runnable> toRun = new ArrayList<>(); in drainPendingCalls()
136 List<Runnable> tmp = toRun; in drainPendingCalls()
140 for (Runnable runnable : toRun) { in drainPendingCalls()
159 private void delayOrExecute(Runnable runnable) { in delayOrExecute()
173 delayOrExecute(new Runnable() { in setAuthority()
205 delayOrExecute(new Runnable() { in start()
[all …]
DApplicationThreadDeframer.java36 void runOnTransportThread(Runnable r); in runOnTransportThread()
75 new Runnable() { in request()
95 new Runnable() { in deframe()
112 new Runnable() { in closeWhenComplete()
125 new Runnable() { in close()
136 new Runnable() { in bytesRead()
155 new Runnable() { in deframerClosed()
166 new Runnable() { in deframeFailed()
175 private final Runnable runnable;
178 private InitializingMessageProducer(Runnable runnable) { in InitializingMessageProducer()
DSerializeReentrantCallsDirectExecutor.java41 private ArrayDeque<Runnable> taskQueue;
44 public void execute(Runnable task) { in execute()
64 Runnable task = null; in completeQueuedTasks()
75 private void enqueue(Runnable r) { in enqueue()
77 taskQueue = new ArrayDeque<Runnable>(4); in enqueue()
/external/guava/guava-tests/benchmark/com/google/common/util/concurrent/
DExecutionListBenchmark.java53 void add(Runnable runnable, Executor executor); in add()
64 @Override public void add(Runnable runnable, Executor executor) { in newExecutionList()
82 @Override public void add(Runnable runnable, Executor executor) { in newExecutionList()
100 @Override public void add(Runnable runnable, Executor executor) { in newExecutionList()
118 @Override public void add(Runnable runnable, Executor executor) {
136 @Override public void add(Runnable runnable, Executor executor) {
160 private final Runnable listener = new Runnable() {
171 new ArrayBlockingQueue<Runnable>(1000));
175 executorService.submit(new Runnable() {
186 @Footprint(exclude = {Runnable.class, Executor.class})
[all …]
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DSerializingExecutorTest.java43 Queue<Runnable> tasks = Queues.newArrayDeque();
44 @Override public void execute(Runnable command) { in execute()
77 Runnable intCounter = new Runnable() { in testBasics()
106 class FakeOp implements Runnable { in testOrdering()
131 Runnable runMe = new Runnable() { in testExceptions()
151 @Override public void execute(Runnable r) { in testDelegateRejection()
158 Runnable task = new Runnable() { in testDelegateRejection()
181 Runnable errorTask = new Runnable() { in testTaskThrowsError()
187 Runnable barrierTask = new Runnable() { in testTaskThrowsError()
DWrappingScheduledExecutorServiceTest.java38 private static final Runnable DO_NOTHING = new Runnable() {
78 private static final class WrappedRunnable implements Runnable {
79 private final Runnable delegate;
81 public WrappedRunnable(Runnable delegate) { in WrappedRunnable()
101 @Override protected Runnable wrapTask(Runnable command) { in wrapTask()
125 @Override public ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) { in schedule()
143 Runnable command, long initialDelay, long period, TimeUnit unit) { in scheduleAtFixedRate()
153 Runnable command, long initialDelay, long delay, TimeUnit unit) { in scheduleWithFixedDelay()
209 public List<Runnable> shutdownNow() { in shutdownNow()
219 public Future<?> submit(Runnable task) { in submit()
[all …]
DExecutionListTest.java57 list.add(new Runnable() { in testExecute_idempotent()
71 list.add(new Runnable() { in testExecute_idempotentConcurrently()
82 Runnable execute = new Runnable() { in testExecute_idempotentConcurrently()
113 new Runnable() { in testOrdering()
124 private class MockRunnable implements Runnable {
146 private static final Runnable THROWING_RUNNABLE = new Runnable() {
/external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/android/util/concurrent/
DRoboExecutorService.java23 private final HashSet<Runnable> runnables = new HashSet<>();
33 public AdvancingFutureTask(Scheduler scheduler, Runnable runnable, V result) { in AdvancingFutureTask()
57 public List<Runnable> shutdownNow() { in shutdownNow()
59 List<Runnable> notExecutedRunnables = new ArrayList<>(); in shutdownNow()
60 for (Runnable runnable : runnables) { in shutdownNow()
90 public <T> Future<T> submit(Runnable runnable, T t) { in submit()
95 public Future<?> submit(Runnable runnable) { in submit()
100 Runnable runnable = new Runnable() { in schedule()
134 public void execute(Runnable runnable) { in execute()
/external/guice/core/src/com/google/inject/internal/
DProcessedBindingData.java31 private final List<Runnable> uninitializedBindings = Lists.newArrayList();
32 private final List<Runnable> delayedUninitializedBindings = Lists.newArrayList();
38 void addUninitializedBinding(Runnable runnable) { in addUninitializedBinding()
42 void addDelayedUninitializedBinding(Runnable runnable) { in addDelayedUninitializedBinding()
48 for (Runnable initializer : uninitializedBindings) { in initializeBindings()
70 for (Runnable initializer : delayedUninitializedBindings) { in initializeDelayedBindings()
/external/robolectric-shadows/utils/src/test/java/org/robolectric/util/
DSchedulerTest.java212 scheduler.postDelayed(new Runnable() { in postDelayed_whenMoreItemsAreAdded_runsJobs()
216 scheduler.postDelayed(new Runnable() { in postDelayed_whenMoreItemsAreAdded_runsJobs()
289 scheduler.postDelayed(new Runnable() { in nestedPost_whilePaused_doesntAutomaticallyExecute()
293 scheduler.post(new Runnable() { in nestedPost_whilePaused_doesntAutomaticallyExecute()
302 scheduler.postDelayed(new Runnable() { in nestedPost_whilePaused_doesntAutomaticallyExecute()
324 scheduler.postDelayed(new Runnable() { in nestedPost_whileUnpaused_automaticallyExecutes3After()
328 scheduler.post(new Runnable() { in nestedPost_whileUnpaused_automaticallyExecutes3After()
345 scheduler.postDelayed(new Runnable() { in nestedPostAtFront_whilePaused_runsBeforeSubsequentPost()
349 scheduler.postAtFrontOfQueue(new Runnable() { in nestedPostAtFront_whilePaused_runsBeforeSubsequentPost()
358 scheduler.postDelayed(new Runnable() { in nestedPostAtFront_whilePaused_runsBeforeSubsequentPost()
[all …]
/external/grpc-grpc-java/core/src/main/java/io/grpc/util/
DTransmitStatusRuntimeExceptionInterceptor.java134 serializingExecutor.execute(new Runnable() {
144 serializingExecutor.execute(new Runnable() {
154 serializingExecutor.execute(new Runnable() {
164 serializingExecutor.execute(new Runnable() {
179 serializingExecutor.execute(new Runnable() {
197 serializingExecutor.execute(new Runnable() {
214 serializingExecutor.execute(new Runnable() {
224 serializingExecutor.execute(new Runnable() {
235 serializingExecutor.execute(new Runnable() {
254 serializingExecutor.execute(new Runnable() {
/external/jsilver/src/org/clearsilver/jni/
DJNI.java39 public static Runnable EXIT_JVM = new Runnable() {
58 public static Runnable THROW_ERROR = new Runnable() {
64 private static Runnable failureCallback = EXIT_JVM;
119 public static void setFailureCallback(Runnable failureCallback) { in setFailureCallback()
/external/robolectric-shadows/shadows/supportv4/src/main/java/org/robolectric/shadows/support/v4/
DSupportFragmentController.java107 new Runnable() { in create()
136 shadowMainLooper.runPaused(new Runnable() { in postCreate()
147 shadowMainLooper.runPaused(new Runnable() { in destroy()
157 shadowMainLooper.runPaused(new Runnable() { in start()
167 shadowMainLooper.runPaused(new Runnable() { in resume()
177 shadowMainLooper.runPaused(new Runnable() { in pause()
187 shadowMainLooper.runPaused(new Runnable() { in stop()
197 shadowMainLooper.runPaused(new Runnable() { in visible()
208 new Runnable() { in saveInstanceState()
/external/robolectric-shadows/utils/src/main/java/org/robolectric/util/
DScheduler.java140 public synchronized void post(Runnable runnable) { in post()
150 public synchronized void postDelayed(Runnable runnable, long delayMillis) { in postDelayed()
157 public synchronized void postDelayed(Runnable runnable, long delay, TimeUnit unit) { in postDelayed()
171 public synchronized void postAtFrontOfQueue(Runnable runnable) { in postAtFrontOfQueue()
190 public synchronized void remove(Runnable runnable) { in remove()
331 private void runOrQueueRunnable(Runnable runnable, long scheduledTime) { in runOrQueueRunnable()
360 private final Runnable runnable;
364 private ScheduledRunnable(Runnable runnable, long scheduledTime) { in ScheduledRunnable()
368 private ScheduledRunnable(Runnable runnable, long scheduledTime, long timeDisambiguator) { in ScheduledRunnable()
/external/guava/guava/src/com/google/common/util/concurrent/
DMoreExecutors.java195 addShutdownHook(MoreExecutors.newThread("DelayedShutdownHook-for-" + service, new Runnable() { in addDelayedShutdownHook()
296 public void execute(Runnable command) { in execute()
327 public List<Runnable> shutdownNow() { in shutdownNow()
456 @Override public void execute(Runnable command) { in execute()
544 public List<Runnable> shutdownNow() { in shutdownNow()
549 public void execute(Runnable command) { in execute()
566 Runnable command, long delay, TimeUnit unit) { in schedule()
583 Runnable command, long initialDelay, long period, TimeUnit unit) { in scheduleAtFixedRate()
593 Runnable command, long initialDelay, long delay, TimeUnit unit) { in scheduleWithFixedDelay()
639 implements Runnable {
[all …]
DAbstractScheduledService.java126 Runnable task) { in newFixedDelaySchedule()
145 Runnable task) { in newFixedRateSchedule()
153 Runnable runnable);
170 private final Runnable task = new Runnable() {
196 executorService.execute(new Runnable() {
215 executorService.execute(new Runnable() {
289 @Override public Thread newThread(Runnable runnable) {
406 private final Runnable wrappedRunnable;
429 Runnable runnable) {
489 Runnable runnable) {
/external/libchrome/base/android/javatests/src/org/chromium/base/
DAsyncTaskTest.java45 private static class SpecialRunnable implements Runnable {
63 new ArrayBlockingQueue<Runnable>(QUEUE_SIZE), new ThreadFactory() { in testChromeThreadPoolExecutorRunnables()
65 public Thread newThread(@NonNull Runnable r) { in testChromeThreadPoolExecutorRunnables()
88 new ArrayBlockingQueue<Runnable>(QUEUE_SIZE), new ThreadFactory() { in testChromeThreadPoolExecutorChromeAsyncTask()
90 public Thread newThread(@NonNull Runnable r) { in testChromeThreadPoolExecutorChromeAsyncTask()
112 new ArrayBlockingQueue<Runnable>(QUEUE_SIZE), new ThreadFactory() { in testChromeThreadPoolExecutorOsAsyncTask()
114 public Thread newThread(@NonNull Runnable r) { in testChromeThreadPoolExecutorOsAsyncTask()
/external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/android/controller/
DFragmentController.java73 shadowMainLooper.runPaused(new Runnable() { in create()
96 shadowMainLooper.runPaused(new Runnable() { in destroy()
106 shadowMainLooper.runPaused(new Runnable() { in start()
116 shadowMainLooper.runPaused(new Runnable() { in resume()
126 shadowMainLooper.runPaused(new Runnable() { in pause()
136 shadowMainLooper.runPaused(new Runnable() { in visible()
146 shadowMainLooper.runPaused(new Runnable() { in stop()
156 shadowMainLooper.runPaused(new Runnable() { in saveInstanceState()
/external/desugar/test/java/com/google/devtools/build/android/desugar/
DDefaultMethodClassFixerTest.java209 assertThat(INSTANCE.compare(Runnable.class, Runnable.class)).isEqualTo(0); in testInterfaceComparator()
210 assertThat(INSTANCE.compare(Runnable.class, MyRunnable1.class)).isEqualTo(1); in testInterfaceComparator()
211 assertThat(INSTANCE.compare(MyRunnable2.class, Runnable.class)).isEqualTo(-1); in testInterfaceComparator()
212 assertThat(INSTANCE.compare(MyRunnable3.class, Runnable.class)).isEqualTo(-1); in testInterfaceComparator()
216 assertThat(INSTANCE.compare(Runnable.class, Serializable.class)).isGreaterThan(0); in testInterfaceComparator()
217 assertThat(INSTANCE.compare(Serializable.class, Runnable.class)).isLessThan(0); in testInterfaceComparator()
221 orderedSet.add(Runnable.class); in testInterfaceComparator()
233 Runnable.class, in testInterfaceComparator()
238 private static interface MyRunnable1 extends Runnable {}
240 private static interface MyRunnable2 extends Runnable {}

12345678910>>...28