- Sort Score
- Result 10 results
- Languages All
Results 521 - 530 of 985 for concurrent1 (0.05 sec)
-
guava/src/com/google/common/cache/LongAddables.java
* the License. */ package com.google.common.cache; import com.google.common.annotations.GwtCompatible; import java.util.concurrent.atomic.LongAdder; /** * Source of {@link LongAddable} objects that deals with GWT and all that. * * @author Louis Wasserman */ @GwtCompatible final class LongAddables {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Aug 10 19:54:19 UTC 2025 - 1.1K bytes - Viewed (0) -
docs/changelogs/changelog_4x.md
* Fix: Immediately update the connection's flow control window instead of waiting for the receiving stream to process it. This change may increase OkHttp's memory use for applications that make many concurrent HTTP calls and that can receive data faster than they can process it. Previously, OkHttp limited HTTP/2 to 16 MiB of unacknowledged data per connection. With this fix there is a limit of 16 MiB
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Apr 17 13:25:31 UTC 2024 - 25.2K bytes - Viewed (0) -
.github/workflows/helm-lint.yml
name: Helm Chart linting on: pull_request: branches: - master # This ensures that previous jobs for the PR are canceled when the PR is # updated. concurrency: group: ${{ github.workflow }}-${{ github.head_ref }} cancel-in-progress: true permissions: contents: read jobs: release: runs-on: ubuntu-latest steps: - name: Checkout uses: actions/checkout@v4
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Jun 09 09:13:09 UTC 2024 - 551 bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/WebSocketEcho.java
package okhttp3.recipes; import java.util.concurrent.TimeUnit; import okhttp3.OkHttpClient; import okhttp3.Request; import okhttp3.Response; import okhttp3.WebSocket; import okhttp3.WebSocketListener; import okio.ByteString; public final class WebSocketEcho extends WebSocketListener { private void run() { OkHttpClient client = new OkHttpClient.Builder() .readTimeout(0, TimeUnit.MILLISECONDS) .build();
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Apr 04 11:40:21 UTC 2024 - 1.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/dict/DictionaryManager.java
} } return OptionalEntity.empty(); } /** * Stores or updates a dictionary file in the ConfigSync storage. * This method checks for concurrent modifications by comparing timestamps * and uploads the file content to the ConfigSync API. * * @param dictFile the dictionary file metadata to store
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 7.7K bytes - Viewed (0) -
cmd/metacache.go
metacacheBlockSize = 5000 // metacacheSharePrefix controls whether prefixes on dirty paths are always shared. // This will make `test/a` and `test/b` share listings if they are concurrent. // Enabling this will make cache sharing more likely and cause less IO, // but may cause additional latency to some calls. metacacheSharePrefix = false ) //go:generate msgp -file $GOFILE -unexported
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Jul 12 16:23:16 UTC 2024 - 6K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelLoadBalancer.java
*/ package jcifs.internal.smb2.multichannel; import java.util.ArrayList; import java.util.Collection; import java.util.List; import java.util.concurrent.ThreadLocalRandom; import java.util.concurrent.atomic.AtomicInteger; import jcifs.internal.CommonServerMessageBlock; import jcifs.internal.smb2.ServerMessageBlock2Request; import jcifs.internal.smb2.info.Smb2QueryDirectoryRequest;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 8.2K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Dns.kt
* implementation to use a different DNS server, to prefer IPv6 addresses, to prefer IPv4 addresses, * or to force a specific known IP address. * * Implementations of this interface must be safe for concurrent use. */ fun interface Dns { /** * Returns the IP addresses of `hostname`, in the order they will be attempted by OkHttp. If a
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 2.2K bytes - Viewed (0) -
regression-test/src/androidTest/java/okhttp/regression/compare/ApacheHttpClientHttp2Test.kt
import org.apache.hc.client5.http.async.methods.SimpleHttpRequests import org.apache.hc.client5.http.async.methods.SimpleHttpResponse import org.apache.hc.client5.http.impl.async.HttpAsyncClients import org.apache.hc.core5.concurrent.FutureCallback import org.apache.hc.core5.http.ProtocolVersion import org.junit.Assert import org.junit.Test /** * Simplified from
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/SettableFuture.java
* or implied. See the License for the specific language governing permissions and limitations under * the License. */ package com.google.common.util.concurrent; import com.google.common.annotations.GwtCompatible; import com.google.errorprone.annotations.CanIgnoreReturnValue; import org.jspecify.annotations.Nullable; /**
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 2.3K bytes - Viewed (0)