Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 88 for Coroutine (0.06 sec)

  1. src/main/java/jcifs/smb1/netbios/NameServiceClient.java

                throw new UnknownHostException(name.name);
            }
    
            /* If a target address to query was not specified explicitly
             * with the addr parameter we fall into this resolveOrder routine.
             */
    
            for (final int element : resolveOrder) {
                try {
                    switch (element) {
                    case RESOLVER_LMHOSTS:
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 17.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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Aug 04 01:46:49 UTC 2025
    - 93.1K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb/SmbResourceLocatorImpl.java

            final char[] out = new char[in.length];
            final int length = in.length;
            int prefixLen = 0, state = 0;
    
            /*
             * The canonicalization routine
             */
            for (int i = 0; i < length; i++) {
                switch (state) {
                case 0:
                    if (in[i] != '/') {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 23.6K bytes
    - Viewed (0)
  4. cmd/storage-rest-server.go

    				globalLocalSetDrives[endpoint.PoolIdx][endpoint.SetIdx][endpoint.DiskIdx] = storage
    				return true
    			}
    
    			if createStorage(endpoint) {
    				continue
    			}
    
    			// Start async goroutine to create storage.
    			go func(endpoint Endpoint) {
    				for {
    					time.Sleep(3 * time.Second)
    					if createStorage(endpoint) {
    						return
    					}
    				}
    			}(endpoint)
    		}
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 45.7K bytes
    - Viewed (0)
  5. src/main/java/jcifs/util/transport/Transport.java

                    this.state = 6;
                    ioe = ioe0;
                }
            case 4: /* failed to connect - reset the transport */
                // thread is cleaned up by connect routine, joining it here causes a deadlock
                this.thread = null;
                this.state = 6;
                break;
            default:
                log.error("Invalid state: " + this.state);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 27.8K bytes
    - Viewed (0)
  6. cmd/metrics-v2.go

    	cpuSubsystem              MetricSubsystem = "cpu_avg"
    	storageClassSubsystem     MetricSubsystem = "storage_class"
    	fileDescriptorSubsystem   MetricSubsystem = "file_descriptor"
    	goRoutines                MetricSubsystem = "go_routine"
    	ioSubsystem               MetricSubsystem = "io"
    	nodesSubsystem            MetricSubsystem = "nodes"
    	objectsSubsystem          MetricSubsystem = "objects"
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 133.4K bytes
    - Viewed (0)
  7. docs/zh-hant/docs/async.md

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

    * Version-guard Kubectl client Guestbook application test against deployments ([#24478](https://github.com/kubernetes/kubernetes/pull/24478), [@ihmccreery](https://github.com/ihmccreery))
    * Fix goroutine leak in ssh-tunnel healthcheck. ([#24487](https://github.com/kubernetes/kubernetes/pull/24487), [@cjcullen](https://github.com/cjcullen))
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Fri Dec 04 06:36:19 UTC 2020
    - 41.4K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

          V value = entry.getValue();
          if (value == null) {
            tryDrainReferenceQueues();
            return null;
          }
    
          return value;
        }
    
        /**
         * Performs routine cleanup following a read. Normally cleanup happens during writes, or from
         * the cleanupExecutor. If cleanup is not observed after a sufficient number of reads, try
         * cleaning up from the read thread.
         */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 90K bytes
    - Viewed (0)
  10. cmd/erasure-multipart.go

    		g.Go(func() error {
    			_ = storageDisks[index].DeleteBulk(ctx, minioMetaMultipartBucket, paths...)
    			return nil
    		}, index)
    	}
    	g.Wait()
    }
    
    // Clean-up the old multipart uploads. Should be run in a Go routine.
    func (er erasureObjects) cleanupStaleUploads(ctx context.Context) {
    	// run multiple cleanup's local to this server.
    	var wg sync.WaitGroup
    	for _, disk := range er.getLocalDisks() {
    		if disk != nil {
    			wg.Add(1)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
Back to top