Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 127 for coroutines (1.68 sec)

  1. cmd/metrics-v2.go

    		Type:      counterMetric,
    	}
    }
    
    func getMinIOGORoutineCountMD() MetricDescription {
    	return MetricDescription{
    		Namespace: nodeMetricNamespace,
    		Subsystem: goRoutines,
    		Name:      total,
    		Help:      "Total number of go routines running",
    		Type:      gaugeMetric,
    	}
    }
    
    func getMinIOProcessStartTimeMD() MetricDescription {
    	return MetricDescription{
    		Namespace: nodeMetricNamespace,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 133.6K bytes
    - Viewed (0)
  2. docs/metrics/prometheus/grafana/minio-dashboard.json

              "intervalFactor": 1,
              "legendFormat": "{{server}}",
              "metric": "process_start_time_seconds",
              "refId": "A",
              "step": 60
            }
          ],
          "title": "Goroutines",
          "type": "timeseries"
        },
        {
          "datasource": {
            "type": "prometheus",
            "uid": "${DS_PROMETHEUS}"
          },
          "fieldConfig": {
            "defaults": {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Aug 04 01:46:49 UTC 2025
    - 93.1K bytes
    - Viewed (0)
  3. cmd/format-erasure.go

    		g.Go(func() error {
    			if formats[index] == nil {
    				return errDiskNotFound
    			}
    			return saveFormatErasure(storageDisks[index], formats[index], "")
    		}, index)
    	}
    
    	// Wait for the routines to finish.
    	return reduceWriteQuorumErrs(ctx, g.Wait(), nil, len(storageDisks))
    }
    
    // relinquishes the underlying connection for all storage disks.
    func closeStorageDisks(storageDisks ...StorageAPI) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 23.1K bytes
    - Viewed (0)
  4. cmd/admin-heal-ops.go

    	}
    
    	if h.clientToken == bgHealingUUID {
    		// For background heal do nothing, do not spawn an unnecessary goroutine.
    	} else {
    		// Launch top-level background heal go-routine
    		go h.healSequenceStart(objAPI)
    	}
    
    	b, err := json.Marshal(madmin.HealStartSuccess{
    		ClientToken:   clientToken,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  5. docs/metrics/prometheus/list.md

    | `minio_node_file_descriptor_open_total`    | Total number of open file descriptors by the MinIO Server process.                                              |
    | `minio_node_go_routine_total`              | Total number of go routines running.                                                                            |
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 43.4K bytes
    - Viewed (0)
  6. docs/zh-hant/docs/async.md

    ## 協程
    
    **協程** 只是 `async def` 函式所回傳的非常特殊的事物名稱。Python 知道它是一個類似函式的東西,可以啟動它,並且在某個時刻它會結束,但它也可能在內部暫停 ⏸,只要遇到 `await`。
    
    這種使用 `async` 和 `await` 的非同步程式碼功能通常被概括為「協程」。這與 Go 語言的主要特性「Goroutines」相似。
    
    ## 結論
    
    讓我們再次回顧之前的句子:
    
    > 現代版本的 Python 支持使用 **"協程"** 的 **`async` 和 `await`** 語法來寫 **"非同步程式碼"**。
    
    現在應該能明白其含意了。✨
    
    這些就是驅動 FastAPI(通過 Starlette)運作的原理,也讓它擁有如此驚人的效能。
    
    ## 非常技術性的細節
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sun Aug 31 09:56:21 UTC 2025
    - 21.1K bytes
    - Viewed (0)
  7. docs/zh/docs/async.md

    ## 协程
    
    **协程**只是 `async def` 函数返回的一个非常奇特的东西的称呼。Python 知道它有点像一个函数,它可以启动,也会在某个时刻结束,而且它可能会在内部暂停 ⏸ ,只要内部有一个 `await`。
    
    通过使用 `async` 和 `await` 的异步代码的所有功能大多数被概括为"协程"。它可以与 Go 的主要关键特性 "Goroutines" 相媲美。
    
    ## 结论
    
    让我们再来回顾下上文所说的:
    
    > Python 的现代版本可以通过使用 `async` 和 `await` 语法创建**协程**,并用于支持**异步代码**。
    
    现在应该能明白其含义了。✨
    
    所有这些使得 FastAPI(通过 Starlette)如此强大,也是它拥有如此令人印象深刻的性能的原因。
    
    ## 非常技术性的细节
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sun Aug 31 09:56:21 UTC 2025
    - 21.5K bytes
    - Viewed (0)
  8. internal/ringbuffer/ring_buffer_test.go

    	go func() {
    		select {
    		case <-cc:
    			return
    		case <-c:
    			buf := make([]byte, 1<<20)
    			stacklen := runtime.Stack(buf, true)
    			fmt.Printf("=== Timeout, assuming deadlock ===\n*** goroutine dump...\n%s\n*** end\n", string(buf[:stacklen]))
    			os.Exit(2)
    		}
    	}()
    	return func() {
    		close(cc)
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 26.7K bytes
    - Viewed (0)
  9. internal/grid/grid_test.go

    	go func() {
    		select {
    		case <-cc:
    			return
    		case <-c:
    			buf := make([]byte, 1<<20)
    			stacklen := runtime.Stack(buf, true)
    			fmt.Printf("=== Timeout, assuming deadlock ===\n*** goroutine dump...\n%s\n*** end\n", string(buf[:stacklen]))
    			os.Exit(2)
    		}
    	}()
    	return func() {
    		close(cc)
    	}
    }
    
    func assertNoActive(t *testing.T, c *Connection) {
    	t.Helper()
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 36.1K bytes
    - Viewed (0)
  10. 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
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 42.2K bytes
    - Viewed (1)
Back to top