- Sort Score
- Result 10 results
- Languages All
Results 571 - 580 of 822 for Concurrent (0.04 sec)
-
src/main/java/org/codelibs/fess/helper/SystemHelper.java
import java.util.Map.Entry; import java.util.Properties; import java.util.Set; import java.util.TimeZone; import java.util.UUID; import java.util.concurrent.ExecutionException; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicInteger; import java.util.function.Supplier; import java.util.regex.Pattern; import java.util.stream.Collectors;
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Dec 20 08:30:43 UTC 2025 - 36.6K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/TrailersTest.kt
import assertk.assertions.isIn import assertk.assertions.isLessThan import assertk.assertions.isNull import assertk.assertions.isTrue import java.lang.Thread.sleep import java.util.concurrent.TimeUnit import kotlin.concurrent.thread import kotlin.test.assertFailsWith import kotlin.time.Duration import kotlin.time.Duration.Companion.milliseconds import kotlin.time.measureTime import mockwebserver3.MockResponse
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sat Nov 08 21:45:04 UTC 2025 - 18.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/PopulatedCachesTest.java
import static com.google.common.cache.TestingCacheLoaders.identityLoader; import static com.google.common.truth.Truth.assertThat; import static java.util.concurrent.TimeUnit.DAYS; import static java.util.concurrent.TimeUnit.SECONDS; import static org.junit.Assert.assertThrows; import com.google.common.base.Function; import com.google.common.cache.CacheBuilderFactory.DurationSpec;
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 30 22:03:28 UTC 2025 - 15.7K bytes - Viewed (0) -
CLAUDE.md
``` ### Setting Crawl Limits ```java context.setMaxAccessCount(1000); // Max URLs (0 = unlimited) context.setMaxDepth(3); // Max depth (-1 = unlimited) context.setNumOfThread(10); // Concurrent threads ``` ### Accessing Results ```java DataService ds = container.getComponent("dataService"); // Count int count = ds.getCount(sessionId); // Get by URL
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Fri Nov 28 17:31:34 UTC 2025 - 10.7K bytes - Viewed (0) -
src/main/java/org/codelibs/core/collection/Maps.java
import java.util.HashMap; import java.util.Hashtable; import java.util.IdentityHashMap; import java.util.LinkedHashMap; import java.util.Map; import java.util.TreeMap; import java.util.WeakHashMap; import java.util.concurrent.ConcurrentHashMap; /** * Utility class for easily creating and setting values in {@link Map} instances. * <p> * By statically importing this class, you can easily initialize {@literal Map} instances as follows:Registered: Sat Dec 20 08:55:33 UTC 2025 - Last Modified: Thu Jun 19 09:12:22 UTC 2025 - 7.2K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/RequestWithFileIdTest.java
// Wait for all threads to complete for (Thread thread : threads) { thread.join(); } // Then - should complete without errors assertTrue(true, "Concurrent setFileId calls should complete without issues"); } @Test @DisplayName("Should handle file ID with special patterns") void testSpecialFileIdPatterns() { // Test various special patternsRegistered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 11.9K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/ResponseBodyJvmTest.kt
import assertk.assertions.isEqualTo import assertk.assertions.isTrue import java.io.IOException import java.io.InputStreamReader import java.io.Reader import java.nio.charset.StandardCharsets import java.util.concurrent.atomic.AtomicBoolean import kotlin.test.assertFailsWith import okhttp3.MediaType.Companion.toMediaType import okhttp3.ResponseBody.Companion.toResponseBody import okhttp3.internal.and import okio.Buffer
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 12.4K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Settings.kt
const val HEADER_TABLE_SIZE = 1 /** HTTP/2: The peer must not send a PUSH_PROMISE frame when this is 0. */ const val ENABLE_PUSH = 2 /** Sender's maximum number of concurrent streams. */ const val MAX_CONCURRENT_STREAMS = 3 /** Window size in bytes. */ const val INITIAL_WINDOW_SIZE = 4 /** HTTP/2: Size in bytes of the largest frame payload the sender will accept. */Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 3.8K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/testers/ListListIteratorTester.java
import com.google.common.collect.testing.features.ListFeature; import java.lang.reflect.Method; import java.util.List; import java.util.ListIterator; import java.util.Set; import java.util.concurrent.CopyOnWriteArraySet; import org.jspecify.annotations.NullMarked; import org.jspecify.annotations.Nullable; import org.junit.Ignore; /**
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 5K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/testing/FreshValueGeneratorTest.java
import java.util.NavigableSet; import java.util.Set; import java.util.SortedMap; import java.util.SortedSet; import java.util.TreeMap; import java.util.TreeSet; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.TimeUnit; import java.util.regex.MatchResult; import java.util.regex.Pattern; import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked; /**
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 16:03:47 UTC 2025 - 17.4K bytes - Viewed (0)