- Sort Score
- Num 10 results
- Language All
Results 1291 - 1300 of 1,325 for concurrency (0.11 seconds)
-
guava-tests/test/com/google/common/collect/IteratorsTest.java
assertTrue(cycle.hasNext()); cycle.remove(); assertEquals(emptyList(), iterable); assertFalse(cycle.hasNext()); } /** An Iterable whose Iterator is rigorous in checking for concurrent modification. */ private static final class PickyIterable<E> implements Iterable<E> { final List<E> elements; int modCount = 0; PickyIterable(E... elements) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Mar 13 13:01:07 GMT 2026 - 57.3K bytes - Click Count (0) -
guava/src/com/google/common/collect/ImmutableMap.java
import com.google.errorprone.annotations.CanIgnoreReturnValue; import com.google.errorprone.annotations.DoNotCall; import com.google.errorprone.annotations.DoNotMock; import com.google.errorprone.annotations.concurrent.LazyInit; import com.google.j2objc.annotations.RetainedWith; import com.google.j2objc.annotations.WeakOuter; import java.io.InvalidObjectException; import java.io.ObjectInputStream; import java.io.Serializable;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Mar 08 16:16:42 GMT 2026 - 44.7K bytes - Click Count (0) -
src/test/java/jcifs/smb/SmbFileIntegrationTest.java
} } @Test void testSimpleMultipleFiles() throws Exception { // Test creating multiple files sequentially (simpler than concurrent access) for (int i = 0; i < 3; i++) { SmbFile file = new SmbFile(baseUrl + "shared/multi" + i + ".txt", context); String content = "Content for file " + i;Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 56K bytes - Click Count (0) -
android/guava/src/com/google/common/reflect/TypeToken.java
import com.google.common.collect.Ordering; import com.google.common.primitives.Primitives; import com.google.errorprone.annotations.CanIgnoreReturnValue; import com.google.errorprone.annotations.concurrent.LazyInit; import java.io.Serializable; import java.lang.reflect.Constructor; import java.lang.reflect.GenericArrayType; import java.lang.reflect.Method; import java.lang.reflect.Modifier;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jan 29 22:14:05 GMT 2026 - 53.8K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/collect/IteratorsTest.java
assertTrue(cycle.hasNext()); cycle.remove(); assertEquals(emptyList(), iterable); assertFalse(cycle.hasNext()); } /** An Iterable whose Iterator is rigorous in checking for concurrent modification. */ private static final class PickyIterable<E> implements Iterable<E> { final List<E> elements; int modCount = 0; PickyIterable(E... elements) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Mar 13 13:01:07 GMT 2026 - 57.3K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/mylasta/direction/FessProp.java
import java.util.Date; import java.util.Enumeration; import java.util.HashMap; import java.util.HashSet; import java.util.List; import java.util.Locale; import java.util.Map; import java.util.Set; import java.util.concurrent.ConcurrentHashMap; import java.util.regex.Pattern; import java.util.stream.Collectors; import java.util.stream.Stream; import javax.naming.directory.Attribute; import javax.naming.directory.BasicAttribute;
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 02:24:08 GMT 2026 - 92.3K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/mylasta/direction/FessConfig.java
*/ String getQueryGsaIndexFieldContentType(); /** * Get the value for the key 'query.collapse.max.concurrent.group.results'. <br> * The value is, e.g. 4 <br> * comment: Maximum concurrent group results for collapse queries. * @return The value of found property. (NotNull: if not found, exception but basically no way) */Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 28 06:59:19 GMT 2026 - 576.9K bytes - Click Count (2) -
cmd/bucket-handlers.go
// wrote to disk - since that amounts to "copying" from a "copy" // instead of "copying" from source, we need the stream to be seekable // to ensure that we can make fan-out calls concurrently. buf := bytebufferpool.Get() defer func() { buf.Reset() bytebufferpool.Put(buf) }() md5w := md5.New() // Maximum allowed fan-out object size.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 63.9K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt
import java.security.cert.CertificateException import java.security.cert.X509Certificate import java.time.Duration import java.util.Arrays import java.util.EnumSet import java.util.Locale import java.util.concurrent.TimeUnit import java.util.concurrent.atomic.AtomicReference import java.util.zip.GZIPInputStream import javax.net.SocketFactory import javax.net.ssl.SSLException import javax.net.ssl.SSLHandshakeException
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 133.3K bytes - Click Count (0) -
CHANGELOG/CHANGELOG-1.15.md
Check the [release notes website](https://relnotes.k8s.io/?releaseVersions=1.15.0) for the complete changelog of notable features and fixes. ## Known Issues - Concurrently joining control-plane nodes does not work as expected in kubeadm 1.15.0. The feature was planned for release in 1.15.0, but a fix may come in a follow up patch release.
Created: Fri Apr 03 09:05:14 GMT 2026 - Last Modified: Thu May 05 13:44:43 GMT 2022 - 278.9K bytes - Click Count (0)