Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 157 for contention (0.06 sec)

  1. android/guava/src/com/google/common/cache/LongAdder.java

     * sum that is used for purposes such as collecting statistics, not for fine-grained synchronization
     * control. Under low update contention, the two classes have similar characteristics. But under
     * high contention, expected throughput of this class is significantly higher, at the expense of
     * higher space consumption.
     *
     * <p>This class extends {@link Number}, but does not define methods such as {@code
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 5.6K bytes
    - Viewed (0)
  2. docs/contribute/concurrency.md

    #### Per-Connection Locks
    
    Each connection has its own lock. The connections in the pool are all in a `ConcurrentLinkedQueue`. Due to data races, iterators of this queue may return removed connections. Callers must check the connection's `noNewExchanges` property before using connections from the pool.
    
    The connection lock is never held while doing I/O (even closing a socket) to prevent contention.
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Connection.kt

     */
    interface Connection {
      /** Returns the route used by this connection. */
      fun route(): Route
    
      /**
       * Returns the socket that this connection is using. Returns an
       * [SSL socket][javax.net.ssl.SSLSocket] if this connection is HTTPS. If this is an HTTP/2
       * connection the socket may be shared by multiple concurrent calls.
       */
      fun socket(): Socket
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  4. guava/src/com/google/common/base/CaseFormat.java

        }
      },
    
      /** Java variable naming convention, e.g., "lowerCamel". */
      LOWER_CAMEL(CharMatcher.inRange('A', 'Z'), "") {
        @Override
        String normalizeWord(String word) {
          return firstCharOnlyToUpper(word);
        }
    
        @Override
        String normalizeFirstWord(String word) {
          return Ascii.toLowerCase(word);
        }
      },
    
      /** Java and C++ class naming convention, e.g., "UpperCamel". */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue Apr 15 22:14:00 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/CallConnectionUser.kt

      override fun connectionConnectEnd(
        connection: Connection,
        route: Route,
      ) {
        poolConnectionListener.connectEnd(connection, route, call)
      }
    
      override fun connectionAcquired(connection: Connection) {
        eventListener.connectionAcquired(call, connection)
      }
    
      override fun acquireConnectionNoEvents(connection: RealConnection) {
        call.acquireConnectionNoEvents(connection)
      }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri May 30 21:28:20 UTC 2025
    - 4.1K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/PoolConnectionUser.kt

      override fun connectionReleased(connection: Connection) {
      }
    
      override fun connectionConnectionAcquired(connection: RealConnection) {
      }
    
      override fun connectionConnectionReleased(connection: RealConnection) {
      }
    
      override fun connectionConnectionClosed(connection: RealConnection) {
      }
    
      override fun noNewExchanges(connection: RealConnection) {
      }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 2.6K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/CallServerInterceptor.kt

              }
            } else {
              exchange.noRequestBody()
              if (!exchange.connection.isMultiplexed) {
                // If the "Expect: 100-continue" expectation wasn't met, prevent the HTTP/1 connection
                // from being reused. Otherwise we're still obligated to transmit the request body to
                // leave the connection in a consistent state.
                exchange.noNewExchangesOnConnection()
              }
            }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jul 29 22:04:11 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/base/CaseFormat.java

        }
      },
    
      /** Java variable naming convention, e.g., "lowerCamel". */
      LOWER_CAMEL(CharMatcher.inRange('A', 'Z'), "") {
        @Override
        String normalizeWord(String word) {
          return firstCharOnlyToUpper(word);
        }
    
        @Override
        String normalizeFirstWord(String word) {
          return Ascii.toLowerCase(word);
        }
      },
    
      /** Java and C++ class naming convention, e.g., "UpperCamel". */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue Apr 15 22:14:00 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectionListener.kt

        connection: Connection,
        route: Route,
        call: Call,
      ) {}
    
      /**
       * Invoked when a connection is released as no longer required.
       */
      open fun connectionClosed(connection: Connection) {}
    
      /**
       * Invoked when a call is assigned a particular connection.
       */
      open fun connectionAcquired(
        connection: Connection,
        call: Call,
      ) {}
    
      /**
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri May 30 21:28:20 UTC 2025
    - 2.2K bytes
    - Viewed (0)
  10. buildSrc/src/main/kotlin/Osgi.kt

          BundleTaskExtension::class.java,
          jarTask,
        )
      bundleExtension.run {
        setClasspath(osgi.compileClasspath + sourceSets["main"].compileClasspath)
        bnd(*bndProperties)
      }
      // Call the convention when the task has finished, to modify the jar to contain OSGi metadata.
      jarTask.doLast {
        bundleExtension.buildAction().execute(this)
      }
    }
    
    fun Project.applyOsgiMultiplatform(vararg bndProperties: String) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Aug 01 08:06:31 UTC 2025
    - 5.1K bytes
    - Viewed (0)
Back to top