- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,045 for while (0.16 sec)
-
guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java
// try to swap null into head. } while (!UNSAFE.compareAndSwapObject(this, HEAD_OFFSET, stack, null)); RunnableExecutorPair reversedStack = null; while (stack != NULL_PAIR) { RunnableExecutorPair head = stack; stack = stack.next; head.next = reversedStack; reversedStack = head; } stack = reversedStack; while (stack != null) { stack.execute();
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) -
guava-testlib/src/com/google/common/testing/GcFinalization.java
return; } catch (InterruptedException ie) { throw new RuntimeException("Unexpected interrupt while waiting for future", ie); } catch (TimeoutException tryHarder) { /* OK */ } } while (System.nanoTime() - deadline < 0); throw formatRuntimeException("Future not done within %d second timeout", timeoutSeconds); } /**
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 11.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AtomicLongMap.java
public long addAndGet(K key, long delta) { outer: while (true) { AtomicLong atomic = map.get(key); if (atomic == null) { atomic = map.putIfAbsent(key, new AtomicLong(delta)); if (atomic == null) { return delta; } // atomic is now non-null; fall through } while (true) { long oldValue = atomic.get();
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 14.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java
@J2ktIncompatible @GwtIncompatible // concurrency public static void awaitUninterruptibly(CountDownLatch latch) { boolean interrupted = false; try { while (true) { try { latch.await(); return; } catch (InterruptedException e) { interrupted = true; } } } finally { if (interrupted) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 14.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
* <li>It is easy for the user to ensure that listeners are never invoked while holding locks. * </ul> * * The last point is subtle. Often the observable object will be managing its own internal state * using a lock, however it is dangerous to dispatch listeners while holding a lock because they * might run on the {@code directExecutor()} or be otherwise re-entrant (call back into your
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) -
guava/src/com/google/common/cache/LoadingCache.java
* {@code key} while the new value was loading then a removal notification will be sent for the * new value. * * <p>If the cache loader associated with this cache is known not to throw checked exceptions, * then prefer {@link #getUnchecked} over this method. * * @throws ExecutionException if a checked exception was thrown while loading the value. ({@code
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Sat Aug 06 17:12:03 GMT 2022 - 8.3K bytes - Viewed (0) -
android/guava/src/com/google/common/io/CharSink.java
* writer each time it is called. * * <p>The caller is responsible for ensuring that the returned writer is closed. * * @throws IOException if an I/O error occurs while opening the writer */ public abstract Writer openStream() throws IOException; /** * Opens a new buffered {@link Writer} for writing to this sink. The returned stream is not
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 28 20:13:02 GMT 2023 - 6.1K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/Dispatcher.java
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Dec 15 19:31:54 GMT 2023 - 7.3K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/LoadingCache.java
* {@code key} while the new value was loading then a removal notification will be sent for the * new value. * * <p>If the cache loader associated with this cache is known not to throw checked exceptions, * then prefer {@link #getUnchecked} over this method. * * @throws ExecutionException if a checked exception was thrown while loading the value. ({@code
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Sat Aug 06 17:12:03 GMT 2022 - 8.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-HostnamesCommon.kt
var b = addressOffset var i = pos while (i < limit) { if (b == address.size) return false // Too many groups. // Read a delimiter. if (b != addressOffset) { if (input[i] != '.') return false // Wrong delimiter. i++ } // Read 1 or more decimal digits for a value in 0..255. var value = 0 val groupOffset = i while (i < limit) { val c = input[i]
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.2K bytes - Viewed (0)