Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 361 for walkers (0.06 seconds)

  1. 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)
  2. 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)
  3. .ci/scripts/run-gradle.sh

       else
          echo "Unsupported OS Type: $OSTYPE"
          exit 1
       fi
    fi
    if pwd | grep -v -q ^/dev/shm ; then
       echo "Not running on a ramdisk, reducing number of workers"
       MAX_WORKERS=$(($MAX_WORKERS*2/3))
    fi
    set -e
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Thu May 13 19:08:52 GMT 2021
    - 824 bytes
    - Click Count (0)
  4. .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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top