- Sort Score
- Result 10 results
- Languages All
Results 991 - 1000 of 1,022 for concurrency (0.1 sec)
-
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/HcHttpClient.java
import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Locale; import java.util.Map; import java.util.concurrent.TimeUnit; import java.util.regex.Pattern; import javax.net.ssl.SSLContext; import org.apache.commons.io.output.DeferredFileOutputStream; import org.apache.commons.lang3.SystemUtils; import org.apache.http.Header;
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 52.2K bytes - Viewed (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;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 44.3K bytes - Viewed (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;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 56K bytes - Viewed (0) -
guava/src/com/google/common/collect/Iterables.java
* @throws NoSuchElementException if the iterable is empty */ @ParametricNullness public static <T extends @Nullable Object> T getLast(Iterable<T> iterable) { // TODO(kevinb): Support a concurrently modified collection? if (iterable instanceof List) { List<T> list = (List<T>) iterable; if (list.isEmpty()) { throw new NoSuchElementException(); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 43.3K bytes - Viewed (0) -
cmd/object-handlers_test.go
} // Wrapper for calling NewMultipartUploadParallel tests for both Erasure multiple disks and single node setup. // The objective of the test is to initialte multipart upload on the same object 10 times concurrently, // The UploadID from the response body is parsed and its existence is asserted with an attempt to ListParts using it. func TestAPINewMultipartHandlerParallel(t *testing.T) { defer DetectTestLeak(t)()
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 163.1K bytes - Viewed (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) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 54.4K bytes - Viewed (0) -
android/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;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 41.2K bytes - Viewed (0) -
android/guava/src/com/google/common/net/MediaType.java
import com.google.common.collect.Multimaps; import com.google.errorprone.annotations.CanIgnoreReturnValue; import com.google.errorprone.annotations.Immutable; import com.google.errorprone.annotations.concurrent.LazyInit; import java.nio.charset.Charset; import java.nio.charset.IllegalCharsetNameException; import java.nio.charset.UnsupportedCharsetException; import java.util.HashMap; import java.util.Map;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 48K bytes - Viewed (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
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Jun 21 20:36:35 UTC 2025 - 133.2K bytes - Viewed (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.
Registered: Fri Sep 05 09:05:11 UTC 2025 - Last Modified: Thu May 05 13:44:43 UTC 2022 - 278.9K bytes - Viewed (0)