| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | KeepAliveManagerTest.java | 74 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 …]
|
| D | SerializeReentrantCallsDirectExecutorTest.java | 44 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 …]
|
| D | SerializingExecutorTest.java | 40 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 …]
|
| /external/guava/guava-testlib/test/com/google/common/testing/anotherpackage/ |
| D | ForwardingWrapperTesterTest.java | 69 Runnable.class, in testVoidMethodForwarding()
70 new Function<Runnable, Runnable>() { in testVoidMethodForwarding()
72 public Runnable apply(final Runnable runnable) { in testVoidMethodForwarding()
80 Runnable.class, in testToStringForwarding()
81 new Function<Runnable, Runnable>() { in testToStringForwarding()
83 public Runnable apply(final Runnable runnable) { in testToStringForwarding()
96 Runnable.class, in testFailsToForwardToString()
97 new Function<Runnable, Runnable>() { in testFailsToForwardToString()
99 public Runnable apply(final Runnable runnable) { in testFailsToForwardToString()
114 Runnable.class, in testFailsToForwardHashCode()
[all …]
|
| /external/guava/android/guava-testlib/test/com/google/common/testing/anotherpackage/ |
| D | ForwardingWrapperTesterTest.java | 69 Runnable.class, in testVoidMethodForwarding()
70 new Function<Runnable, Runnable>() { in testVoidMethodForwarding()
72 public Runnable apply(final Runnable runnable) { in testVoidMethodForwarding()
80 Runnable.class, in testToStringForwarding()
81 new Function<Runnable, Runnable>() { in testToStringForwarding()
83 public Runnable apply(final Runnable runnable) { in testToStringForwarding()
96 Runnable.class, in testFailsToForwardToString()
97 new Function<Runnable, Runnable>() { in testFailsToForwardToString()
99 public Runnable apply(final Runnable runnable) { in testFailsToForwardToString()
114 Runnable.class, in testFailsToForwardHashCode()
[all …]
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | DelayedStream.java | 55 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 …]
|
| D | ApplicationThreadDeframer.java | 36 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()
|
| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | SequentialExecutorTest.java | 49 Queue<Runnable> tasks = Queues.newArrayDeque();
52 public void execute(Runnable command) { in execute()
91 Runnable intCounter = in testBasics()
92 new Runnable() { in testBasics()
127 class FakeOp implements Runnable { in testOrdering()
152 Runnable runMe = in testRuntimeException_doesNotStopExecution()
153 new Runnable() { in testRuntimeException_doesNotStopExecution()
171 new Runnable() { in testInterrupt_beforeRunRestoresInterruption()
179 new Runnable() { in testInterrupt_beforeRunRestoresInterruption()
198 new Runnable() { in testInterrupt_doesNotInterruptSubsequentTask()
[all …]
|
| D | WrappingScheduledExecutorServiceTest.java | 39 private static final Runnable DO_NOTHING =
40 new Runnable() {
86 private static final class WrappedRunnable implements Runnable {
87 private final Runnable delegate;
89 public WrappedRunnable(Runnable delegate) { in WrappedRunnable()
110 protected Runnable wrapTask(Runnable command) { in wrapTask()
135 public ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) { in schedule()
154 Runnable command, long initialDelay, long period, TimeUnit unit) { in scheduleAtFixedRate()
165 Runnable command, long initialDelay, long delay, TimeUnit unit) { in scheduleWithFixedDelay()
221 public List<Runnable> shutdownNow() { in shutdownNow()
[all …]
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | SequentialExecutorTest.java | 49 Queue<Runnable> tasks = Queues.newArrayDeque();
52 public void execute(Runnable command) { in execute()
91 Runnable intCounter = in testBasics()
92 new Runnable() { in testBasics()
127 class FakeOp implements Runnable { in testOrdering()
152 Runnable runMe = in testRuntimeException_doesNotStopExecution()
153 new Runnable() { in testRuntimeException_doesNotStopExecution()
171 new Runnable() { in testInterrupt_beforeRunRestoresInterruption()
179 new Runnable() { in testInterrupt_beforeRunRestoresInterruption()
198 new Runnable() { in testInterrupt_doesNotInterruptSubsequentTask()
[all …]
|
| D | WrappingScheduledExecutorServiceTest.java | 39 private static final Runnable DO_NOTHING =
40 new Runnable() {
86 private static final class WrappedRunnable implements Runnable {
87 private final Runnable delegate;
89 public WrappedRunnable(Runnable delegate) { in WrappedRunnable()
110 protected Runnable wrapTask(Runnable command) { in wrapTask()
135 public ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) { in schedule()
154 Runnable command, long initialDelay, long period, TimeUnit unit) { in scheduleAtFixedRate()
165 Runnable command, long initialDelay, long delay, TimeUnit unit) { in scheduleWithFixedDelay()
221 public List<Runnable> shutdownNow() { in shutdownNow()
[all …]
|
| /external/rust/crates/async-task/src/ |
| D | runnable.rs | 45 pub fn spawn<F, S>(future: F, schedule: S) -> (Runnable, Task<F::Output>) in spawn() argument
49 S: Fn(Runnable) + Send + Sync + 'static, in spawn()
87 pub fn spawn_local<F, S>(future: F, schedule: S) -> (Runnable, Task<F::Output>) in spawn_local() argument
91 S: Fn(Runnable) + Send + Sync + 'static, in spawn_local()
174 pub unsafe fn spawn_unchecked<F, S>(future: F, schedule: S) -> (Runnable, Task<F::Output>) in spawn_unchecked() argument
177 S: Fn(Runnable), in spawn_unchecked() argument
187 let runnable = Runnable { ptr }; in spawn_unchecked()
233 pub struct Runnable { struct
238 unsafe impl Send for Runnable {} implementation
239 unsafe impl Sync for Runnable {} implementation
[all …]
|
| /external/guava/android/guava-tests/benchmark/com/google/common/util/concurrent/ |
| D | ExecutionListBenchmark.java | 50 void add(Runnable runnable, Executor executor); in add()
65 public void add(Runnable runnable, Executor executor) { in newExecutionList()
88 public void add(Runnable runnable, Executor executor) { in newExecutionList()
111 public void add(Runnable runnable, Executor executor) { in newExecutionList()
134 public void add(Runnable runnable, Executor executor) {
157 public void add(Runnable runnable, Executor executor) {
180 public void add(Runnable runnable, Executor executor) {
204 public void add(Runnable runnable, Executor executor) {
234 private final Runnable listener =
235 new Runnable() {
[all …]
|
| /external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
| D | ExecutionListBenchmark.java | 50 void add(Runnable runnable, Executor executor); in add()
65 public void add(Runnable runnable, Executor executor) { in newExecutionList()
88 public void add(Runnable runnable, Executor executor) { in newExecutionList()
111 public void add(Runnable runnable, Executor executor) { in newExecutionList()
134 public void add(Runnable runnable, Executor executor) {
157 public void add(Runnable runnable, Executor executor) {
180 public void add(Runnable runnable, Executor executor) {
204 public void add(Runnable runnable, Executor executor) {
234 private final Runnable listener =
235 new Runnable() {
[all …]
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | InterruptibleTask.java | 30 abstract class InterruptibleTask<T> extends AtomicReference<Runnable> implements Runnable {
38 private static final class DoNothingRunnable implements Runnable {
44 private static final Runnable DONE = new DoNothingRunnable();
45 private static final Runnable INTERRUPTING = new DoNothingRunnable();
46 private static final Runnable PARKED = new DoNothingRunnable();
93 Runnable state = get(); in run()
164 Runnable currentRunner = get(); in interruptTask()
173 Runnable prev = getAndSet(DONE); in interruptTask()
183 Runnable state = get(); in toString()
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | InterruptibleTask.java | 30 abstract class InterruptibleTask<T> extends AtomicReference<Runnable> implements Runnable {
38 private static final class DoNothingRunnable implements Runnable {
44 private static final Runnable DONE = new DoNothingRunnable();
45 private static final Runnable INTERRUPTING = new DoNothingRunnable();
46 private static final Runnable PARKED = new DoNothingRunnable();
93 Runnable state = get(); in run()
164 Runnable currentRunner = get(); in interruptTask()
173 Runnable prev = getAndSet(DONE); in interruptTask()
183 Runnable state = get(); in toString()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/ |
| D | CoroutineSchedulerTest.kt | 9 import java.lang.Runnable in <lambda>()
22 it.dispatch(Runnable { in <lambda>()
35 it.dispatch(Runnable { in <lambda>()
37 it.dispatch(Runnable { in <lambda>()
53 it.dispatch(Runnable { in <lambda>()
54 it.dispatch(Runnable { in <lambda>()
59 it.dispatch(Runnable { in <lambda>()
77 it.dispatch(Runnable { in <lambda>()
78 it.dispatch(Runnable { in <lambda>()
83 it.dispatch(Runnable { in <lambda>()
[all …]
|
| D | BlockingCoroutineDispatcherMixedStealingStressTest.kt | 30 regular.execute(Runnable { in testBlockingProgressPreventedInternal()
33 regular.execute(Runnable { in testBlockingProgressPreventedInternal()
38 blocking.execute(Runnable { in testBlockingProgressPreventedInternal()
42 regular.execute(Runnable { in testBlockingProgressPreventedInternal()
59 regular.execute(Runnable { in testBlockingProgressPreventedExternal()
70 blocking.execute(Runnable { in testBlockingProgressPreventedExternal()
73 regular.execute(Runnable { in testBlockingProgressPreventedExternal()
|
| /external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/android/util/concurrent/ |
| D | RoboExecutorService.java | 23 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/ |
| D | ProcessedBindingData.java | 31 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/crosvm/cros_async/src/ |
| D | queue.rs | 7 use async_task::Runnable;
13 runnables: Mutex<VecDeque<Runnable>>,
25 pub fn push_back(&self, runnable: Runnable) { in push_back() argument
30 pub fn pop_front(&self) -> Option<Runnable> { in pop_front() argument
42 type Item = Runnable;
56 type Item = Runnable;
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | Runnable.kt | 10 public actual typealias Runnable = java.lang.Runnable typealias
16 public actual inline fun Runnable(crossinline block: () -> Unit): Runnable = in Runnable() method
17 java.lang.Runnable { block() } in Runnable()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | EventLoop.common.kt | 240 protected fun scheduleInvokeOnTimeout(timeMillis: Long, block: Runnable): DisposableHandle { in scheduleInvokeOnTimeout()
280 public final override fun dispatch(context: CoroutineContext, block: Runnable) = enqueue(block) in dispatch()
282 public fun enqueue(task: Runnable) { in dispatch()
292 private fun enqueueImpl(task: Runnable): Boolean { in enqueueImpl()
298 when ((queue as Queue<Runnable>).addLast(task)) { in enqueueImpl()
308 … val newQueue = Queue<Runnable>(Queue.INITIAL_CAPACITY, singleConsumer = true) in enqueueImpl()
309 newQueue.addLast(queue as Runnable) in enqueueImpl()
319 private fun dequeue(): Runnable? { in dequeue()
324 val result = (queue as Queue<Runnable>).removeFirstOrNull() in dequeue()
325 if (result !== Queue.REMOVE_FROZEN) return result as Runnable? in dequeue()
[all …]
|
| /external/jsilver/src/org/clearsilver/jni/ |
| D | JNI.java | 39 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/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
| D | TransmitStatusRuntimeExceptionInterceptor.java | 134 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() {
|