Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 164 for workerCh (0.07 seconds)

  1. .idea/gradle.xml

                <option value="$PROJECT_DIR$/platforms/core-execution/scoped-persistent-cache" />
                <option value="$PROJECT_DIR$/platforms/core-execution/snapshots" />
                <option value="$PROJECT_DIR$/platforms/core-execution/worker-main" />
                <option value="$PROJECT_DIR$/platforms/core-execution/workers" />
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Thu Dec 11 18:02:10 GMT 2025
    - 23.2K bytes
    - Click Count (0)
  2. cmd/erasure-server-pool-rebalance.go

    	if err != nil {
    		rebalanceLogIf(ctx, fmt.Errorf("invalid workers value err: %v, defaulting to %d", err, len(pool.sets)))
    		workerSize = len(pool.sets)
    	}
    
    	// Each decom worker needs one List() goroutine/worker
    	// add that many extra workers.
    	workerSize += len(pool.sets)
    
    	wk, err := workers.New(workerSize)
    	if err != nil {
    		return err
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 28.7K bytes
    - Click Count (0)
  3. docs/pt/docs/deployment/docker.md

    E se você precisar ter múltiplos workers, você pode simplesmente usar a opção de linha de comando `--workers`.
    
    /// note | Detalhes Técnicos
    
    A imagem Docker foi criada quando o Uvicorn não suportava gerenciar e reiniciar workers mortos, então era necessário usar o Gunicorn com o Uvicorn, o que adicionava bastante complexidade, apenas para que o Gunicorn gerenciasse e reiniciasse os processos workers do Uvicorn.
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Nov 12 16:23:57 GMT 2025
    - 32.1K bytes
    - Click Count (0)
  4. cmd/batch-handlers.go

    // newBatchJobPool creates a pool of job manifest workers of specified size
    func newBatchJobPool(ctx context.Context, o ObjectLayer, workers int) *BatchJobPool {
    	jpool := &BatchJobPool{
    		ctx:          ctx,
    		objLayer:     o,
    		jobCh:        make(chan *BatchJobRequest, 10000),
    		workerKillCh: make(chan struct{}, workers),
    		jobCancelers: make(map[string]context.CancelFunc),
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 63.5K bytes
    - Click Count (1)
  5. docs/fr/docs/project-generation.md

    * Modèles **SQLAlchemy** (indépendants des extensions Flask, afin qu'ils puissent être utilisés directement avec des *workers* Celery).
    * Modèle de démarrages basiques pour les utilisateurs (à modifier et supprimer au besoin).
    * Migrations **Alembic**.
    * **CORS** (partage des ressources entre origines multiples, ou *Cross Origin Resource Sharing*).
    * *Worker* **Celery** pouvant importer et utiliser les modèles et le code du reste du backend.
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Mon Jul 29 23:35:07 GMT 2024
    - 6.7K bytes
    - Click Count (0)
  6. cmd/batch-rotate.go

    	}
    
    	workerSize, err := strconv.Atoi(env.Get("_MINIO_BATCH_KEYROTATION_WORKERS", strconv.Itoa(runtime.GOMAXPROCS(0)/2)))
    	if err != nil {
    		return err
    	}
    
    	wk, err := workers.New(workerSize)
    	if err != nil {
    		// invalid worker size.
    		return err
    	}
    
    	ctx, cancel := context.WithCancel(ctx)
    
    	results := make(chan itemOrErr[ObjectInfo], 100)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 14.7K bytes
    - Click Count (0)
  7. cmd/batch-expire.go

    	oi, ok := oiCache[fmt.Sprintf("%s-%s", toDel.ObjectName, toDel.VersionID)]
    	return oi, ok
    }
    
    func batchObjsForDelete(ctx context.Context, r *BatchJobExpire, ri *batchJobInfo, job BatchJobRequest, api ObjectLayer, wk *workers.Workers, expireCh <-chan []expireObjInfo) {
    	vc, _ := globalBucketVersioningSys.Get(r.Bucket)
    	retryAttempts := job.Expire.Retry.Attempts
    	if retryAttempts <= 0 {
    		retryAttempts = batchExpireJobDefaultRetries
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Apr 22 11:16:32 GMT 2025
    - 23K bytes
    - Click Count (0)
  8. cmd/erasure-server-pool-decom.go

    	if err != nil {
    		decomLogIf(ctx, fmt.Errorf("invalid workers value err: %v, defaulting to %d", err, len(pool.sets)))
    		workerSize = len(pool.sets)
    	}
    
    	// Each decom worker needs one List() goroutine/worker
    	// add that many extra workers.
    	workerSize += len(pool.sets)
    
    	wk, err := workers.New(workerSize)
    	if err != nil {
    		return err
    	}
    
    	var vc *versioning.Versioning
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 42.2K bytes
    - Click Count (1)
  9. cmd/background-heal-ops.go

    }
    
    func newHealRoutine() *healRoutine {
    	workers := runtime.GOMAXPROCS(0) / 2
    
    	if envHealWorkers := env.Get("_MINIO_HEAL_WORKERS", ""); envHealWorkers != "" {
    		if numHealers, err := strconv.Atoi(envHealWorkers); err != nil {
    			bugLogIf(context.Background(), fmt.Errorf("invalid _MINIO_HEAL_WORKERS value: %w", err))
    		} else {
    			workers = numHealers
    		}
    	}
    
    	if workers == 0 {
    		workers = 4
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  10. docs/zh/docs/deployment/docker.md

    因此,在这种情况下,你**不会**希望拥有像 Gunicorn 和 Uvicorn worker一样的进程管理器,或者 Uvicorn 使用自己的 Uvicorn worker。 你可能希望每个容器(但可能有多个容器)只有一个**单独的 Uvicorn 进程**。
    
    在容器内拥有另一个进程管理器(就像使用 Gunicorn 或 Uvicorn 管理 Uvicorn 工作线程一样)只会增加**不必要的复杂性**,而你很可能已经在集群系统中处理这些复杂性了。
    
    ### 具有多个进程的容器
    
    当然,在某些**特殊情况**,你可能希望拥有 **一个容器**,其中包含 **Gunicorn 进程管理器**,并在其中启动多个 **Uvicorn worker进程**。
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Mon Aug 12 21:47:53 GMT 2024
    - 31.2K bytes
    - Click Count (0)
Back to Top