Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 808 for pool (0.04 sec)

  1. android/guava/src/com/google/common/util/concurrent/ThreadFactoryBuilder.java

       *     be unique to the built instance of the ThreadFactory and will be assigned sequentially. For
       *     example, {@code "rpc-pool-%d"} will generate thread names like {@code "rpc-pool-0"}, {@code
       *     "rpc-pool-1"}, {@code "rpc-pool-2"}, etc.
       * @return this for the builder pattern
       */
      @CanIgnoreReturnValue
      public ThreadFactoryBuilder setNameFormat(String nameFormat) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:35:26 UTC 2025
    - 9K bytes
    - Viewed (0)
  2. ci/official/containers/ml_build/builder.devtoolset/build_devtoolset.sh

      wget "http://old-releases.ubuntu.com/ubuntu/pool/main/e/eglibc/libc6_2.12.1-0ubuntu6_amd64.deb" && \
          unar "libc6_2.12.1-0ubuntu6_amd64.deb" && \
          tar -C "${TARGET}" -xvzf "libc6_2.12.1-0ubuntu6_amd64/data.tar.gz" && \
          rm -rf "libc6_2.12.1-0ubuntu6_amd64.deb" "libc6_2.12.1-0ubuntu6_amd64"
      # Download binary glibc 2.12 development library release.
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Tue Sep 24 20:45:58 UTC 2024
    - 8K bytes
    - Viewed (0)
  3. interfaces.go

    type Plugin interface {
    	Name() string
    	Initialize(*DB) error
    }
    
    type ParamsFilter interface {
    	ParamsFilter(ctx context.Context, sql string, params ...interface{}) (string, []interface{})
    }
    
    // ConnPool db conns pool interface
    type ConnPool interface {
    	PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)
    	ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Sat Aug 19 13:33:31 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  4. src/test/java/jcifs/smb/CriticalPerformanceTest.java

            // Test multiple components together
            long start = System.nanoTime();
    
            // 1. Connection Pool Test
            SmbTransportPoolImpl pool = new SmbTransportPoolImpl();
            pool.setMaxPoolSize(50);
            for (int i = 0; i < 100; i++) {
                pool.contains(null); // Should be fast without global sync
            }
    
            // 2. Buffer Cache Test
            for (int i = 0; i < 100; i++) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 15.3K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/suggest/SuggesterBuilder.java

        }
    
        /**
         * Sets the thread pool.
         * @param threadPool The thread pool.
         * @return This builder instance.
         */
        public SuggesterBuilder threadPool(final ExecutorService threadPool) {
            this.threadPool = threadPool;
            return this;
        }
    
        /**
         * Sets the thread pool size.
         * @param threadPoolSize The thread pool size.
         * @return This builder instance.
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Fri Jul 04 14:00:23 UTC 2025
    - 6K bytes
    - Viewed (0)
  6. docs/distributed/README.md

    > **NOTE:** **Each pool you add must have the same erasure coding parity configuration as the original pool, so the same data redundancy SLA is maintained.**
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 8.9K bytes
    - Viewed (0)
  7. okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt

      var uriPort: Int = 1
    
      fun newConnection(
        pool: RealConnectionPool,
        route: Route,
        idleAtNanos: Long = Long.MAX_VALUE,
        taskRunner: TaskRunner = this.taskRunner,
      ): RealConnection {
        val result =
          RealConnection.newTestConnection(
            taskRunner = taskRunner,
            connectionPool = pool,
            route = route,
            socket = Socket(),
            idleAtNs = idleAtNanos,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri May 30 21:28:20 UTC 2025
    - 7.7K bytes
    - Viewed (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/FakeRoutePlanner.kt

        val id: Int,
      ) : RoutePlanner.Plan {
        var planningThrowable: Throwable? = null
        var canceled = false
        var connectState = ConnectState.READY
        val connection =
          factory.newConnection(
            pool = pool,
            route = factory.newRoute(address),
            idleAtNanos = defaultConnectionIdleAtNanos,
          )
        var retry: FakePlan? = null
        var retryTaken = false
        var yieldBeforePlanReturns = false
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/ThreadFactoryBuilderTest.java

        // pool ID but a thread ID of 2.
        Thread thread2 = threadFactory.newThread(monitoredRunnable);
        checkThreadPoolName(thread2, 2);
        assertEquals(
            thread.getName().substring(0, thread.getName().lastIndexOf('-')),
            thread2.getName().substring(0, thread.getName().lastIndexOf('-')));
    
        // Building again should give us a different pool ID.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 7.6K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

        connections.add(connection)
    //    connection.queueEvent { connectionListener.connectEnd(connection) }
        scheduleCloser()
      }
    
      /**
       * Notify this pool that [connection] has become idle. Returns true if the connection has been
       * removed from the pool and should be closed.
       */
      fun connectionBecameIdle(connection: RealConnection): Boolean {
        connection.assertLockHeld()
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jun 03 17:10:08 UTC 2025
    - 16.1K bytes
    - Viewed (0)
Back to top