Searched refs:runnables (Results 1 – 9 of 9) sorted by relevance
| /external/robolectric-shadows/utils/src/main/java/org/robolectric/util/ |
| D | Scheduler.java | 62 private final PriorityQueue<ScheduledRunnable> runnables = new PriorityQueue<>(); field in Scheduler
160 runnables.add(new ScheduledRunnable(runnable, currentTime + delayMillis)); in postDelayed()
174 if (runnables.isEmpty()) { in postAtFrontOfQueue()
177 timeDisambiguator = runnables.peek().timeDisambiguator - 1; in postAtFrontOfQueue()
179 runnables.add(new ScheduledRunnable(runnable, 0, timeDisambiguator)); in postAtFrontOfQueue()
191 Iterator<ScheduledRunnable> iterator = runnables.iterator(); in remove()
207 for (ScheduledRunnable scheduled : runnables) { in advanceToLastPostedRunnable()
221 return !runnables.isEmpty() && advanceTo(runnables.peek().scheduledTime); in advanceToNextPostedRunnable()
253 if (endTime < currentTime || runnables.isEmpty()) { in advanceTo()
273 ScheduledRunnable postedRunnable = runnables.poll(); in runOneTask()
[all …]
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | ExecutionList.java | 56 private RunnableExecutorPair runnables; field in ExecutionList
93 runnables = new RunnableExecutorPair(runnable, executor, runnables); in add()
125 list = runnables; in execute()
126 runnables = null; // allow GC to free listeners even if this stays around for a while. in execute()
|
| /external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/android/util/concurrent/ |
| D | RoboExecutorService.java | 23 private final HashSet<Runnable> runnables = new HashSet<>(); field in RoboExecutorService
60 for (Runnable runnable : runnables) { in shutdownNow()
64 runnables.clear(); in shutdownNow()
104 runnables.remove(this); in schedule()
107 runnables.add(runnable); in schedule()
|
| /external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
| D | ExecutionListBenchmark.java | 278 final Queue<OldExecutionList.RunnableExecutorPair> runnables = Lists.newLinkedList();
287 synchronized (runnables) {
289 runnables.add(new RunnableExecutorPair(runnable, executor));
301 synchronized (runnables) {
308 while (!runnables.isEmpty()) {
309 runnables.poll().execute();
338 private RunnableExecutorPair runnables;
348 runnables = new RunnableExecutorPair(runnable, executor, runnables);
362 list = runnables;
363 runnables = null; // allow GC to free listeners even if this stays around for a while.
|
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| D | AsyncFrameWriterTest.java | 101 private final Queue<Runnable> runnables = new ConcurrentLinkedQueue<Runnable>(); field in AsyncFrameWriterTest.QueueingExecutor
105 runnables.add(command); in execute()
110 while ((r = runnables.poll()) != null) { in runAll()
|
| /external/mockito/src/test/java/org/mockitoutil/ |
| D | ConcurrentTesting.java | 28 public static void concurrently(Runnable ... runnables) throws InterruptedException { in concurrently() argument
30 for (Runnable r : runnables) { in concurrently()
|
| /external/testng/src/main/java/org/testng/internal/thread/graph/ |
| D | GraphThreadPoolExecutor.java | 62 List<IWorker<T>> runnables = m_factory.createWorkers(freeNodes); in runNodes() local
63 for (IWorker<T> r : runnables) { in runNodes()
|
| /external/grpc-grpc-java/context/src/test/java/io/grpc/ |
| D | ContextTest.java | 534 assertEquals(1, queuedExecutor.runnables.size()); in currentContextExecutor()
535 queuedExecutor.runnables.remove().run(); in currentContextExecutor()
544 assertEquals(1, queuedExecutor.runnables.size()); in fixedContextExecutor()
545 queuedExecutor.runnables.remove().run(); in fixedContextExecutor()
712 private final Queue<Runnable> runnables = new ArrayDeque<Runnable>(); field in ContextTest.QueuedExecutor
716 runnables.add(r); in execute()
|
| /external/testng/src/main/java/org/testng/ |
| D | TestRunner.java | 780 List<IWorker<ITestNGMethod>> runnables = createWorkers(freeNodes); in privateRun() local
781 for (IWorker<ITestNGMethod> r : runnables) { in privateRun()
|