Home
last modified time | relevance | path

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

12345678910>>...21

/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.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() {
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 …]
/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/libchrome/base/
Dbind_internal.h283 template <bool IsWeakCall, typename ReturnType, typename Runnable,
287 template <typename ReturnType, typename Runnable, typename... Args>
288 struct InvokeHelper<false, ReturnType, Runnable, TypeList<Args...>> {
289 static ReturnType MakeItSo(Runnable runnable, Args... args) {
294 template <typename Runnable, typename... Args>
295 struct InvokeHelper<false, void, Runnable, TypeList<Args...>> {
296 static void MakeItSo(Runnable runnable, Args... args) {
301 template <typename Runnable, typename BoundWeakPtr, typename... Args>
302 struct InvokeHelper<true, void, Runnable, TypeList<BoundWeakPtr, Args...>> {
303 static void MakeItSo(Runnable runnable, BoundWeakPtr weak_ptr, Args... args) {
[all …]
/external/libweave/third_party/chromium/base/
Dbind_internal.h283 template <bool IsWeakCall, typename ReturnType, typename Runnable,
287 template <typename ReturnType, typename Runnable, typename... Args>
288 struct InvokeHelper<false, ReturnType, Runnable, TypeList<Args...>> {
289 static ReturnType MakeItSo(Runnable runnable, Args... args) {
294 template <typename Runnable, typename... Args>
295 struct InvokeHelper<false, void, Runnable, TypeList<Args...>> {
296 static void MakeItSo(Runnable runnable, Args... args) {
301 template <typename Runnable, typename BoundWeakPtr, typename... Args>
302 struct InvokeHelper<true, void, Runnable, TypeList<BoundWeakPtr, Args...>> {
303 static void MakeItSo(Runnable runnable, BoundWeakPtr weak_ptr, Args... args) {
[all …]
/external/opencv3/samples/gpu/performance/
Dperformance.h13 class Runnable
16 explicit Runnable(const std::string& nameStr): name_(nameStr) {} in Runnable() function
17 virtual ~Runnable() {} in ~Runnable()
45 void addInit(Runnable* init) { inits_.push_back(init); } in addInit()
46 void addTest(Runnable* test) { tests_.push_back(test); } in addTest()
123 std::vector<Runnable*> inits_;
124 std::vector<Runnable*> tests_;
147 struct name##_init: Runnable { \
148 name##_init(): Runnable(#name) { \
157 struct name##_test: Runnable { \
[all …]
/external/skia/platform_tools/android/apps/sample_app/src/main/java/com/skia/
DSkiaSampleView.java65 queueEvent(new Runnable() { in onTouchEvent()
76 queueEvent(new Runnable() { in inval()
85 queueEvent(new Runnable() { in terminate()
94 queueEvent(new Runnable() { in showOverview()
103 queueEvent(new Runnable() { in nextSample()
112 queueEvent(new Runnable() { in previousSample()
121 queueEvent(new Runnable() { in goToSample()
130 queueEvent(new Runnable() { in toggleRenderingMode()
139 queueEvent(new Runnable() { in toggleSlideshow()
148 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/
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) {
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 ArrayDeque<Runnable>();
92 public void execute(Runnable r) { in execute()
129 private class TaskRunner implements Runnable {
136 Runnable nextToRun; in run()
/external/libgdx/backends/gdx-backend-lwjgl3/src/com/badlogic/gdx/backends/lwjgl3/
DLwjgl3Window.java41 private final Array<Runnable> runnables = new Array<Runnable>();
42 private final Array<Runnable> executedRunnables = new Array<Runnable>();
50 postRunnable(new Runnable() {
68 postRunnable(new Runnable() {
92 postRunnable(new Runnable() {
109 postRunnable(new Runnable() {
156 public void postRunnable(Runnable runnable) { in postRunnable()
245 for(Runnable runnable: executedRunnables) { in update()
/external/robolectric/v1/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/guice/core/test/com/google/inject/matcher/
DMatcherTest.java94 assertTrue(subclassesOf(Runnable.class).matches(Runnable.class)); in testSubclassesOf()
95 assertTrue(subclassesOf(Runnable.class).matches(MyRunnable.class)); in testSubclassesOf()
96 assertFalse(subclassesOf(Runnable.class).matches(Object.class)); in testSubclassesOf()
97 assertEquals("subclassesOf(Runnable.class)", subclassesOf(Runnable.class).toString()); in testSubclassesOf()
98 assertEqualsBothWays(subclassesOf(Runnable.class), subclassesOf(Runnable.class)); in testSubclassesOf()
99 assertFalse(subclassesOf(Runnable.class).equals(subclassesOf(Object.class))); in testSubclassesOf()
166 static abstract class MyRunnable implements Runnable {}
/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()

12345678910>>...21