- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of about 10,000 for lost (0.05 sec)
-
guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
* finishing. Also acts as a concurrency test to make sure the locking is done correctly when a * future is finishing so that no listeners can be lost. */ public void testAllListenersCompleteSuccessfully() throws InterruptedException, ExecutionException { ExecutorService exec = Executors.newCachedThreadPool(); int listenerCount = 20;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 18:30:30 UTC 2023 - 6K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ForwardingSortedMap.java
public abstract class ForwardingSortedMap<K extends @Nullable Object, V extends @Nullable Object> extends ForwardingMap<K, V> implements SortedMap<K, V> { // TODO(lowasser): identify places where thread safety is actually lost /** Constructor for use by subclasses. */ protected ForwardingSortedMap() {} @Override protected abstract SortedMap<K, V> delegate(); @Override @CheckForNull
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 12 15:26:39 UTC 2023 - 5.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Monitor.java
* other thread (last thread modifying the state protected by the monitor) takes over the * responsibility of signalling the next waiter. * * <p>This method must not be called from within a beginWaitingFor/endWaitingFor block, or else * the current thread's guard might be mistakenly signalled, leading to a lost signal. */ @GuardedBy("lock") private void signalNextWaiter() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 18:22:01 UTC 2023 - 38.6K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ConcurrentHashMultiset.java
return snapshot().toArray(array); } private List<Multiset.Entry<E>> snapshot() { List<Multiset.Entry<E>> list = Lists.newArrayListWithExpectedSize(size()); // Not Iterables.addAll(list, this), because that'll forward right back here. Iterators.addAll(list, iterator()); return list; } } /** @serialData the ConcurrentMap of elements and their counts. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 21:19:52 UTC 2024 - 20.9K bytes - Viewed (0) -
platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/maven/MavenVersionRangeResolveIntegrationTest.groovy
root(":", ":test:") { edge("org.test:projectA:[1.1]", "org.test:projectA:1.1") { edge("org.test:projectB:2.0", "org.test:projectB:2.0") // Transitive version range is lost when converting to Ivy ModuleDescriptor } } } } @Issue("https://github.com/gradle/gradle/issues/1898") def "can resolve parent pom with version range"() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 10 21:10:11 UTC 2023 - 7.4K bytes - Viewed (0) -
pkg/kube/portforwarder.go
// Close this forwarder and release an resources. Close() // ErrChan returns a channel that returns an error when one is encountered. While Start() may return an initial error, // the port-forward connection may be lost at anytime. The ErrChan can be read to determine if/when the port-forwarding terminates. // This can return nil if the port forwarding stops gracefully. ErrChan() <-chan error
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 02:12:37 UTC 2023 - 5.5K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Monitor.java
* other thread (last thread modifying the state protected by the monitor) takes over the * responsibility of signalling the next waiter. * * <p>This method must not be called from within a beginWaitingFor/endWaitingFor block, or else * the current thread's guard might be mistakenly signalled, leading to a lost signal. */ @GuardedBy("lock")
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 18:22:01 UTC 2023 - 42.5K bytes - Viewed (0) -
cmd/peer-s3-client.go
} } } // loop through buckets and see if some with lost quorum // these could be stale buckets lying around, queue a heal // of such a bucket. This is needed here as we identify such // buckets here while listing buckets. As part of regular // globalBucketMetadataSys.Init() call would get a valid // buckets only and not the quourum lost ones like this, so // explicit call
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 15.3K bytes - Viewed (0) -
src/go/ast/filter.go
// General filtering type Filter func(string) bool func filterIdentList(list []*Ident, f Filter) []*Ident { j := 0 for _, x := range list { if f(x.Name) { list[j] = x j++ } } return list[0:j] } // fieldName assumes that x is the type of an anonymous field and // returns the corresponding field name. If x is not an acceptable
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 13.3K bytes - Viewed (0) -
guava/src/com/google/common/collect/ConcurrentHashMultiset.java
return snapshot().toArray(array); } private List<Multiset.Entry<E>> snapshot() { List<Multiset.Entry<E>> list = Lists.newArrayListWithExpectedSize(size()); // Not Iterables.addAll(list, this), because that'll forward right back here. Iterators.addAll(list, iterator()); return list; } } /** @serialData the ConcurrentMap of elements and their counts. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 21:19:52 UTC 2024 - 20.9K bytes - Viewed (0)