| /external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
| D | ExecutionListBenchmark.java | 53 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/v1/src/main/java/com/xtremelabs/robolectric/util/ |
| D | Scheduler.java | 30 public void postDelayed(Runnable runnable, long delayMillis) { in postDelayed() argument
32 postedRunnables.add(new PostedRunnable(runnable, currentTime + delayMillis)); in postDelayed()
35 runnable.run(); in postDelayed()
39 public void post(Runnable runnable) { in post() argument
40 postDelayed(runnable, 0); in post()
43 public void postAtFrontOfQueue(Runnable runnable) { in postAtFrontOfQueue() argument
45 postedRunnables.add(0, new PostedRunnable(runnable, currentTime)); in postAtFrontOfQueue()
47 runnable.run(); in postAtFrontOfQueue()
51 public void remove(Runnable runnable) { in remove() argument
55 if (next.runnable == runnable) { in remove()
[all …]
|
| D | RobolectricBackgroundExecutorService.java | 47 public <T> Future<T> submit(Runnable runnable, T t) { in submit() argument
48 return schedule(new FutureTask<T>(runnable, t)); in submit()
52 public Future<?> submit(Runnable runnable) { in submit() argument
53 return submit(runnable, null); in submit()
88 public void execute(Runnable runnable) { in execute() argument
89 submit(runnable); in execute()
|
| /external/emma/core/java13/com/vladium/util/exit/ |
| D | ExitHookManager.java | 29 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/guava/guava/src/com/google/common/util/concurrent/ |
| D | ExecutionList.java | 81 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 …]
|
| D | ListenableFutureTask.java | 69 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()
|
| D | AbstractScheduledService.java | 153 Runnable runnable);
289 @Override public Thread newThread(Runnable runnable) {
290 return MoreExecutors.newThread(serviceName(), runnable);
429 Runnable runnable) {
430 this.wrappedRunnable = runnable;
489 Runnable runnable) {
490 ReschedulableCallable task = new ReschedulableCallable(service, executor, runnable);
|
| /external/guava/guava-testlib/test/com/google/common/testing/anotherpackage/ |
| D | ForwardingWrapperTesterTest.java | 67 @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/proguard/src/proguard/gui/ |
| D | SwingUtil.java | 43 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/robolectric/v1/src/test/java/com/xtremelabs/robolectric/util/ |
| D | SchedulerTest.java | 110 TestRunnable runnable = new TestRunnable(); in removeShouldRemoveAllInstancesOfRunnableFromQueue() local
111 scheduler.post(runnable); in removeShouldRemoveAllInstancesOfRunnableFromQueue()
112 scheduler.post(runnable); in removeShouldRemoveAllInstancesOfRunnableFromQueue()
114 scheduler.remove(runnable); in removeShouldRemoveAllInstancesOfRunnableFromQueue()
117 assertThat(runnable.wasRun, equalTo(false)); in removeShouldRemoveAllInstancesOfRunnableFromQueue()
124 TestRunnable runnable = new TestRunnable(); in resetShouldUnPause() local
125 scheduler.post(runnable); in resetShouldUnPause()
127 assertThat(runnable.wasRun, equalTo(false)); in resetShouldUnPause()
130 scheduler.post(runnable); in resetShouldUnPause()
131 assertThat(runnable.wasRun, equalTo(true)); in resetShouldUnPause()
|
| D | RobolectricBackgroundExecutorServiceTest.java | 20 private Runnable runnable; field in RobolectricBackgroundExecutorServiceTest
28 runnable = new Runnable() { in setUp()
37 executorService.execute(runnable); in execute_shouldRunStuffOnBackgroundThread()
47 Future<String> future = executorService.submit(runnable, "foo"); in submitRunnable_shouldRunStuffOnBackgroundThread()
63 runnable.run(); in submitCallable_shouldRunStuffOnBackgroundThread()
|
| /external/glide/library/src/main/java/com/bumptech/glide/load/engine/executor/ |
| D | FifoPriorityThreadPoolExecutor.java | 36 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/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | AbstractListeningExecutorServiceTest.java | 42 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/libmojo/mojo/android/system/src/org/chromium/mojo/system/impl/ |
| D | BaseRunLoop.java | 46 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/mockito/src/test/java/org/mockitoutil/ |
| D | ThrowableAssert.java | 12 private ThrowableAssert(Runnable runnable) { in ThrowableAssert() argument
14 runnable.run(); in ThrowableAssert()
40 public static ThrowableAssert assertThat(Runnable runnable) { in assertThat() argument
41 return new ThrowableAssert(runnable); in assertThat()
|
| /external/junit/src/main/java/org/junit/internal/runners/ |
| D | ClassRoadie.java | 23 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/autotest/client/site_tests/network_FirewallHolePunch/src/tcpserver/commands/ |
| D | BrowserCommands.js | 25 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/volley/src/main/java/com/android/volley/ |
| D | ExecutorDelivery.java | 59 public void postResponse(Request<?> request, Response<?> response, Runnable runnable) { in postResponse() argument
62 mResponsePoster.execute(new ResponseDeliveryRunnable(request, response, runnable)); in postResponse()
82 public ResponseDeliveryRunnable(Request request, Response response, Runnable runnable) { in ResponseDeliveryRunnable() argument
85 mRunnable = runnable; in ResponseDeliveryRunnable()
|
| /external/robolectric/v1/src/main/java/com/xtremelabs/robolectric/shadows/ |
| D | ShadowLooper.java | 152 public boolean post(Runnable runnable, long delayMillis) {
154 scheduler.postDelayed(runnable, delayMillis);
161 public boolean postAtFrontOfQueue(Runnable runnable) {
163 scheduler.postAtFrontOfQueue(runnable);
|
| /external/v8/tools/ |
| D | run_perf.py | 623 def _Run(self, runnable, count, no_patch=False): argument
626 def Run(self, runnable, count): argument
638 stdout = self._Run(runnable, count, no_patch=False)
640 return stdout, self._Run(runnable, count, no_patch=True)
674 def _Run(self, runnable, count, no_patch=False): argument
678 command = self.command_prefix + runnable.GetCommand(shell_dir,
683 timeout=runnable.timeout,
697 print ">>> Test timed out after %ss." % runnable.timeout
813 def _Run(self, runnable, count, no_patch=False): argument
820 AndroidPlatform.DEVICE_DIR, target_dir, runnable.binary)
[all …]
|
| /external/webrtc/webrtc/examples/androidapp/src/org/appspot/apprtc/util/ |
| D | LooperExecutor.java | 83 public synchronized void execute(final Runnable runnable) { in execute() argument
89 runnable.run(); in execute()
91 handler.post(runnable); in execute()
|
| /external/vogar/test/vogar/target/junit4/ |
| D | MockitoFieldTest.java | 32 private Runnable runnable; field in MockitoFieldTest
36 assertNotNull("Runnable field was not mocked", runnable); in test()
|
| /external/webrtc/webrtc/base/ |
| D | thread.cc | 128 Runnable* runnable; member
190 bool Thread::Start(Runnable* runnable) { in Start() argument
204 init->runnable = runnable; in Start()
297 if (init->runnable) { in PreRun()
298 init->runnable->Run(init->thread); in PreRun()
|
| /external/apache-xml/src/main/java/org/apache/xml/utils/ |
| D | ThreadControllerWrapper.java | 33 public static Thread runThread(Runnable runnable, int priority) in runThread() argument
35 return m_tpool.run(runnable, priority); in runThread()
|
| /external/guice/core/src/com/google/inject/internal/ |
| D | ProcessedBindingData.java | 38 void addUninitializedBinding(Runnable runnable) { in addUninitializedBinding() argument
39 uninitializedBindings.add(runnable); in addUninitializedBinding()
|