- Sort Score
- Result 10 results
- Languages All
Results 51 - 57 of 57 for Moll (8.01 sec)
-
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
Object nextLabel; synchronized (PerListenerQueue.this) { Preconditions.checkState(isThreadScheduled); nextToRun = waitQueue.poll(); nextLabel = labelQueue.poll(); if (nextToRun == null) { isThreadScheduled = false; stillRunning = false; break; } }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 8.2K bytes - Viewed (0) -
android/guava/src/com/google/common/io/LineReader.java
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed May 17 14:35:11 GMT 2023 - 3.1K bytes - Viewed (0) -
guava/src/com/google/common/base/FinalizableReferenceQueue.java
loadFinalizer(new SystemLoader(), new DecoupledLoader(), new DirectLoader()); startFinalizer = getStartFinalizer(finalizer); } /** The actual reference queue that our background thread will poll. */ final ReferenceQueue<Object> queue; final PhantomReference<Object> frqRef; /** Whether or not the background thread started successfully. */ final boolean threadStarted;
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Wed Apr 26 20:07:17 GMT 2023 - 13.1K bytes - Viewed (0) -
android/guava/src/com/google/common/base/FinalizableReferenceQueue.java
loadFinalizer(new SystemLoader(), new DecoupledLoader(), new DirectLoader()); startFinalizer = getStartFinalizer(finalizer); } /** The actual reference queue that our background thread will poll. */ final ReferenceQueue<Object> queue; final PhantomReference<Object> frqRef; /** Whether or not the background thread started successfully. */ final boolean threadStarted;
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Apr 26 20:07:17 GMT 2023 - 13.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/EvictingQueueTest.java
assertEquals(0, queue.size()); try { queue.element(); fail(); } catch (NoSuchElementException expected) { } assertNull(queue.peek()); assertNull(queue.poll()); try { queue.remove(); fail(); } catch (NoSuchElementException expected) { } } public void testRemainingCapacity_maxSize0() {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Feb 19 20:34:55 GMT 2024 - 6.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java
*/ protected void startUp() throws Exception {} /** * Run the service. This method is invoked on the execution thread. Implementations must respond * to stop requests. You could poll for lifecycle changes in a work loop: * * <pre> * public void run() { * while ({@link #isRunning()}) { * // perform a unit of work * } * } * </pre> *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 7.6K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java
public void execute() { synchronized (runnables) { if (executed) { return; } executed = true; } while (!runnables.isEmpty()) { runnables.poll().execute(); } } private static class RunnableExecutorPair { final Runnable runnable; final Executor executor; RunnableExecutorPair(Runnable runnable, Executor executor) {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Apr 17 15:19:38 GMT 2023 - 20.4K bytes - Viewed (0)