Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 61 - 70 of 285 for workers (0.05 seconds)

  1. docs/metrics/prometheus/list.md

    | `minio_node_replication_average_active_workers`         | Average number of active replication workers                                                             |
    | `minio_node_replication_max_active_workers`             | Maximum number of active replication workers seen since server start                                     |
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 43.4K bytes
    - Click Count (0)
  2. docs/ja/docs/deployment/docker.md

    この場合、例えばコマンドラインオプションの `--workers` で、コンテナ内に複数のワーカーを持つことは**避けたい**でしょう。**コンテナごとにUvicornのプロセスは1つだけ**にしたいでしょう(おそらく複数のコンテナが必要でしょう)。
    
    (複数のワーカーの場合のように)コンテナ内に別のプロセスマネージャーを持つことは、クラスターシステムですでに対処しているであろう**不要な複雑さ**を追加するだけです。
    
    ### 複数プロセスのコンテナと特殊なケース { #containers-with-multiple-processes-and-special-cases }
    
    もちろん、**特殊なケース**として、**コンテナ**内で複数の**Uvicornワーカープロセス**を起動させたい場合があります。
    
    そのような場合、`--workers` コマンドラインオプションを使って、実行したいワーカー数を設定できます:
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Mar 20 14:07:17 GMT 2026
    - 36.8K bytes
    - Click Count (0)
  3. tensorflow/c/eager/c_api_distributed_test.cc

    // once (i.e., on the main function side) in running distributed functions.
    // This test creates a cluster with two workers, create a variable on the
    // second worker, and run a distributed function (VariableAddFunction) whose ops
    // span the local and remote workers. If the graph optimization pass is executed
    // on both the main function side and the component function side, an error will
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Sat Oct 12 05:11:17 GMT 2024
    - 23.4K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

      /**
       * This counter prevents an ABA issue where a thread may successfully schedule the worker, the
       * worker runs and exhausts the queue, another thread enqueues a task and fails to schedule the
       * worker, and then the first thread's call to delegate.execute() returns. Without this counter,
       * it would observe the QUEUING state and set it to QUEUED, and the worker would never be
       * scheduled again for future submissions.
       */
      @GuardedBy("queue")
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 10.6K bytes
    - Click Count (0)
  5. cmd/config-current.go

    			Description: "manage namespace scanning for usage calculation, lifecycle, healing and more",
    		},
    		config.HelpKV{
    			Key:         config.BatchSubSys,
    			Description: "manage batch job workers and wait times",
    		},
    		config.HelpKV{
    			Key:         config.CompressionSubSys,
    			Description: "enable server side compression of objects",
    		},
    		config.HelpKV{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 28.5K bytes
    - Click Count (0)
  6. docs/metrics/prometheus/grafana/replication/minio-replication-node.json

              "interval": "1m",
              "intervalFactor": 2,
              "legendFormat": "{{server}}",
              "refId": "A"
            }
          ],
          "title": "Avg. Active Workers",
          "type": "timeseries"
        },
        {
          "datasource": {
            "type": "prometheus",
            "uid": "${DS_PROMETHEUS}"
          },
          "fieldConfig": {
            "defaults": {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Aug 04 01:46:49 GMT 2025
    - 57.5K bytes
    - Click Count (0)
  7. 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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 14.7K bytes
    - Click Count (0)
  8. tensorflow/c/eager/c_api_experimental.h

    // EagerService to maintain consistency between client and worker. The
    // context_id is initialized with a dummy value and is later set when the worker
    // is initialized (either locally or remotely). The context_id can change during
    // the process lifetime although this should cause the worker to be
    // reinitialized (e.g. cleared caches) as well.
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Wed Feb 21 22:37:46 GMT 2024
    - 39.5K bytes
    - Click Count (1)
  9. cmd/bucket-stats.go

    			Avg:  (savg + lavg) / float64(count),
    			Curr: (lcurr + scurr) / float64(count),
    			Peak: totpeak,
    		}
    	}
    	return qs
    }
    
    // populate queue totals for node and active workers in use for metrics
    func (r *ReplicationStats) getNodeQueueStatsSummary() (qs ReplQNodeStats) {
    	qs.NodeName = globalLocalNodeName
    	qs.Uptime = UTCNow().Unix() - globalBootTime.Unix()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 13.5K bytes
    - Click Count (0)
  10. 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";
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Feb 24 14:36:23 GMT 2026
    - 35.6K bytes
    - Click Count (0)
Back to Top