pool - Code Search

android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

   *
   * <p><b>Warning:</b> If the input future does not already implement {@code ListenableFuture}, the
   * returned future will emulate {@link ListenableFuture#addListener} by taking a thread from an
   * internal, unbounded pool at the first call to {@code addListener} and holding it until the
   * future is {@linkplain Future#isDone() done}.
   *
   * <p>Prefer to create {@code ListenableFuture} instances with {@link SettableFuture}, {@link

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Thu Jul 17 15:26:41 GMT 2025

- 7.5K bytes

- Click Count (0)

github.com/go-gorm/gorm

tests/prepared_stmt_test.go

		t.Fatalf("Failed, got error: %v, rows affected: %v", result.Error, result.RowsAffected)
	}

	tx2.Commit()
	// Attempt to convert the connection pool of tx to the *gorm.PreparedStmtDB type.
	// If the conversion is successful, ok will be true and conn will be the converted object;
	// otherwise, ok will be false and conn will be nil.

Created: Sun Apr 05 09:35:12 GMT 2026

- Last Modified: Fri Apr 25 08:22:26 GMT 2025

- 8K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/main/java/jcifs/SmbTransportPool.java

            boolean exclusive, boolean forceSigning);

    /**
     * Removes a transport from the pool.
     *
     * @param trans the transport to remove
     */
    void removeTransport(SmbTransport trans);

    /**
     * Closes the pool and all connections in it
     *
     * @return whether any transport was still in use
     *

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Sat Aug 16 01:32:48 GMT 2025

- 7.5K bytes

- Click Count (0)

github.com/codelibs/fess-suggest

src/main/java/org/codelibs/fess/suggest/Suggester.java

 *   <li>{@link #popularWords()}: Creates a new PopularWordsRequestBuilder for querying popular words.</li>
 *   <li>{@link #refresh()}: Refreshes the suggestion indices.</li>
 *   <li>{@link #shutdown()}: Shuts down the thread pool.</li>
 *   <li>{@link #createIndexIfNothing()}: Creates a new index if no index exists.</li>
 *   <li>{@link #createNextIndex()}: Creates a new index and replaces the current update alias with the new index.</li>

Created: Fri Apr 17 09:08:13 GMT 2026

- Last Modified: Sun Feb 01 12:48:24 GMT 2026

- 21.6K bytes

- Click Count (3)

github.com/minio/minio

.github/workflows/run-mint.sh

docker volume prune -f || true
docker volume rm $(docker volume ls -q -f dangling=true) || true

# Stop two nodes, one of each pool, to check that all S3 calls work while quorum is still there
[ "${MODE}" == "pools" ] && docker-compose -f minio-${MODE}.yaml stop minio2
[ "${MODE}" == "pools" ] && docker-compose -f minio-${MODE}.yaml stop minio6

# Pause one node, to check that all S3 calls work while one node goes wrong

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Mon Jan 20 14:49:07 GMT 2025

- 1.9K bytes

- Click Count (0)

github.com/minio/minio

cmd/object-api-interface.go

	LockEnabled       bool
	VersioningEnabled bool
	ForceCreate       bool      // Create buckets even if they are already created.
	CreatedAt         time.Time // only for site replication
	NoLock            bool      // does not lock the make bucket call if set to 'true'
}

// DeleteBucketOptions provides options for DeleteBucket calls.
type DeleteBucketOptions struct {

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Sun Sep 28 20:59:21 GMT 2025

- 17.5K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/jvmTest/kotlin/okhttp3/OkHttpClientTest.kt

      .build()
    assertThat(original.interceptors.size).isEqualTo(0)
    assertThat(original.networkInterceptors.size).isEqualTo(0)
  }

  /**
   * When copying the client, stateful things like the connection pool are shared across all
   * clients.
   */
  @Test fun cloneSharesStatefulInstances() {
    val client = clientTestRule.newClient()

    // Values should be non-null.
    val a = client.newBuilder().build()

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Tue Feb 03 22:17:59 GMT 2026

- 13.4K bytes

- Click Count (1)

github.com/google/guava

android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

     * the interrupting thread doesn't interrupt the _next_ thing to run on this thread.
     *
     * Note: We don't reset the interrupted bit, just wait for it to be set. If this is a thread
     * pool thread, the thread pool will reset it for us. Otherwise, the interrupted bit may have
     * been intended for something else, so don't clear it.
     */
    boolean restoreInterruptedBit = false;
    int spinCount = 0;

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Wed Jan 28 22:39:02 GMT 2026

- 10K bytes

- Click Count (0)

github.com/tensorflow/tensorflow

ci/official/utilities/generate_index_html.sh

cat > "$1" <<EOF
<html>
<head>
<title>$(basename "$KOKORO_JOB_NAME")</title>
</head>
<body>
<h1>TensorFlow Job Logs and Links</h1>
<h2>Job Details</h2>
<ul>
<li>Job name: $KOKORO_JOB_NAME</li>
<li>Job pool: $KOKORO_JOB_POOL</li>
<li>Job ID: $KOKORO_BUILD_ID</li>
<li>Current HEAD Piper Changelist, if any: cl/${KOKORO_PIPER_CHANGELIST:-not available}</li>

Created: Tue Apr 07 12:39:13 GMT 2026

- Last Modified: Fri Sep 29 20:26:13 GMT 2023

- 2.3K bytes

- Click Count (0)

github.com/minio/minio

cmd/storage-rest-server.go

	globalLocalSetDrives = make([][][]StorageAPI, len(endpointServerPools))
	for pool := range globalLocalSetDrives {
		globalLocalSetDrives[pool] = make([][]StorageAPI, endpointServerPools[pool].SetCount)
		for set := range globalLocalSetDrives[pool] {
			globalLocalSetDrives[pool][set] = make([]StorageAPI, endpointServerPools[pool].DrivesPerSet)
		}
	}
	for _, serverPool := range endpointServerPools {

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Tue May 27 15:19:03 GMT 2025

- 45.7K bytes

- Click Count (0)

Search Options