- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 30 for blocking (0.11 sec)
-
guava/src/com/google/common/collect/Queues.java
* Drains the queue as {@link BlockingQueue#drainTo(Collection, int)}, but if the requested {@code * numElements} elements are not available, it will wait for them up to the specified timeout. * * @param q the blocking queue to be drained * @param buffer where to add the transferred elements * @param numElements the number of elements to be waited for * @param timeout how long to wait before giving up
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 26 14:11:14 UTC 2024 - 18.2K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Queues.java
* Drains the queue as {@link BlockingQueue#drainTo(Collection, int)}, but if the requested {@code * numElements} elements are not available, it will wait for them up to the specified timeout. * * @param q the blocking queue to be drained * @param buffer where to add the transferred elements * @param numElements the number of elements to be waited for * @param timeout how long to wait before giving up
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 26 14:11:14 UTC 2024 - 18.4K bytes - Viewed (0) -
cmd/admin-heal-ops.go
return jbytes, ErrNone } // healSource denotes single entity and heal option. type healSource struct { bucket string object string versionID string noWait bool // a non blocking call, if task queue is full return right away. opts *madmin.HealOpts // optional heal option overrides default setting } // healSequence - state for each heal sequence initiated on the // server.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 25.6K bytes - Viewed (0) -
cmd/xl-storage.go
targetPath2, } { if target == "" { continue } select { case s.immediatePurge <- target: default: // Too much back pressure, we will perform the delete // blocking at this point we need to serialize operations. removeAll(target) } } } return nil }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 91.3K bytes - Viewed (0) -
CONTRIBUTING.md
This button will cause a Javascript alert dialog to appear asking you to type a reason for accepting the changes, e.g. "Added new API for Gradle 8.x". Clicking okay on the dialog will cause a copy of the `accepted-public-api-changes.json` containing your (properly sorted) addition to be downloaded. You can then replace the existing file with this new downloaded version. ### Java Toolchain
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Tue Nov 05 15:15:33 UTC 2024 - 15.6K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/google/MultisetFeature.java
@GwtCompatible public enum MultisetFeature implements Feature<Multiset> { /** * Indicates that elements from {@code Multiset.entrySet()} update to reflect changes in the * backing multiset. */ ENTRIES_ARE_VIEWS; @Override public Set<Feature<? super Multiset>> getImpliedFeatures() { return emptySet(); } @Retention(RetentionPolicy.RUNTIME) @Inherited
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 1.8K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/google/MultisetFeature.java
@GwtCompatible public enum MultisetFeature implements Feature<Multiset> { /** * Indicates that elements from {@code Multiset.entrySet()} update to reflect changes in the * backing multiset. */ ENTRIES_ARE_VIEWS; @Override public Set<Feature<? super Multiset>> getImpliedFeatures() { return emptySet(); } @Retention(RetentionPolicy.RUNTIME) @Inherited
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 1.8K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ConcurrentHashMultiset.java
* backing map. * * <p>This instance will assume ownership of {@code countMap}, and other code should not maintain * references to the map or modify it in any way. * * <p>The returned multiset is serializable if the input map is. * * @param countMap backing map for storing the elements in the multiset and their counts. It must
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 21.1K bytes - Viewed (0) -
common/scripts/setup_env.sh
#!/usr/bin/env bash # shellcheck disable=SC2034 # WARNING: DO NOT EDIT, THIS FILE IS PROBABLY A COPY # # The original version of this file is located in the https://github.com/istio/common-files repo. # If you're looking at this file in a different repo and want to make a change, please go to the # common-files repo, make the change there and check it in. Then come back to this repo and run # "make update-common". # Copyright Istio Authors #
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Nov 06 04:52:54 UTC 2024 - 8.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/ConcurrentHashMultisetBasherTest.java
} }); assertEquals("Counts not as expected", Ints.asList(deltas), actualCounts); } finally { pool.shutdownNow(); } // Since we have access to the backing map, verify that there are no zeroes in the map for (AtomicInteger value : map.values()) { assertTrue("map should not contain a zero", value.get() != 0); } }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 5.9K bytes - Viewed (0)