Home
last modified time | relevance | path

Searched refs:runnable (Results 1 – 25 of 151) sorted by relevance

1234567

/external/guava/guava-tests/benchmark/com/google/common/util/concurrent/
DExecutionListBenchmark.java53 void add(Runnable runnable, Executor executor); in add() argument
64 @Override public void add(Runnable runnable, Executor executor) { in newExecutionList() argument
65 list.add(runnable, executor); in newExecutionList()
82 @Override public void add(Runnable runnable, Executor executor) { in newExecutionList() argument
83 list.add(runnable, executor); in newExecutionList()
100 @Override public void add(Runnable runnable, Executor executor) { in newExecutionList() argument
101 list.add(runnable, executor); in newExecutionList()
118 @Override public void add(Runnable runnable, Executor executor) {
119 list.add(runnable, executor);
136 @Override public void add(Runnable runnable, Executor executor) {
[all …]
/external/robolectric-shadows/utils/src/main/java/org/robolectric/util/
DScheduler.java140 public synchronized void post(Runnable runnable) { in post() argument
141 postDelayed(runnable, 0, TimeUnit.MILLISECONDS); in post()
150 public synchronized void postDelayed(Runnable runnable, long delayMillis) { in postDelayed() argument
151 postDelayed(runnable, delayMillis, TimeUnit.MILLISECONDS); in postDelayed()
157 public synchronized void postDelayed(Runnable runnable, long delay, TimeUnit unit) { in postDelayed() argument
160 runnables.add(new ScheduledRunnable(runnable, currentTime + delayMillis)); in postDelayed()
162 runOrQueueRunnable(runnable, currentTime + delayMillis); in postDelayed()
171 public synchronized void postAtFrontOfQueue(Runnable runnable) { in postAtFrontOfQueue() argument
179 runnables.add(new ScheduledRunnable(runnable, 0, timeDisambiguator)); in postAtFrontOfQueue()
181 runOrQueueRunnable(runnable, currentTime); in postAtFrontOfQueue()
[all …]
/external/guava/guava-testlib/test/com/google/common/testing/anotherpackage/
DForwardingWrapperTesterTest.java67 @Override public Runnable apply(final Runnable runnable) { in testVoidMethodForwarding()
68 return new ForwardingRunnable(runnable); in testVoidMethodForwarding()
76 @Override public Runnable apply(final Runnable runnable) { in testToStringForwarding()
77 return new ForwardingRunnable(runnable) { in testToStringForwarding()
79 return runnable.toString(); in testToStringForwarding()
88 @Override public Runnable apply(final Runnable runnable) { in testFailsToForwardToString()
89 return new ForwardingRunnable(runnable) { in testFailsToForwardToString()
101 @Override public Runnable apply(final Runnable runnable) { in testFailsToForwardHashCode()
102 return new ForwardingRunnable(runnable) { in testFailsToForwardHashCode()
106 return runnable.equals(that.runnable); in testFailsToForwardHashCode()
[all …]
/external/guava/guava/src/com/google/common/util/concurrent/
DExecutionList.java81 public void add(Runnable runnable, Executor executor) { in add() argument
85 Preconditions.checkNotNull(runnable, "Runnable was null."); in add()
93 runnables = new RunnableExecutorPair(runnable, executor, runnables); in add()
101 executeListener(runnable, executor); in add()
145 executeListener(reversedList.runnable, reversedList.executor); in execute()
154 private static void executeListener(Runnable runnable, Executor executor) { in executeListener() argument
156 executor.execute(runnable); in executeListener()
162 + runnable + " with executor " + executor, e); in executeListener()
167 final Runnable runnable; field in ExecutionList.RunnableExecutorPair
171 RunnableExecutorPair(Runnable runnable, Executor executor, RunnableExecutorPair next) { in RunnableExecutorPair() argument
[all …]
DListenableFutureTask.java69 Runnable runnable, @Nullable V result) { in create() argument
70 return new ListenableFutureTask<V>(runnable, result); in create()
77 ListenableFutureTask(Runnable runnable, @Nullable V result) { in ListenableFutureTask() argument
78 super(runnable, result); in ListenableFutureTask()
/external/emma/core/java13/com/vladium/util/exit/
DExitHookManager.java29 public abstract boolean addExitHook (Runnable runnable); in addExitHook() argument
30 public abstract boolean removeExitHook (Runnable runnable); in removeExitHook() argument
61 public synchronized boolean addExitHook (final Runnable runnable) in addExitHook() argument
63 if ((runnable != null) && ! m_exitThreadMap.containsKey (runnable)) in addExitHook()
65 …final Thread exitThread = new Thread (runnable, IAppConstants.APP_NAME + " shutdown handler thread… in addExitHook()
70 m_exitThreadMap.put (runnable, exitThread); // TODO: use identity here in addExitHook()
84 public synchronized boolean removeExitHook (final Runnable runnable) in removeExitHook() argument
86 if (runnable != null) in removeExitHook()
88 … final Thread exitThread = (Thread) m_exitThreadMap.get (runnable); // TODO: use identity here in removeExitHook()
95 m_exitThreadMap.remove (runnable); in removeExitHook()
/external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/android/util/concurrent/
DRoboExecutorService.java33 public AdvancingFutureTask(Scheduler scheduler, Runnable runnable, V result) { in AdvancingFutureTask() argument
34 super(runnable, result); in AdvancingFutureTask()
60 for (Runnable runnable : runnables) { in shutdownNow()
61 scheduler.remove(runnable); in shutdownNow()
62 notExecutedRunnables.add(runnable); in shutdownNow()
90 public <T> Future<T> submit(Runnable runnable, T t) { in submit() argument
91 return schedule(new AdvancingFutureTask<T>(scheduler, runnable, t)); in submit()
95 public Future<?> submit(Runnable runnable) { in submit() argument
96 return submit(runnable, null); in submit()
100 Runnable runnable = new Runnable() { in schedule() local
[all …]
/external/proguard/src/proguard/gui/
DSwingUtil.java43 public static void invokeAndWait(Runnable runnable) in invokeAndWait() argument
50 runnable.run(); in invokeAndWait()
54 SwingUtilities.invokeAndWait(runnable); in invokeAndWait()
71 public static void invokeLater(Runnable runnable) in invokeLater() argument
75 runnable.run(); in invokeLater()
79 SwingUtilities.invokeLater(runnable); in invokeLater()
/external/glide/library/src/main/java/com/bumptech/glide/load/engine/executor/
DFifoPriorityThreadPoolExecutor.java36 protected <T> RunnableFuture<T> newTaskFor(Runnable runnable, T value) { in newTaskFor() argument
37 return new LoadTask<T>(runnable, value, ordering.getAndIncrement()); in newTaskFor()
47 public Thread newThread(Runnable runnable) { in newThread() argument
48 final Thread result = new Thread(runnable, "fifo-pool-thread-" + threadNum) { in newThread()
65 public LoadTask(Runnable runnable, T result, int order) { in LoadTask() argument
66 super(runnable, result); in LoadTask()
67 if (!(runnable instanceof Prioritized)) { in LoadTask()
71 priority = ((Prioritized) runnable).getPriority(); in LoadTask()
/external/robolectric-shadows/robolectric/src/test/java/org/robolectric/android/util/concurrent/
DRoboExecutorServiceTest.java23 private Runnable runnable; field in RoboExecutorServiceTest
28 runnable = new Runnable() { in setUp()
38 executorService.execute(runnable); in execute_shouldRunStuffOnBackgroundThread()
48 Future<String> future = executorService.submit(runnable, "foo"); in submitRunnable_shouldRunStuffOnBackgroundThread()
65 runnable.run(); in submitCallable_shouldRunStuffOnBackgroundThread()
92 executorService.execute(runnable); in whenShutdownBeforeSubmittedTasksAreExecuted_TaskIsNotInTranscript()
102 executorService.execute(runnable); in whenShutdownNow_ReturnedListContainsOneRunnable()
113 Future<String> future = executorService.submit(runnable, "foo"); in whenGettingFutureValue_FutureRunnableIsExecuted()
128 executorService.execute(runnable); in whenAwaitingTermination_AllTasksAreRunByDefault()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DChannelExecutor.java57 Runnable runnable; in drain() local
66 runnable = queue.poll(); in drain()
67 if (runnable == null) { in drain()
73 runnable.run(); in drain()
85 final ChannelExecutor executeLater(Runnable runnable) { in executeLater() argument
87 queue.add(checkNotNull(runnable, "runnable is null")); in executeLater()
DDelayedStream.java140 for (Runnable runnable : toRun) { in drainPendingCalls()
143 runnable.run(); in drainPendingCalls()
159 private void delayOrExecute(Runnable runnable) { in delayOrExecute() argument
162 pendingCalls.add(runnable); in delayOrExecute()
166 runnable.run(); in delayOrExecute()
376 private void delayOrExecute(Runnable runnable) { in delayOrExecute() argument
379 pendingCallbacks.add(runnable); in delayOrExecute()
383 runnable.run(); in delayOrExecute()
463 for (Runnable runnable : toRun) { in drainPendingCallbacks()
466 runnable.run(); in drainPendingCallbacks()
DHttp2Ping.java94 Runnable runnable; in addCallback() local
101 runnable = this.failureCause != null ? asRunnable(callback, failureCause) in addCallback()
104 doExecute(executor, runnable); in addCallback()
178 private static void doExecute(Executor executor, Runnable runnable) { in doExecute() argument
180 executor.execute(runnable); in doExecute()
DApplicationThreadDeframer.java175 private final Runnable runnable; field in ApplicationThreadDeframer.InitializingMessageProducer
178 private InitializingMessageProducer(Runnable runnable) { in InitializingMessageProducer() argument
179 this.runnable = runnable; in InitializingMessageProducer()
184 runnable.run(); in initialize()
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DWriteQueue.java95 void enqueue(Runnable runnable, boolean flush) { in enqueue() argument
96 queue.add(new RunnableCommand(runnable)); in enqueue()
136 private final Runnable runnable; field in WriteQueue.RunnableCommand
138 public RunnableCommand(Runnable runnable) { in RunnableCommand() argument
139 this.runnable = runnable; in RunnableCommand()
154 runnable.run(); in run()
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DAbstractListeningExecutorServiceTest.java42 TestRunnable runnable = new TestRunnable(); in testSubmit() local
43 ListenableFuture<?> runnableFuture = e.submit(runnable); in testSubmit()
46 assertTrue(runnable.run); in testSubmit()
83 public void execute(Runnable runnable) { in execute() argument
84 assertTrue(runnable instanceof ListenableFutureTask); in execute()
85 runnable.run(); in execute()
/external/opencensus-java/api/src/main/java/io/opencensus/trace/
DCurrentSpanUtils.java63 static Runnable withSpan(Span span, boolean endSpan, Runnable runnable) { in withSpan() argument
64 return new RunnableInSpan(span, runnable, endSpan); in withSpan()
108 private final Runnable runnable; field in CurrentSpanUtils.RunnableInSpan
111 private RunnableInSpan(Span span, Runnable runnable, boolean endSpan) { in RunnableInSpan() argument
113 this.runnable = runnable; in RunnableInSpan()
122 runnable.run(); in run()
/external/libchrome/mojo/public/java/system/src/org/chromium/mojo/system/impl/
DBaseRunLoop.java46 public void postDelayedTask(Runnable runnable, long delay) { in postDelayedTask() argument
48 nativePostDelayedTask(mRunLoopID, runnable, delay); in postDelayedTask()
64 private static void runRunnable(Runnable runnable) { in runRunnable() argument
65 runnable.run(); in runRunnable()
72 private native void nativePostDelayedTask(long runLoopID, Runnable runnable, long delay); in nativePostDelayedTask() argument
/external/junit/src/main/java/org/junit/internal/runners/
DClassRoadie.java23 private final Runnable runnable; field in ClassRoadie
26 Description description, Runnable runnable) { in ClassRoadie() argument
30 this.runnable = runnable; in ClassRoadie()
34 runnable.run(); in runUnprotected()
/external/opencensus-java/api/src/test/java/io/opencensus/trace/
DCurrentSpanUtilsTest.java46 private void executeRunnableAndExpectError(Runnable runnable, Throwable error) { in executeRunnableAndExpectError() argument
49 CurrentSpanUtils.withSpan(span, true, runnable).run(); in executeRunnableAndExpectError()
116 Runnable runnable = in withSpanRunnable() local
124 CurrentSpanUtils.withSpan(span, false, runnable).run(); in withSpanRunnable()
132 Runnable runnable = in withSpanRunnable_EndSpan() local
140 CurrentSpanUtils.withSpan(span, true, runnable).run(); in withSpanRunnable_EndSpan()
149 Runnable runnable = in withSpanRunnable_WithError() local
158 executeRunnableAndExpectError(runnable, error); in withSpanRunnable_WithError()
168 Runnable runnable = in withSpanRunnable_WithErrorNoMessage() local
177 executeRunnableAndExpectError(runnable, error); in withSpanRunnable_WithErrorNoMessage()
/external/mockito/src/test/java/org/mockitoutil/
DThrowableAssert.java16 private ThrowableAssert(Runnable runnable) { in ThrowableAssert() argument
18 runnable.run(); in ThrowableAssert()
44 public static ThrowableAssert assertThat(Runnable runnable) { in assertThat() argument
45 return new ThrowableAssert(runnable); in assertThat()
/external/guice/core/src/com/google/inject/internal/
DProcessedBindingData.java38 void addUninitializedBinding(Runnable runnable) { in addUninitializedBinding() argument
39 uninitializedBindings.add(runnable); in addUninitializedBinding()
42 void addDelayedUninitializedBinding(Runnable runnable) { in addDelayedUninitializedBinding() argument
43 delayedUninitializedBindings.add(runnable); in addDelayedUninitializedBinding()
/external/autotest/client/site_tests/network_FirewallHolePunch/src/tcpserver/commands/
DBrowserCommands.js25 Commands.prototype.addCommand=function(name, help, runnable) { argument
30 this.commands[name] = {help: help, runnable: runnable}; property
54 return this.commands[name].runnable.call(context, args);
/external/v8/tools/
Drun_perf.py631 def _Run(self, runnable, count, secondary=False): argument
634 def Run(self, runnable, count): argument
645 stdout = self._Run(runnable, count, secondary=False)
647 return stdout, self._Run(runnable, count, secondary=True)
684 def _Run(self, runnable, count, secondary=False): argument
688 cmd = runnable.GetCommand(self.command_prefix, shell_dir, self.extra_flags)
700 logging.warning(">>> Test timed out after %ss.", runnable.timeout)
711 if runnable.process_size:
750 def _Run(self, runnable, count, secondary=False): argument
757 if runnable.path:
[all …]
/external/volley/src/test/java/com/android/volley/
DCacheDispatcherTest.java122 ArgumentCaptor<Runnable> runnable = ArgumentCaptor.forClass(Runnable.class); in softExpiredCacheHit() local
123 verify(mDelivery).postResponse(any(Request.class), any(Response.class), runnable.capture()); in softExpiredCacheHit()
124 runnable.getValue().run(); in softExpiredCacheHit()
194 ArgumentCaptor<Runnable> runnable = ArgumentCaptor.forClass(Runnable.class); in duplicateSoftExpiredCacheHit_failedRequest() local
195 verify(mDelivery).postResponse(any(Request.class), any(Response.class), runnable.capture()); in duplicateSoftExpiredCacheHit_failedRequest()
196 runnable.getValue().run(); in duplicateSoftExpiredCacheHit_failedRequest()
223 ArgumentCaptor<Runnable> runnable = ArgumentCaptor.forClass(Runnable.class); in duplicateSoftExpiredCacheHit_successfulRequest() local
224 verify(mDelivery).postResponse(any(Request.class), any(Response.class), runnable.capture()); in duplicateSoftExpiredCacheHit_successfulRequest()
225 runnable.getValue().run(); in duplicateSoftExpiredCacheHit_successfulRequest()

1234567