- Sort Score
- Num 10 results
- Language All
Results 211 - 220 of 688 for sure (0.02 seconds)
-
guava-tests/test/com/google/common/util/concurrent/StripedTest.java
assertThat(striped.getAt(i)).isSameInstanceAs(object); // idempotent observed.add(object); } assertTrue("All stripes observed", observed.size() == striped.size()); // this uses #get(key), makes sure an already observed stripe is returned for (int i = 0; i < striped.size() * 100; i++) { assertTrue(observed.contains(striped.get(new Object()))); } try { striped.getAt(-1); fail();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 8.1K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/cache/CacheExpirationTest.java
import java.util.concurrent.atomic.AtomicInteger; import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked; /** * Tests relating to cache expiration: make sure entries expire at the right times, make sure * expired entries don't show up, etc. * * @author mike nonemacher */ @SuppressWarnings("deprecation") // tests of deprecated method @NullUnmarked
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 23 16:38:16 GMT 2026 - 19.1K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureFallbackAtomicHelperTest.java
Thread.currentThread().setContextClassLoader(oldClassLoader); } } private void checkHelperVersion(ClassLoader classLoader, String expectedHelperClassName) throws Exception { // Make sure we are actually running with the expected helper implementation Class<?> abstractFutureStateClass = classLoader.loadClass(AbstractFutureState.class.getName());
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 7.4K bytes - Click Count (0) -
cmd/site-replication-utils.go
for { if err := sm.load(ctx, newObjectLayerFn()); err == nil { <-ctx.Done() return } duration := max(time.Duration(r.Float64()*float64(time.Second*10)), // Make sure to sleep at least a second to avoid high CPU ticks. time.Second) time.Sleep(duration) } } // load resync metrics saved on disk into memoryCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 8.8K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/AbstractMultimap.java
return get(key).add(value); } @CanIgnoreReturnValue @Override public boolean putAll(@ParametricNullness K key, Iterable<? extends V> values) { checkNotNull(values); // make sure we only call values.iterator() once // and we only call get(key) if values is nonempty if (values instanceof Collection) { Collection<? extends V> valueCollection = (Collection<? extends V>) values;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Aug 09 01:14:59 GMT 2025 - 6.4K bytes - Click Count (0) -
compat/maven-settings-builder/src/main/java/org/apache/maven/settings/building/DefaultSettingsBuilder.java
problems.setSource(""); userSettings = interpolate(userSettings, request, problems); // for the special case of a drive-relative Windows path, make sure it's absolute to save plugins from trouble String localRepository = userSettings.getLocalRepository(); if (localRepository != null && !localRepository.isEmpty()) { File file = new File(localRepository);Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Wed Jul 23 17:27:08 GMT 2025 - 9.5K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
return new FutureAsCancellable(immediateCancelledFuture()); } // We reschedule ourselves with a lock held for two reasons. 1. we want to make sure that // cancel calls cancel on the correct future. 2. we want to make sure that the assignment // to currentFuture doesn't race with itself so that currentFuture is assigned in the // correct order. Throwable scheduleFailure = null;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Aug 09 01:14:59 GMT 2025 - 27.7K bytes - Click Count (0) -
docs/distributed/DECOMMISSION.md
``` > NOTE: Canceled decommission will not make the pool active again, since we might have potentially partial namespace on the other pools, to avoid this scenario be absolutely sure to make decommissioning a planned well thought activity. This is not to be run on a daily basis. ``` λ mc admin decommission cancel alias/ http://minio{1...2}/data{1...4}Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Mon Jul 11 14:59:49 GMT 2022 - 8.3K bytes - Click Count (0) -
guava/src/com/google/common/collect/RegularContiguousSet.java
if (this.domain.equals(that.domain)) { return this.first().equals(that.first()) && this.last().equals(that.last()); } } return super.equals(object); } // copied to make sure not to use the GWT-emulated version @Override public int hashCode() { return Sets.hashCodeImpl(this); } @GwtIncompatible @J2ktIncompatible
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 8.3K bytes - Click Count (0) -
android/guava/src/com/google/common/graph/StandardNetwork.java
} @Override public EndpointPair<N> incidentNodes(E edge) { N nodeU = checkedReferenceNode(edge); // requireNonNull is safe because checkedReferenceNode made sure the edge is in the network. N nodeV = requireNonNull(nodeConnections.get(nodeU)).adjacentNode(edge); return EndpointPair.of(this, nodeU, nodeV); } @Override public Set<N> adjacentNodes(N node) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Apr 02 14:49:41 GMT 2026 - 6.9K bytes - Click Count (0)