poolId - Code Search

src/main/java/jcifs/smb/MultiChannelManager.java

        this.loadBalancingStrategy = getLoadBalancingStrategyFromConfig(config);
        this.healthCheckInterval = getHealthCheckIntervalFromConfig(config);

        // Create thread pools
        this.channelExecutor = Executors.newCachedThreadPool(r -> {
            Thread t = new Thread(r, "SMB3-MultiChannel-Worker");
            t.setDaemon(true);
            return t;
        });

Created: Sat Dec 20 13:44:44 GMT 2025

- Last Modified: Sun Aug 31 08:00:57 GMT 2025

- 20.5K bytes

- Click Count (0)

github.com/codelibs/corelib

src/main/java/org/codelibs/core/concurrent/CommonPoolUtil.java

 * governing permissions and limitations under the License.
 */
package org.codelibs.core.concurrent;

import java.util.concurrent.ForkJoinPool;

import org.codelibs.core.log.Logger;

/**
 * Utility for common pool operations.
 */
public abstract class CommonPoolUtil {
    private static final Logger logger = Logger.getLogger(CommonPoolUtil.class);

    protected CommonPoolUtil() {
        // nothing
    }

    /**

Created: Sat Dec 20 08:55:33 GMT 2025

- Last Modified: Thu Jul 31 08:16:49 GMT 2025

- 1.7K bytes

- Click Count (0)

github.com/minio/minio

cmd/peer-rest-server.go

	objAPI := newObjectLayerFn()
	if objAPI == nil {
		return np, grid.NewRemoteErr(errServerNotInitialized)
	}

	pools, ok := objAPI.(*erasureServerPools)
	if !ok {
		return np, grid.NewRemoteErr(errors.New("not a pooled setup"))
	}

	pools.StopRebalance()
	return np, nerr
}

func (s *peerRESTServer) LoadRebalanceMetaHandler(mss *grid.MSS) (np grid.NoPayload, nerr *grid.RemoteErr) {

Created: Sun Dec 28 19:28:13 GMT 2025

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

- 53.6K bytes

- Click Count (0)

github.com/tiangolo/fastapi

scripts/docs.py

        if (lang.is_dir() and lang.name in SUPPORTED_LANGS)
    ]
    cpu_count = os.cpu_count() or 1
    process_pool_size = cpu_count * 4
    typer.echo(f"Using process pool size: {process_pool_size}")
    with Pool(process_pool_size) as p:
        p.map(build_lang, langs)


@app.command()
def update_languages() -> None:
    """

Created: Sun Dec 28 07:19:09 GMT 2025

- Last Modified: Sun Dec 21 17:40:17 GMT 2025

- 16.9K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/timer/SystemMonitorTarget.java

        append(buf, "committed", () -> mem.getNonHeapCommitted().getBytes());
        buf.append('}');
        buf.append("},");
        final List<BufferPool> bufferPools = jvmStats.getBufferPools();
        buf.append("\"pools\":{");
        buf.append(bufferPools.stream().map(p -> {
            final StringBuilder b = new StringBuilder();
            b.append('"').append(StringEscapeUtils.escapeJson(p.getName())).append("\":{");

Created: Sat Dec 20 09:19:18 GMT 2025

- Last Modified: Thu Jul 17 08:28:31 GMT 2025

- 7.8K bytes

- Click Count (0)

github.com/codelibs/curl4j

src/main/java/org/codelibs/curl/CurlRequest.java

            throw new CurlException("Invalid encoding: " + encoding, e);
        }
    }

    /**
     * Sets the thread pool for executing the request.
     *
     * @param threadPool the thread pool
     * @return this CurlRequest instance
     */
    public CurlRequest threadPool(final ForkJoinPool threadPool) {
        this.threadPool = threadPool;
        return this;

Created: Sat Dec 20 09:13:53 GMT 2025

- Last Modified: Mon Nov 24 03:10:07 GMT 2025

- 18.6K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs/es/docs/tutorial/request-files.md

{* ../../docs_src/request_files/tutorial001_an_py39.py hl[14] *}

Usar `UploadFile` tiene varias ventajas sobre `bytes`:

* No tienes que usar `File()` en el valor por defecto del parámetro.
* Usa un archivo "spooled":
    * Un archivo almacenado en memoria hasta un límite de tamaño máximo, y después de superar este límite, se almacenará en el disco.

Created: Sun Dec 28 07:19:09 GMT 2025

- Last Modified: Tue Dec 16 16:33:45 GMT 2025

- 7.9K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs/zh/docs/tutorial/request-files.md

这种方式把文件的所有内容都存储在内存里，适用于小型文件。

不过，很多情况下，`UploadFile` 更好用。

## 含 `UploadFile` 的文件参数

定义文件参数时使用 `UploadFile`：

{* ../../docs_src/request_files/tutorial001.py hl[12] *}

`UploadFile` 与 `bytes` 相比有更多优势：

* 使用 `spooled` 文件：
    * 存储在内存的文件超出最大上限时，FastAPI 会把文件存入磁盘；
* 这种方式更适于处理图像、视频、二进制文件等大型文件，好处是不会占用所有内存；
* 可获取上传文件的元数据；

Created: Sun Dec 28 07:19:09 GMT 2025

- Last Modified: Mon Nov 18 02:25:44 GMT 2024

- 6.3K bytes

- Click Count (0)

github.com/minio/minio

cmd/bucket-replication.go

		priority:        priority,
		maxWorkers:      maxWorkers,
		maxLWorkers:     maxLWorkers,
	}

	pool.ResizeLrgWorkers(maxLWorkers, 0)
	pool.ResizeWorkers(workers, 0)
	pool.ResizeFailedWorkers(failedWorkers)
	go pool.resyncer.PersistToDisk(ctx, o)
	go pool.processMRF()
	go pool.persistMRF()
	return pool
}

// AddMRFWorker adds a pending/failed replication worker to handle requests that could not be queued

Created: Sun Dec 28 19:28:13 GMT 2025

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

- 118.2K 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 Dec 30 12:39:10 GMT 2025

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

- 2.3K bytes

- Click Count (0)

Search Options