- Sort Score
- Result 10 results
- Languages All
Results 411 - 420 of 507 for timers (0.04 sec)
-
guava/src/com/google/common/collect/Multimaps.java
* {@code Set}. * * <p>The function is applied lazily, invoked when needed. This is necessary for the returned * multimap to be a view, but it means that the function will be applied many times for bulk * operations like {@link Multimap#containsValue} and {@code Multimap.toString()}. For this to * perform well, {@code function} should be fast. To avoid lazy evaluation when the returnedRegistered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 86.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/hash/HashTestUtils.java
int same = 0x0; // bitset for output bits with same values int diff = 0x0; // bitset for output bits with different values int count = 0; // originally was 2 * Math.log(...), making it try more times to avoid flakiness issues int maxCount = (int) (4 * Math.log(2 * keyBits * hashBits) + 1); while (same != 0xffffffff || diff != 0xffffffff) { int key1 = rand.nextInt(); // flip input bit for key2Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 25.6K bytes - Viewed (0) -
cmd/erasure-server-pool.go
defer timer.Stop() for { select { case <-ctx.Done(): return case <-timer.C: z.mpCache.Range(func(id string, info MultipartInfo) bool { if time.Since(info.Initiated) >= globalAPIConfig.getStaleUploadsExpiry() { z.mpCache.Delete(id) // No need to notify to peers, each node will delete its own cache. } return true }) // Reset for the next interval
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 89.1K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableListMultimap.java
* .putAll("several", 1, 2, 3) * .putAll("many", 1, 2, 3, 4, 5) * .build(); * } * * <p>Builder instances can be reused; it is safe to call {@link #build} multiple times to build * multiple multimaps in series. Each multimap contains the key-value mappings in the previously * created multimaps. * * @since 2.0 */
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 19K bytes - Viewed (0) -
guava/src/com/google/common/collect/Multimap.java
* So, using the multimap shown above as an example, the {@link #size} is {@code 3}, not {@code 2}, * and the {@link #values} collection is {@code [1, 2, 3]}, not {@code [[1, 2], [3]]}. For those * times when the first style is more useful, use the multimap's {@link #asMap} view (or create a * {@code Map<K, Collection<V>>} in the first place). * * <h3>Example</h3> * * <p>The following code: * * {@snippet :Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 15.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
* * <p>The delegate future is interrupted and cancelled if it times out. * * @param delegate The future to delegate to. * @param time when to time out the future * @param unit the time unit of the time parameter * @param scheduledExecutor The executor service to enforce the timeout. * @since 19.0 */ @J2ktIncompatible
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 64.3K bytes - Viewed (0) -
src/test/java/jcifs/internal/dfs/DfsReferralDataImplTest.java
assertEquals("share$", result.getShare()); assertEquals("path", result.getPath()); } @Test @DisplayName("Should handle negative expiration times") void testNegativeExpiration() { when(mockReferral.getTtl()).thenReturn(300); when(mockReferral.getRFlags()).thenReturn(0);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 30.6K bytes - Viewed (0) -
guava/src/com/google/common/collect/Iterables.java
* should use an explicit {@code break} or be certain that you will eventually remove all the * elements. * * <p>To cycle over the iterable {@code n} times, use the following: {@code * Iterables.concat(Collections.nCopies(n, iterable))} * * <p><b>Java 8+ users:</b> The {@code Stream} equivalent of this method is {@codeRegistered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 43.3K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractFutureState.java
// so that it looks like we timed out even though we didn't. For comparison FutureTask respects // completion preferably and AQS is non-deterministic (depends on where in the queue the waiter // is). If we wanted to be strict about it, we could store the unpark() time in the Waiter node // and we could use that to make a decision about whether or not we timed out prior to being // unparked.
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 34.8K bytes - Viewed (0) -
cmd/metacache-entries_test.go
func Test_metaCacheEntries_resolve(t *testing.T) { baseTime, err := time.Parse("2006/01/02", "2015/02/25") if err != nil { t.Fatal(err) } inputs := []xlMetaV2{ 0: { versions: []xlMetaV2ShallowVersion{ {header: xlMetaV2VersionHeader{ VersionID: [16]byte{1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1}, ModTime: baseTime.Add(30 * time.Minute).UnixNano(), Signature: [4]byte{1, 1, 1, 1},
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 31.6K bytes - Viewed (0)