- Sort Score
- Result 10 results
- Languages All
Results 781 - 790 of 985 for concurrent1 (0.6 sec)
-
okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/HttpLoggingInterceptor.kt
* limitations under the License. */ package okhttp3.logging import java.io.IOException import java.nio.charset.Charset import java.util.TreeSet import java.util.concurrent.TimeUnit import okhttp3.Headers import okhttp3.HttpUrl import okhttp3.Interceptor import okhttp3.OkHttpClient import okhttp3.Response import okhttp3.internal.charsetOrUtf8 import okhttp3.internal.http.promisesBody
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Aug 21 14:27:04 UTC 2025 - 11.4K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/mylasta/direction/FessConfigImplTest.java
} catch (ConfigPropertyNotFoundException e) { // Expected exception assertTrue(e.getMessage().contains("filter.null")); } } // Test concurrent access public void test_get_concurrentAccess() throws InterruptedException { // Create multiple threads accessing the same property final String testKey = "domain.title";
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 12.6K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/ConnectionReuseTest.kt
* limitations under the License. */ package okhttp3 import assertk.assertThat import assertk.assertions.isEqualTo import java.io.IOException import java.util.concurrent.TimeUnit import javax.net.ssl.SSLException import kotlin.test.assertFailsWith import mockwebserver3.MockResponse import mockwebserver3.MockWebServer import mockwebserver3.SocketEffect.CloseSocket
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 12.2K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt
lateinit var currentThread: Thread private val loggerHandler = object : Handler() { override fun publish(record: LogRecord) { // Try to avoid multi threading issues with concurrent requests if (Thread.currentThread() != currentThread) { return } // https://timothybasanov.com/2016/05/26/java-pre-master-secret.html
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat May 10 11:15:14 UTC 2025 - 10.9K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/FreshValueGenerator.java
import java.util.OptionalLong; 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.atomic.AtomicInteger; import java.util.regex.Pattern; import org.jspecify.annotations.NullUnmarked; import org.jspecify.annotations.Nullable; /**
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 28.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/Crawler.java
import java.util.ArrayList; import java.util.Collections; import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Queue; import java.util.concurrent.ConcurrentLinkedQueue; import java.util.concurrent.atomic.AtomicBoolean; import java.util.stream.Collectors; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.CoreLibConstants;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 31K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/RequestBody.kt
* [RequestBody.writeTo] after that method returns. For duplex requests bodies that condition is * lifted. Such writes occur on an application-provided thread and may occur concurrently with * reads of the [ResponseBody]. For duplex request bodies, [writeTo] should return * quickly, possibly by handing off the provided request body to another thread to perform * writing. *
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 04 17:43:43 UTC 2025 - 9K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt
import java.io.IOException import java.net.UnknownServiceException import kotlin.test.assertFailsWith import okhttp3.FakeRoutePlanner import okhttp3.FakeRoutePlanner.ConnectState.TLS_CONNECTED import okhttp3.internal.concurrent.TaskFaker import org.junit.jupiter.api.AfterEach import org.junit.jupiter.api.Test /** * Unit test for [FastFallbackExchangeFinder] implementation details. *
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 20.9K bytes - Viewed (0) -
src/main/java/jcifs/Configuration.java
*/ int getPid(); /** * * Property {@code jcifs.smb.client.maxMpxCount} (int, default 10) * * @return maximum count of concurrent commands to announce */ int getMaxMpxCount(); /** * * Property {@code jcifs.smb.client.signingPreferred} (boolean, default false) *
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 25.4K bytes - Viewed (0) -
docs/fr/docs/deployment/manually.md
En ajoutant `standard`, Uvicorn va installer et utiliser quelques dépendances supplémentaires recommandées. Cela inclut `uvloop`, le remplaçant performant de `asyncio`, qui fournit le gros gain de performance en matière de concurrence. /// //// //// tab | Hypercorn * <a href="https://github.com/pgjones/hypercorn" class="external-link" target="_blank">Hypercorn</a>, un serveur ASGI également compatible avec HTTP/2.
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sat Nov 09 16:39:20 UTC 2024 - 5.3K bytes - Viewed (0)