- Sort Score
- Num 10 results
- Language All
Results 231 - 240 of 285 for workers (0.04 seconds)
-
guava-tests/test/com/google/common/collect/QueuesTest.java
@Override public void setUp() { threadPool = newCachedThreadPool(); } @Override public void tearDown() throws InterruptedException { threadPool.shutdown(); assertTrue("Some worker didn't finish in time", threadPool.awaitTermination(10, SECONDS)); } private static <T> int drain( BlockingQueue<T> q, Collection<? super T> buffer, int numElements, long timeout,
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Nov 04 17:24:58 GMT 2025 - 12.6K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/storage/S3StorageClient.java
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Dec 13 02:21:17 GMT 2025 - 10.9K bytes - Click Count (0) -
internal/bucket/replication/rule.go
// Status represents Enabled/Disabled status type Status string // Supported status types const ( Enabled Status = "Enabled" Disabled Status = "Disabled" ) // DeleteMarkerReplication - whether delete markers are replicated - https://docs.aws.amazon.com/AmazonS3/latest/dev/replication-add-config.html type DeleteMarkerReplication struct { Status Status `xml:"Status"` // should be set to "Disabled" by default }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 8.3K bytes - Click Count (0) -
android/guava/src/com/google/common/graph/ValueGraphBuilder.java
* with user-defined properties. * * <p>A {@code ValueGraph} built by this class has the following default properties: * * <ul> * <li>does not allow self-loops * <li>orders {@link ValueGraph#nodes()} in the order in which the elements were added (insertion * order) * </ul> * * <p>{@code ValueGraph}s built by this class also guarantee that each collection-returning accessorCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Apr 02 14:49:41 GMT 2026 - 7.8K bytes - Click Count (0) -
tensorflow/c/c_api_experimental.h
TF_CAPI_EXPORT extern void TFE_AbortCollectiveOps(TFE_Context* ctx, TF_Status* status); // Checks the health of collective ops peers. Explicit health check is needed in // multi worker collective ops to detect failures in the cluster. If a peer is // down, collective ops may hang. TF_CAPI_EXPORT extern void TFE_CollectiveOpsCheckPeerHealth( TFE_Context* ctx, const char* task, int64_t timeout_in_ms,
Created: Tue Apr 07 12:39:13 GMT 2026 - Last Modified: Thu Apr 27 21:07:00 GMT 2023 - 15.1K bytes - Click Count (0) -
docs/distributed/decom-encrypted-kes.sh
./mc encrypt set sse-kms minio-default-key myminio/versioned-1 ./mc mirror internal myminio/versioned/ --quiet >/dev/null ./mc mirror internal myminio/versioned-1/ --quiet >/dev/null ## Soft delete (creates delete markers) ./mc rm -r --force myminio/versioned >/dev/null ./mc rm -r --force myminio/versioned-1 >/dev/null ## mirror again to create another set of version on top ./mc mirror internal myminio/versioned/ --quiet >/dev/null
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Mon May 27 19:17:46 GMT 2024 - 7.1K bytes - Click Count (1) -
pyproject.toml
module = "docs_src.*" disallow_incomplete_defs = false disallow_untyped_defs = false disallow_untyped_calls = false [tool.pytest] minversion = "9.0" addopts = [ "--strict-config", "--strict-markers", "--ignore=docs_src", ] strict_xfail = true filterwarnings = [ "error", ] timeout = "20" [tool.coverage.run] parallel = true data_file = "coverage/.coverage" source = [Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Mon Mar 23 12:36:49 GMT 2026 - 10.3K bytes - Click Count (0) -
src/main/java/jcifs/smb/MultiChannelManager.java
// Create thread pools this.channelExecutor = Executors.newCachedThreadPool(r -> { Thread t = new Thread(r, "SMB3-MultiChannel-Worker"); t.setDaemon(true); return t; }); this.healthCheckExecutor = Executors.newScheduledThreadPool(2, r -> {Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 20.5K bytes - Click Count (0) -
docs/de/docs/python-types.md
### Es bearbeiten { #edit-it } Es ist ein sehr einfaches Programm. Aber nun stellen Sie sich vor, Sie würden es selbst schreiben. Irgendwann sind die Funktions-Parameter fertig, Sie starten mit der Definition des Körpers ... Aber dann müssen Sie „diese Methode aufrufen, die den ersten Buchstaben in Großbuchstaben umwandelt“. War es `upper`? War es `uppercase`? `first_uppercase`? `capitalize`?Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 17:58:09 GMT 2026 - 12.6K bytes - Click Count (1) -
docs/zh-hant/docs/_llm-test.md
* 效能優化 * 回傳型別 * 回傳值 * 安全性 * 安全性機制 * 任務 * 背景任務 * 任務函式 * 樣板 * 樣板引擎 * 型別註解 * 型別提示 * 伺服器工作進程 * Uvicorn 工作進程 * Gunicorn 工作進程 * 工作進程 * worker 類別 * 工作負載 * 部署 * 部署 * SDK * 軟體開發工具組 * `APIRouter` * `requirements.txt` * Bearer Token * 相容性破壞變更 * 錯誤 * 按鈕 * 可呼叫對象 * 程式碼 * 提交 * 情境管理器 * 協程
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Fri Mar 20 17:05:38 GMT 2026 - 10K bytes - Click Count (0)