- Sort Score
- Result 10 results
- Languages All
Results 1471 - 1480 of 1,618 for lang (0.02 sec)
-
src/test/java/org/codelibs/core/collection/CaseInsensitiveMapTest.java
Registered: Fri Nov 01 20:58:10 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 4K bytes - Viewed (0) -
.teamcity/.mvn/wrapper/MavenWrapperDownloader.java
ReadableByteChannel rbc; rbc = Channels.newChannel(website.openStream()); FileOutputStream fos = new FileOutputStream(destination); fos.getChannel().transferFrom(rbc, 0, Long.MAX_VALUE); fos.close(); rbc.close(); }
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Wed Feb 26 01:48:39 UTC 2020 - 4.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/concurrent/Deferred.java
} return this; } public RESPONSE getResponse() { return getResponse(1, TimeUnit.MINUTES); } public RESPONSE getResponse(final long time, final TimeUnit unit) { try { final boolean isTimeout = !latch.await(time, unit); if (isTimeout) {
Registered: Fri Nov 08 09:08:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 5.4K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
sconfig.Net.TLS.Config.ClientAuth = h.kconfig.TLS.ClientAuth sconfig.Net.TLS.Config.RootCAs = h.kconfig.TLS.RootCAs // These settings are needed to ensure that kafka client doesn't hang on brokers // refer https://github.com/IBM/sarama/issues/765#issuecomment-254333355 sconfig.Producer.Retry.Max = 2 sconfig.Producer.Retry.Backoff = (10 * time.Second) sconfig.Producer.Return.Successes = true
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 10.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/SynchronizedQueueTest.java
} @Override public <T> T[] toArray(T[] array) { assertTrue(Thread.holdsLock(mutex)); return delegate.toArray(array); } private static final long serialVersionUID = 0; } @SuppressWarnings("CheckReturnValue") public void testHoldsLockOnAllOperations() { create().element(); create().offer("foo"); create().peek(); create().poll();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Aug 19 20:50:58 UTC 2024 - 4.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/SynchronizedTableTest.java
return delegate.rowKeySet(); } @Override public Map<R, Map<C, V>> rowMap() { assertTrue(Thread.holdsLock(mutex)); return delegate.rowMap(); } private static final long serialVersionUID = 0; } @Override protected Table<String, Integer, Character> create(@Nullable Object... data) { TestTable<String, Integer, Character> table = new TestTable<>();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Aug 06 17:23:04 UTC 2024 - 4.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionError.java
* provide a non-nullable {@code cause}, as many users expect to find one. */ public ExecutionError(@CheckForNull Error cause) { super(cause); } private static final long serialVersionUID = 0;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Mar 07 17:52:19 UTC 2024 - 3.8K bytes - Viewed (0) -
guava/src/com/google/common/hash/MessageDigestHashFunction.java
this.bytes = bytes; this.toString = toString; } private Object readResolve() { return new MessageDigestHashFunction(algorithmName, bytes, toString); } private static final long serialVersionUID = 0; } Object writeReplace() { return new SerializedForm(prototype.getAlgorithm(), bytes, toString); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed May 25 20:32:46 UTC 2022 - 5K bytes - Viewed (0) -
misc/cgo/gmp/gmp.go
Go to hang on to a reference to the pointer until C is done with it. */ package gmp /* #cgo LDFLAGS: -lgmp #include <gmp.h> #include <stdlib.h> // gmp 5.0.0+ changed the type of the 3rd argument to mp_bitcnt_t, // so, to support older versions, we wrap these two functions. void _mpz_mul_2exp(mpz_ptr a, mpz_ptr b, unsigned long n) { mpz_mul_2exp(a, b, n); }
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Mon Apr 11 16:34:30 UTC 2022 - 9.5K bytes - Viewed (0) -
tensorflow/c/c_api_experimental.h
// Checks the health of collective ops peers. Explicit health check is needed in // multi worker collective ops to detect failures in the cluster. If a peer is // down, collective ops may hang. TF_CAPI_EXPORT extern void TFE_CollectiveOpsCheckPeerHealth( TFE_Context* ctx, const char* task, int64_t timeout_in_ms, TF_Status* status); // Information about the shape of a Tensor and its type.
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Thu Apr 27 21:07:00 UTC 2023 - 15.1K bytes - Viewed (0)