- Sort Score
- Num 10 results
- Language All
Results 31 - 40 of 361 for walkers (0.05 seconds)
-
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,
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 12K bytes - Click Count (0) -
docs/en/docs/deployment/docker.md
So, in this case, you **would not** want to have a multiple workers in the container, for example with the `--workers` command line option. You would want to have just a **single Uvicorn process** per container (but probably multiple containers).
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 05 18:13:19 GMT 2026 - 28.3K bytes - Click Count (1) -
.ci/scripts/run-gradle.sh
Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Thu May 13 19:08:52 GMT 2021 - 824 bytes - Click Count (0) -
.teamcity/test-buckets.json
"platform-native", "plugin-development", "plugins-groovy", "plugins-java", "samples", "testing-native", "version-control", "workers" ], "parallelizationMethod": { "name": "TestDistribution" } } ] }, { "testCoverageUuid": 2, "buckets": [ {Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Mon Mar 23 18:38:15 GMT 2026 - 118.6K bytes - Click Count (0) -
docs/es/docs/deployment/docker.md
Así que, en este caso, **no** querrías tener múltiples workers en el contenedor, por ejemplo, con la opción de línea de comandos `--workers`. Querrías tener solo un **proceso Uvicorn por contenedor** (pero probablemente múltiples contenedores).
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:15:55 GMT 2026 - 30.8K bytes - Click Count (0) -
internal/event/targetlist.go
return } } }() } wk.Wait() } var startOnce sync.Once // Init initialize target send workers. func (list *TargetList) Init(workers int) *TargetList { startOnce.Do(func() { go list.startSendWorkers(workers) }) return list } // NewTargetList - creates TargetList. func NewTargetList(ctx context.Context) *TargetList { list := &TargetList{
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 9.2K bytes - Click Count (0) -
internal/config/errors.go
"Invalid value for replication workers", "", "MINIO_API_REPLICATION_WORKERS: should be > 0", ) ErrInvalidTransitionWorkersValue = newErrFn( "Invalid value for transition workers", "", "MINIO_API_TRANSITION_WORKERS: should be >= GOMAXPROCS/2", ) ErrInvalidBatchKeyRotationWorkersWait = newErrFn( "Invalid value for batch key rotation workers wait", "Please input a non-negative duration",
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 9.4K bytes - Click Count (0) -
docs/fr/docs/deployment/concepts.md
Dans cet exemple, il y a un **processus gestionnaire** qui démarre et contrôle deux **processus workers**. Ce processus gestionnaire serait probablement celui qui écoute sur le **port** de l'IP. Et il transmettrait toute la communication aux processus workers.
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:37:13 GMT 2026 - 21.4K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Monitor.java
int waiters = guard.waiterCount++; if (waiters == 0) { // push guard onto activeGuards guard.next = activeGuards; activeGuards = guard; } } /** Records that the current thread is no longer waiting on the specified guard. */ @GuardedBy("lock") private void endWaitingFor(Guard guard) { int waiters = --guard.waiterCount;Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Jan 28 22:39:02 GMT 2026 - 43.5K bytes - Click Count (0) -
cmd/bucket-replication-stats.go
sync.RWMutex // mutex for Cache mostRecentStatsMu sync.Mutex // mutex for mostRecentStats wlock sync.RWMutex // mutex for active workers movingAvgTicker *time.Ticker // Ticker for calculating moving averages wTimer *time.Ticker // ticker for calculating active workers qTimer *time.Ticker // ticker for calculating queue stats } func (r *ReplicationStats) trackEWMA() { for { select {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 13.6K bytes - Click Count (0)