- Sort Score
- Num 10 results
- Language All
Results 501 - 510 of 1,513 for chan (0.01 seconds)
-
guava-tests/benchmark/com/google/common/cache/LoadingCacheSingleThreadBenchmark.java
* the uniformly-distributed random integer, then truncates any fractional * part, so higher integers would appear (in this case linearly) more often * than lower ones. */ return (int) Math.pow(a, 1.0 / concentration); } @AfterExperiment void tearDown() { double req = requests.get(); double hit = req - misses.get();Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 19 18:03:30 GMT 2024 - 3.4K bytes - Click Count (0) -
guava-tests/test/com/google/common/hash/AbstractByteHasherTest.java
hasher.putLong(0x0807060504030201L); hasher.assertBytes(new byte[] {1, 2, 3, 4, 5, 6, 7, 8}); } public void testChar() { TestHasher hasher = new TestHasher(); hasher.putChar((char) 0x0201); hasher.assertBytes(new byte[] {1, 2}); } public void testString() { Random random = new Random(); for (int i = 0; i < 100; i++) { byte[] bytes = new byte[64];
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 19 18:03:30 GMT 2024 - 3.8K bytes - Click Count (0) -
cmd/server-rlimit.go
// Set the Go runtime max threads threshold to 90% of kernel setting. sysMaxThreads, err := sys.GetMaxThreads() if err == nil { minioMaxThreads := (sysMaxThreads * 90) / 100 // Only set max threads if it is greater than the default one if minioMaxThreads > 10000 { debug.SetMaxThreads(minioMaxThreads) } } var maxLimit uint64 // Set open files limit to maximum.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Jul 02 15:09:36 GMT 2024 - 2.8K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/Queues.java
return new LinkedBlockingDeque<>(); } /** * Creates an empty {@code LinkedBlockingDeque} with the given (fixed) capacity. * * @throws IllegalArgumentException if {@code capacity} is less than 1 * @since 12.0 */ @J2ktIncompatible @GwtIncompatible // LinkedBlockingDeque public static <E> LinkedBlockingDeque<E> newLinkedBlockingDeque(int capacity) { return new LinkedBlockingDeque<>(capacity);
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Nov 04 17:24:58 GMT 2025 - 18.2K bytes - Click Count (0) -
guava/src/com/google/common/collect/CompactHashMap.java
* part of the smeared hash of the key not covered by the hashtable mask, whereas the low bits are * the "next" pointer (pointing to the next entry in the bucket chain), which will always be less * than or equal to the hashtable mask. * * <pre> * hash = aaaaaaaa * mask = 00000fff * next = 00000bbb * entry = aaaaabbb * </pre> *
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Jul 08 18:32:10 GMT 2025 - 39.6K bytes - Click Count (0) -
internal/config/identity/openid/jwt.go
// Token was issued. If present, it MUST contain the OAuth // 2.0 Client ID of this party. This Claim is only needed // when the ID Token has a single audience value and that // audience is different than the authorized party. It MAY // be included even when the authorized party is the same // as the sole audience. The azp value is a case sensitive // string containing a StringOrURI value
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 8.4K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/io/MultiInputStreamTest.java
ByteSource checker = new ByteSource() { @Override public InputStream openStream() throws IOException { if (counter[0]++ != 0) { throw new IllegalStateException("More than one source open"); } return new FilterInputStream(source.openStream()) { @Override public void close() throws IOException { super.close();Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Oct 28 18:44:53 GMT 2025 - 4.7K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/CollectionFuture.java
* on the fields of TimeoutFuture. This field is slightly different from the fields discussed * there: cancel() never reads this field, only writes to it. That makes the race here completely * harmless, rather than just 99.99% harmless. */ @LazyInit private @Nullable List<@Nullable Present<V>> values; @SuppressWarnings("EmptyList") // ImmutableList doesn't support nullable element types CollectionFuture(
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 3.9K bytes - Click Count (0) -
internal/config/certs.go
var data []byte if data, err = os.ReadFile(certFile); err != nil { return nil, err } // Trimming leading and tailing white spaces. data = bytes.TrimSpace(data) // Parse all certs in the chain. current := data for len(current) > 0 { var pemBlock *pem.Block if pemBlock, current = pem.Decode(current); pemBlock == nil {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Aug 14 17:11:51 GMT 2024 - 3.8K bytes - Click Count (0) -
cmd/api-headers.go
// this function must be used by only ListObjects() for objects // with control characters, this is a specialized extension // to support AWS S3 compatible behavior. // // Do not use this function for anything other than ListObjects() // variants, please open a github discussion if you wish to use // this in other places. func encodeResponseList(response any) []byte { var buf bytes.Buffer buf.WriteString(xxml.Header)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 8.6K bytes - Click Count (0)