Home
last modified time | relevance | path

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

12345678910>>...17

/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/guava/guava-tests/test/com/google/common/util/concurrent/
DSerializingExecutorTest.java42 Queue<Runnable> tasks = Lists.newLinkedList();
43 @Override public void execute(Runnable command) { in execute()
76 Runnable intCounter = new Runnable() { in testBasics()
105 class FakeOp implements Runnable { in testOrdering()
130 Runnable runMe = new Runnable() { in testExceptions()
150 @Override public void execute(Runnable r) { in testDelegateRejection()
157 Runnable task = new Runnable() { in testDelegateRejection()
180 Runnable errorTask = new Runnable() { in testTaskThrowsError()
186 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.java58 list.add(new Runnable() { in testExecute_idempotent()
72 list.add(new Runnable() { in testExecute_idempotentConcurrently()
83 Runnable execute = new Runnable() { in testExecute_idempotentConcurrently()
114 new Runnable() { in testOrdering()
125 private class MockRunnable implements Runnable {
147 private static final Runnable THROWING_RUNNABLE = new Runnable() {
DWrappingExecutorServiceTest.java43 private static final Runnable DO_NOTHING = new Runnable() {
61 List<Runnable> list = testExecutor.shutdownNow(); in testDelegations()
166 private static final class WrappedRunnable implements Runnable {
167 private final Runnable delegate;
169 public WrappedRunnable(Runnable delegate) { in WrappedRunnable()
189 @Override protected Runnable wrapTask(Runnable command) { in wrapTask()
269 public List<Runnable> shutdownNow() { in shutdownNow()
282 public Future<?> submit(Runnable task) { in submit()
289 public <T> Future<T> submit(Runnable task, T result) { in submit()
296 public void execute(Runnable command) { in execute()
DJSR166TestCase.java630 public void runWithPermissions(Runnable r, Permission... permissions) { in runWithPermissions()
660 public void runWithoutPermissions(Runnable r) { in runWithoutPermissions()
764 Thread newStartedThread(Runnable runnable) { in newStartedThread()
800 public abstract class CheckedRunnable implements Runnable {
812 public abstract class RunnableShouldThrow implements Runnable {
852 public abstract class CheckedInterruptedRunnable implements Runnable {
898 public static class NoOpRunnable implements Runnable {
922 public Runnable awaiter(final CountDownLatch latch) {
1017 public Runnable possiblyInterruptedRunnable(final long timeoutMillis) {
1046 public Thread newThread(Runnable r) {
[all …]
DMoreExecutorsTest.java84 private static final Runnable EMPTY_RUNNABLE = new Runnable() {
100 final Runnable incrementTask = in testSameThreadExecutorServiceInThreadExecution()
101 new Runnable() { in testSameThreadExecutorServiceInThreadExecution()
109 new Runnable() { in testSameThreadExecutorServiceInThreadExecution()
172 final Runnable doNothingRunnable = new Runnable() { in testSameThreadExecutorServiceTermination()
176 Thread otherThread = new Thread(new Runnable() { in testSameThreadExecutorServiceTermination()
292 Runnable task = new Runnable() { in testListeningDecorator_noWrapExecuteTask()
304 protected void afterExecute(Runnable r, Throwable t) { in testListeningDecorator_scheduleSuccess()
360 Runnable runnable = new Runnable() { in testListeningDecorator_cancelled()
387 private static final class ThrowingRunnable implements Runnable {
[all …]
/external/guava/guava-tests/benchmark/com/google/common/util/concurrent/
DExecutionListBenchmark.java55 void add(Runnable runnable, Executor executor); in add()
66 @Override public void add(Runnable runnable, Executor executor) { in newExecutionList()
84 @Override public void add(Runnable runnable, Executor executor) { in newExecutionList()
102 @Override public void add(Runnable runnable, Executor executor) { in newExecutionList()
120 @Override public void add(Runnable runnable, Executor executor) {
138 @Override public void add(Runnable runnable, Executor executor) {
162 private final Runnable listener = new Runnable() {
173 new ArrayBlockingQueue<Runnable>(1000));
177 executorService.submit(new Runnable() {
188 @Footprint(exclude = {Runnable.class, Executor.class})
[all …]
/external/skia/platform_tools/android/app/src/com/skia/
DSkiaSampleView.java64 queueEvent(new Runnable() { in onTouchEvent()
75 queueEvent(new Runnable() { in inval()
84 queueEvent(new Runnable() { in terminate()
93 queueEvent(new Runnable() { in showOverview()
102 queueEvent(new Runnable() { in nextSample()
111 queueEvent(new Runnable() { in previousSample()
120 queueEvent(new Runnable() { in goToSample()
129 queueEvent(new Runnable() { in toggleRenderingMode()
138 queueEvent(new Runnable() { in toggleSlideshow()
147 queueEvent(new Runnable() { in toggleFPS()
[all …]
/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/jetty/src/java/org/eclipse/jetty/util/thread/
DQueuedThreadPool.java53 private BlockingQueue<Runnable> _jobs;
84 public QueuedThreadPool(BlockingQueue<Runnable> jobQ) in QueuedThreadPool()
101 _jobs=_maxQueued>0 ?new ArrayBlockingQueue<Runnable>(_maxQueued) in doStart()
102 :new BlockingArrayQueue<Runnable>(_minThreads,_minThreads); in doStart()
126 Runnable noop = new Runnable(){public void run(){}}; in doStop()
353 public boolean dispatch(Runnable job) in dispatch()
376 public void execute(Runnable job) in execute()
453 protected Thread newThread(Runnable runnable) in newThread()
524 private Runnable idleJobPoll() throws InterruptedException in idleJobPoll()
530 private Runnable _runnable = new Runnable()
[all …]
DExecutorThreadPool.java62 … this(new ThreadPoolExecutor(256, 256, 60, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>())); in ExecutorThreadPool()
74 …< 0 ? new ThreadPoolExecutor(256, 256, 60, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>()) : in ExecutorThreadPool()
75 …ze == 0 ? new ThreadPoolExecutor(32, 256, 60, TimeUnit.SECONDS, new SynchronousQueue<Runnable>()) : in ExecutorThreadPool()
76 …ew ThreadPoolExecutor(32, 256, 60, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(queueSize))); in ExecutorThreadPool()
103 … this(corePoolSize, maximumPoolSize, keepAliveTime, unit, new LinkedBlockingQueue<Runnable>());
116 …oolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue)
122 public boolean dispatch(Runnable job)
/external/guava/guava/src/com/google/common/util/concurrent/
DAbstractScheduledService.java124 Runnable task) { in newFixedDelaySchedule()
143 Runnable task) { in newFixedRateSchedule()
151 Runnable runnable);
168 private final Runnable task = new Runnable() {
194 executorService.execute(new Runnable() {
213 executorService.execute(new Runnable() {
287 @Override public Thread newThread(Runnable runnable) {
429 private final Runnable wrappedRunnable;
452 Runnable runnable) {
512 Runnable runnable) {
DMoreExecutors.java195 addShutdownHook(MoreExecutors.newThread("DelayedShutdownHook-for-" + service, new Runnable() { in addDelayedShutdownHook()
294 public void execute(Runnable command) { in execute()
325 public List<Runnable> shutdownNow() { in shutdownNow()
478 public List<Runnable> shutdownNow() { in shutdownNow()
483 public void execute(Runnable command) { in execute()
500 Runnable command, long delay, TimeUnit unit) { in schedule()
517 Runnable command, long initialDelay, long period, TimeUnit unit) { in scheduleAtFixedRate()
527 Runnable command, long initialDelay, long delay, TimeUnit unit) { in scheduleWithFixedDelay()
573 implements Runnable {
574 private final Runnable delegate;
[all …]
DWrappingExecutorService.java64 protected Runnable wrapTask(Runnable command) { in wrapTask()
67 return new Runnable() { in wrapTask()
94 public final void execute(Runnable command) {
104 public final Future<?> submit(Runnable task) {
109 public final <T> Future<T> submit(Runnable task, T result) {
147 public final List<Runnable> shutdownNow() {
DSerializingExecutor.java55 private final Queue<Runnable> waitQueue = new LinkedList<Runnable>();
92 public void execute(Runnable r) { in execute()
129 private class TaskRunner implements Runnable {
136 Runnable nextToRun; in run()
/external/robolectric/src/main/java/com/xtremelabs/robolectric/util/
DScheduler.java30 public void postDelayed(Runnable runnable, long delayMillis) { in postDelayed()
39 public void post(Runnable runnable) { in post()
43 public void postAtFrontOfQueue(Runnable runnable) { in postAtFrontOfQueue()
51 public void remove(Runnable runnable) { in remove()
140 Runnable runnable;
143 PostedRunnable(Runnable runnable, long scheduledTime) { in PostedRunnable()
DRobolectricBackgroundExecutorService.java22 public List<Runnable> shutdownNow() { in shutdownNow()
47 public <T> Future<T> submit(Runnable runnable, T t) { in submit()
52 public Future<?> submit(Runnable runnable) { in submit()
57 Robolectric.getShadowApplication().getBackgroundScheduler().post(new Runnable() { in schedule()
88 public void execute(Runnable runnable) { in execute()
/external/apache-xml/src/main/java/org/apache/xml/utils/
DThreadControllerWrapper.java33 public static Thread runThread(Runnable runnable, int priority) in runThread()
38 public static void waitThread(Thread worker, Runnable task) in waitThread()
66 public Thread run(Runnable task, int priority) in run()
87 public void waitThread(Thread worker, Runnable task) in waitThread()
/external/guava/guava-testlib/src/com/google/common/collect/testing/
DAbstractTester.java39 private Runnable setUp;
40 private Runnable tearDown;
58 G subjectGenerator, String suiteName, Runnable setUp, Runnable tearDown) { in init()
/external/guava/guava-tests/test/com/google/common/eventbus/
DAsyncEventBusTest.java56 List<Runnable> tasks = executor.getTasks(); in testBasicDistribution()
73 List<Runnable> tasks = Lists.newArrayList();
76 public void execute(Runnable task) { in execute()
80 public List<Runnable> getTasks() { in getTasks()
/external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/
DSameThreadScheduledExecutorService.java59 public List<Runnable> shutdownNow() { in shutdownNow()
87 public <T> ListenableFuture<T> submit(Runnable task, T result) { in submit()
94 public ListenableFuture<?> submit(Runnable task) { in submit()
132 public void execute(Runnable command) { in execute()
138 public ListenableScheduledFuture<?> schedule(Runnable command, long delay, in schedule()
185 public ListenableScheduledFuture<?> scheduleAtFixedRate(Runnable command, in scheduleAtFixedRate()
192 public ListenableScheduledFuture<?> scheduleWithFixedDelay(Runnable command, in scheduleWithFixedDelay()
DTestingExecutors.java111 @Override public List<Runnable> shutdownNow() { in shutdownNow()
128 @Override public void execute(Runnable runnable) {} in execute()
136 Runnable command, long delay, TimeUnit unit) { in schedule()
141 Runnable command, long initialDelay, long period, TimeUnit unit) { in scheduleAtFixedRate()
146 Runnable command, long initialDelay, long delay, TimeUnit unit) { in scheduleWithFixedDelay()
/external/guava/guava-testlib/test/com/google/common/collect/testing/
DFeatureSpecificTestSuiteBuilderTest.java58 Runnable setUpRunnable = new Runnable() { in testLifecycle()
66 Runnable tearDownRunnable = new Runnable() { in testLifecycle()
/external/emma/core/java13/com/vladium/util/exit/
DExitHookManager.java29 public abstract boolean addExitHook (Runnable runnable); in addExitHook()
30 public abstract boolean removeExitHook (Runnable runnable); in removeExitHook()
61 public synchronized boolean addExitHook (final Runnable runnable) in addExitHook()
84 public synchronized boolean removeExitHook (final Runnable runnable) in removeExitHook()

12345678910>>...17