- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 350 for worker (0.09 sec)
-
cmd/bucket-replication-stats.go
type ReplicationStats struct { // map of site deployment ID to site replication status // for site replication - maintain stats at global level srStats *SRStats // active worker stats workers *ActiveWorkerStat // queue stats cache qCache queueCache pCache proxyStatsCache // mrf backlog stats mrfStats ReplicationMRFStats // for bucket replication, continue to use existing cache
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 13.6K bytes - Viewed (0) -
cmd/bucket-replication.go
if (checkOld > 0 && len(p.workers) != checkOld) || n == len(p.workers) || n < 1 { // Either already satisfied or worker count changed while we waited for the lock. return } for len(p.workers) < n { input := make(chan ReplicationWorkerOperation, 10000) p.workers = append(p.workers, input) go p.AddWorker(input, &p.activeWorkers) } for len(p.workers) > n { worker := p.workers[len(p.workers)-1]
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 118K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java
* Run the service. This method is invoked on the execution thread. Implementations must respond * to stop requests. You could poll for lifecycle changes in a work loop: * * <pre> * public void run() { * while ({@link #isRunning()}) { * // perform a unit of work * } * } * </pre> * * <p>...or you could respond to stop requests by implementing {@link #triggerShutdown()}, which
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 7.5K bytes - Viewed (0) -
android/guava/src/com/google/common/net/HttpHeaders.java
public static final String UNSAFE_URL = "unsafe-url"; } /** * The HTTP <a href="https://www.w3.org/TR/service-workers/#update-algorithm">{@code * Service-Worker}</a> header field name. * * @since 20.0 */ public static final String SERVICE_WORKER = "Service-Worker"; /** The HTTP {@code TE} header field name. */ public static final String TE = "TE";
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Mar 27 20:37:16 UTC 2025 - 35.4K bytes - Viewed (0) -
docs/de/docs/project-generation.md
### Full Stack FastAPI PostgreSQL – Funktionen * Vollständige **Docker**-Integration (Docker-basiert). * Docker-Schwarmmodus-Deployment. * **Docker Compose**-Integration und Optimierung für die lokale Entwicklung. * **Produktionsbereit** Python-Webserver, verwendet Uvicorn und Gunicorn.
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Mon Jul 29 23:35:07 UTC 2024 - 6.5K bytes - Viewed (0) -
okhttp/src/androidMain/baseline-prof.txt
HSPLkotlinx/coroutines/scheduling/CoroutineScheduler$Worker;->nextInt(I)I HSPLkotlinx/coroutines/scheduling/CoroutineScheduler$Worker;->pollGlobalQueues()Lkotlinx/coroutines/scheduling/Task; HSPLkotlinx/coroutines/scheduling/CoroutineScheduler$Worker;->run()V HSPLkotlinx/coroutines/scheduling/CoroutineScheduler$Worker;->setIndexInArray(I)V HSPLkotlinx/coroutines/scheduling/CoroutineScheduler$Worker;->setNextParkedWorker(Ljava/lang/Object;)V
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Dec 30 23:28:56 UTC 2024 - 127.9K bytes - Viewed (0) -
kotlin-js-store/yarn.lock
integrity sha512-WhB9zCku7EGTj/HQQRz5aUQEUeoQZH2bWcltRErOpymJ4boYE6wL9Tbr23krRPSZ+C5zqNSrSw+Cc7sZZ4b7vg== jest-worker@^27.4.5: version "27.5.1" resolved "https://registry.yarnpkg.com/jest-worker/-/jest-worker-27.5.1.tgz#8d146f0900e8973b106b6f73cc1e9a8cb86f8db0" integrity sha512-7vuh85V5cdDofPyxn58nrPjBktZo0u9x1g8WtjQol+jZDaE+fhN+cIvTj11GndBnMnyfrUOG1sZQxCdjKh+DKg== dependencies:
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Jul 22 12:28:51 UTC 2023 - 87.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java
* Run the service. This method is invoked on the execution thread. Implementations must respond * to stop requests. You could poll for lifecycle changes in a work loop: * * <pre> * public void run() { * while ({@link #isRunning()}) { * // perform a unit of work * } * } * </pre> * * <p>...or you could respond to stop requests by implementing {@link #triggerShutdown()}, which
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 7.2K bytes - Viewed (0) -
docs/de/docs/deployment/docker.md
## Offizielles Docker-Image mit Gunicorn – Uvicorn Es gibt ein offizielles Docker-Image, in dem Gunicorn mit Uvicorn-Workern ausgeführt wird, wie in einem vorherigen Kapitel beschrieben: [Serverworker – Gunicorn mit Uvicorn](server-workers.md){.internal-link target=_blank}.
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sat Nov 09 16:39:20 UTC 2024 - 38.9K bytes - Viewed (0) -
cmd/data-scanner_test.go
t.Run(fmt.Sprintf("TestApplyNewerNoncurrentVersionsLimit-%d", i), func(t *testing.T) { workers := []chan expiryOp{make(chan expiryOp)} es.workers.Store(&workers) workerReady := make(chan struct{}) var wg sync.WaitGroup wg.Add(1) var gotExpired []ObjectToDelete go expiryWorker(&wg, workerReady, workers[0], &gotExpired) <-workerReady item := scannerItem{ Path: obj,
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 12K bytes - Viewed (0)