- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 1,065 for We (0.2 sec)
-
android/guava/src/com/google/common/io/ReaderInputStream.java
* draining it is flipped (undrained bytes between position and limit). */ private ByteBuffer byteBuffer; /** Whether we've finished reading the reader. */ private boolean endOfInput; /** Whether we're copying encoded bytes to the caller's buffer. */ private boolean draining; /** Whether we've successfully flushed the encoder. */ private boolean doneFlushing; /**
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 28 20:13:02 GMT 2023 - 9.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java
*/ // seenExceptionsLocal = newConcurrentHashSet(); /* * Other handleException() callers may see this as soon as we publish it. We need to populate * it with the initial failure before we do, or else they may think that the initial failure * has never been seen before. */ addInitialException(seenExceptionsLocal);
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Dec 14 20:35:03 GMT 2023 - 8.5K bytes - Viewed (0) -
maven-compat/src/main/java/org/apache/maven/repository/legacy/DefaultWagonManager.java
} catch (ChecksumFailedException e) { // if we catch a ChecksumFailedException, it means the transfer/read succeeded, but the // checksum doesn't match. This could be a problem with the server (ibiblio HTTP-200 error // page), so we'll try this up to two times. On the second try, we'll handle it as a bona-fide
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Thu Sep 14 11:48:15 GMT 2023 - 29.9K bytes - Viewed (0) -
android/guava/src/com/google/common/base/Platform.java
WeakReference<? extends Enum<?>> ref = Enums.getEnumConstants(enumClass).get(value); /* * We use `fromNullable` instead of `of` because `WeakReference.get()` has a nullable return * type. * * In practice, we are very unlikely to see `null`: The `WeakReference` to the enum constant
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 15 22:32:14 GMT 2024 - 3.8K bytes - Viewed (0) -
futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java
* nullness annotations in particular will outweigh the costs. (And it's worth noting that we have * released multiple ListenableFuture.class files that are not byte-for-byte compatible even from * the beginning, thanks to using different `-source -target` values for compiling our `-jre` and * `-android` "flavors.") *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Jun 26 21:13:41 GMT 2023 - 8K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/WriteReplaceOverridesTest.java
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Nov 30 21:54:06 GMT 2023 - 4.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/WriteReplaceOverridesTest.java
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Nov 30 21:54:06 GMT 2023 - 4.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Striped.java
// objects indefinitely. private void drainQueue() { Reference<? extends L> ref; while ((ref = queue.poll()) != null) { // We only ever register ArrayReferences with the queue so this is always safe. ArrayReference<? extends L> arrayRef = (ArrayReference<? extends L>) ref;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 10 20:55:18 GMT 2023 - 20.3K bytes - Viewed (1) -
guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
thread.joinSuccessfully(LONG_DELAY_MS); assertInterrupted(); } public void testJoinTimeoutMultiInterruptExpired() { /* * We don't "need" to schedule a thread completion at all here, but by doing * so, we come the closest we can to testing that the wait time is * appropriately decreased on each progressive join() call. */ TimedThread thread = TimedThread.createWithDelay(LONG_DELAY_MS);
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 31.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java
/* * Here's the order of events that we want. * * 1. The client thread begins to block on a get() call to a future. * 2. The client thread is interrupted sometime before the result would be * available. * 3. We expect the client's get() to throw an InterruptedException. * 4. We expect the client thread's interrupt state to be false.
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 9.1K bytes - Viewed (0)