- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 198 for spool (0.02 sec)
-
docs/contribute/concurrency.md
## Connection Pool A primary responsibility for any HTTP client is to efficiently manage network connections. Creating and establishing new connections require a fair amount of overhead and added latency. OkHttp will make every effort to reuse existing connections to avoid this overhead and added latency.
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Feb 06 16:35:36 UTC 2022 - 7K bytes - Viewed (0) -
docs/distributed/CONFIG.md
``` ### Things to know - Fields such as `version` and `pools` are mandatory, however all other fields are optional. - Each pool expects a minimum of 2 nodes per pool, and unique non-repeating hosts for each argument. - Each pool expects each host in this pool has the same number of drives specified as any other host.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jun 25 02:30:18 UTC 2024 - 4.2K bytes - Viewed (0) -
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 Nov 05 12:39:12 UTC 2024 - Last Modified: Tue Sep 24 20:45:58 UTC 2024 - 8K bytes - Viewed (0) -
cmd/metacache-set_gen.go
case "StopDiskAtLimit": z.StopDiskAtLimit, err = dc.ReadBool() if err != nil { err = msgp.WrapError(err, "StopDiskAtLimit") return } case "pool": z.pool, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "pool") return } case "set": z.set, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "set") return } default:
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Mar 19 20:23:12 UTC 2024 - 13.8K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/helper/CrawlingInfoHelperTest.java
final ForkJoinPool pool = new ForkJoinPool(10); for (int i = 0; i < 1000; i++) { pool.execute(() -> { assertEquals(result, crawlingInfoHelper.generateId(dataMap)); counter.incrementAndGet(); }); } pool.shutdown(); pool.awaitTermination(10, TimeUnit.SECONDS);
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 8.5K bytes - Viewed (0) -
internal/jwt/parser.go
return HashBorrower{pool: &s.HasherPool, borrowed: make([]hash.Hash, 0, 2)} } // HashBorrower keeps track of borrowed hashers and allows to return them all. type HashBorrower struct { pool *sync.Pool borrowed []hash.Hash } // Borrow a single hasher. func (h *HashBorrower) Borrow() hash.Hash { hasher := h.pool.Get().(hash.Hash) h.borrowed = append(h.borrowed, hasher)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 17 16:45:46 UTC 2024 - 14.1K bytes - Viewed (0) -
cmd/metacache-marker.go
continue } case "id": o.ID = kv[1] case "return": o.ID = mustGetUUID() o.Create = true case "p": // pool v, err := strconv.ParseInt(kv[1], 10, 64) if err != nil { o.ID = mustGetUUID() o.Create = true continue } o.pool = int(v) case "s": // set v, err := strconv.ParseInt(kv[1], 10, 64) if err != nil { o.ID = mustGetUUID() o.Create = true
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 2.5K bytes - Viewed (0) -
fastapi/concurrency.py
) -> AsyncGenerator[_T, None]: # blocking __exit__ from running waiting on a free thread # can create race conditions/deadlocks if the context manager itself # has its own internal pool (e.g. a database connection pool) # to avoid this we let __exit__ run without a capacity limit # since we're creating a new limiter for each call, any non-zero limit # works (1 is arbitrary) exit_limiter = CapacityLimiter(1)
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Mon Dec 25 17:57:35 UTC 2023 - 1.4K bytes - Viewed (0) -
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 Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 14 22:50:54 UTC 2024 - 7.9K bytes - Viewed (0) -
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 Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 7.7K bytes - Viewed (0)