Search Options

Results per page
Sort
Preferred Languages
Advance

Results 521 - 530 of 985 for concurrent1 (0.56 sec)

  1. 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)
  2. 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)
  3. .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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top