- Sort Score
- Num 10 results
- Language All
Results 41 - 50 of 1,530 for Mall (0.02 seconds)
-
android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java
* * <p>{@code RuntimeException}s thrown by tasks are simply logged and the executor keeps trucking. * If an {@code Error} is thrown, the error will propagate and execution will stop until it is * restarted by a call to {@link #execute}. */ @J2ktIncompatible @GwtIncompatible final class SequentialExecutor implements Executor { private static final LazyLogger log = new LazyLogger(SequentialExecutor.class);Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 10.6K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/ConcurrentHashMultiset.java
existingCounter = countMap.putIfAbsent(element, new AtomicInteger(occurrences)); if (existingCounter == null) { return 0; } // existingCounter != null: fall through to operate against the existing AtomicInteger } while (true) { int oldValue = existingCounter.get(); if (oldValue != 0) { try {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Dec 26 20:08:09 GMT 2025 - 22.3K bytes - Click Count (0) -
guava/src/com/google/common/collect/ArrayListMultimap.java
* value and the old value. * * <p>Keys and values may be null. All optional multimap methods are supported, and all returned * views are modifiable. * * <p>The lists returned by {@link #get}, {@link #removeAll}, and {@link #replaceValues} all * implement {@link java.util.RandomAccess}. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Dec 05 23:15:58 GMT 2025 - 6.8K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/tls/ClientAuthTest.kt
server.requestClientAuth() server.enqueue( MockResponse .Builder() .body("abc") .build(), ) val call = client.newCall(Request.Builder().url(server.url("/")).build()) val response = call.execute() assertThat(response.handshake!!.peerPrincipal) .isEqualTo(X500Principal("CN=Local Host")) assertThat(response.handshake!!.localPrincipal)
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 13K bytes - Click Count (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
* we must return it in the following next() call even if it was in the process of being removed * when hasNext() was called. */ private @Nullable E nextItem; /** * Index of element returned by most recent call to next. Reset to -1 if this element is deleted * by a call to remove. */ private int lastRet; Itr() { lastRet = -1;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 23 21:06:42 GMT 2026 - 22.4K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/Sets.java
} } /** * Returns an unmodifiable <b>view</b> of the union of two sets. The returned set contains all * elements that are contained in either backing set. Iterating over the returned set iterates * first over all the elements of {@code set1}, then over each element of {@code set2}, in order, * that is not contained in {@code set1}. *
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 19:19:10 GMT 2026 - 81.4K bytes - Click Count (0) -
android/guava/src/com/google/common/io/CharSource.java
* entire stream. To avoid a potentially expensive operation, see {@link #lengthIfKnown}. * * <p>The default implementation calls {@link #lengthIfKnown} and returns the value if present. If * absent, it will fall back to a heavyweight operation that will open a stream, {@link * Reader#skip(long) skip} to the end of the stream, and return the total number of chars that * were skipped. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 19:19:10 GMT 2026 - 25.7K bytes - Click Count (0) -
android/guava/src/com/google/common/hash/LittleEndianByteArray.java
| ((source[offset + 3] & 0xFF) << 24); } /** * Indicates that the load and store operations will be very efficient because of use of VarHandle * or Unsafe. May be useful for calling code to fall back on an alternative implementation that is * slower than those implementations but faster than the pure-Java mask-and-shift. */ static boolean usingFastPath() { return byteArray.usesFastPath(); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Apr 01 17:27:13 GMT 2026 - 10.1K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/TimeLimiter.java
/** * Returns an instance of {@code interfaceType} that delegates all method calls to the {@code * target} object, enforcing the specified time limit on each call. This time-limited delegation * is also performed for calls to {@link Object#equals}, {@link Object#hashCode}, and {@link * Object#toString}. * * <p>If the target method call finishes before the limit is reached, the return value orCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Jan 18 02:54:30 GMT 2025 - 8.2K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
* {@link MoreExecutors#directExecutor}. Normally, when the first future completes, all the other * tasks would be called recursively. Here, we detect that the delegate executor is executing * inline, and maintain a queue to dispatch tasks iteratively. There is one instance of this class * per call to submit() or submitAsync(), and each instance supports only one call to execute(). *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Sep 23 01:35:55 GMT 2025 - 22.1K bytes - Click Count (0)