- Sort Score
- Num 10 results
- Language All
Results 221 - 230 of 344 for consumer (0.06 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
guava/src/com/google/common/util/concurrent/FuturesGetChecked.java
List<Constructor<X>> constructors) { return WITH_STRING_PARAM_THEN_WITH_THROWABLE_PARAM.sortedCopy(constructors); } // TODO: b/296487962 - Consider defining a total order over constructors. private static final Ordering<List<Class<?>>> ORDERING_BY_CONSTRUCTOR_PARAMETER_LIST = Ordering.natural()
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sat Aug 09 01:14:59 GMT 2025 - 11.8K bytes - Click Count (0) -
android/guava/src/com/google/common/io/Files.java
if (parent == null) { /* * The given directory is a filesystem root. All zero of its ancestors exist. This doesn't * mean that the root itself exists -- consider x:\ on a Windows machine without such a drive * -- or even that the caller can create it, but this method makes no such guarantees even for * non-root files. */ return; }
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Sep 25 20:24:13 GMT 2025 - 32.8K bytes - Click Count (0) -
android/guava/src/com/google/common/base/internal/Finalizer.java
import org.jspecify.annotations.Nullable; /** * Thread that finalizes referents. All references should implement {@code * com.google.common.base.FinalizableReference}. * * <p>While this class is public, we consider it to be *internal* and not part of our published API. * It is public so we can access it reflectively across class loaders in secure environments. *Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 9.3K bytes - Click Count (0) -
src/bytes/buffer.go
} // ReadRune reads and returns the next UTF-8-encoded // Unicode code point from the buffer. // If no bytes are available, the error returned is io.EOF. // If the bytes are an erroneous UTF-8 encoding, it // consumes one byte and returns U+FFFD, 1. func (b *Buffer) ReadRune() (r rune, size int, err error) { if b.empty() { // Buffer is empty, reset to recover space. b.Reset() return 0, 0, io.EOF } c := b.buf[b.off]
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Fri Nov 14 19:01:17 GMT 2025 - 16.5K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java
result.timer = scheduledExecutor.schedule(fire, time, unit); delegate.addListener(fire, directExecutor()); return result; } /* * Memory visibility of these fields. There are two cases to consider. * * 1. visibility of the writes to these fields to Fire.run: * * The initial write to delegateRef is made definitely visible via the semantics of
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 8K bytes - Click Count (0) -
android/guava/src/com/google/common/primitives/Ints.java
* such index exists. */ public static int indexOf(int[] array, int target) { return indexOf(array, target, 0, array.length); } // TODO(kevinb): consider making this public private static int indexOf(int[] array, int target, int start, int end) { for (int i = start; i < end; i++) { if (array[i] == target) { return i; } }
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed Oct 22 18:14:49 GMT 2025 - 31.3K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
} } } } @SuppressWarnings({ "Interruption", // We are restoring an interrupt on this thread. "ThreadPriorityCheck", // TODO: b/175898629 - Consider onSpinWait. }) private void waitForInterrupt(Thread currentThread) { /* * If someone called cancel(true), it is possible that the interrupted bit hasn't been set yet.Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 10K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ThreadFactoryBuilder.java
* * <p>If no backing thread factory is provided, a default backing thread factory is used as if by * calling {@code setThreadFactory(}{@link Executors#defaultThreadFactory()}{@code )}. * * <p><b>Java 21+ users:</b> consider using the {@code Thread.Builder} interface instead. E.g., * instead of {@code new ThreadFactoryBuilder().setPriority(priority).setDaemon(false).build()}, use * {@code Thread.ofPlatform().priority(priority).daemon(false).factory()}.Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sat Aug 09 01:35:26 GMT 2025 - 9K bytes - Click Count (0) -
guava-testlib/src/com/google/common/collect/testing/google/AbstractMultisetSetCountTester.java
@SuppressWarnings("JUnit4ClassUsedInJUnit3") public abstract class AbstractMultisetSetCountTester<E> extends AbstractMultisetTester<E> { /* * TODO: consider adding MultisetFeatures.SUPPORTS_SET_COUNT. Currently we * assume that using setCount() to increase the count is permitted iff add() * is permitted and similarly for decrease/remove(). We assume that aCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 13K bytes - Click Count (0) -
compat/maven-artifact/src/main/java/org/apache/maven/artifact/DefaultArtifact.java
} else { result = -1; } } if (result == 0) { // We don't consider the version range in the comparison, just the resolved version result = new DefaultArtifactVersion(version) .compareTo(new DefaultArtifactVersion(a.getVersion()));Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Wed Jul 23 17:27:08 GMT 2025 - 14.6K bytes - Click Count (0)