Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 96 for go_routine (0.42 sec)

  1. cmd/common-main.go

    // Cancellation/timeouts are removed, so parent cancellations/timeout will
    // not propagate from parent.
    // Context values are preserved.
    // This can be used for goroutines that live beyond the parent context.
    func bgContext(parent context.Context) context.Context {
    	return bgCtx{parent: parent}
    }
    
    type bgCtx struct {
    	parent context.Context
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 31.7K bytes
    - Viewed (0)
  2. doc/asm.html

    </p>
    
    <h3 id="arm">ARM</h3>
    
    <p>
    The registers <code>R10</code> and <code>R11</code>
    are reserved by the compiler and linker.
    </p>
    
    <p>
    <code>R10</code> points to the <code>g</code> (goroutine) structure.
    Within assembler source code, this pointer must be referred to as <code>g</code>;
    the name <code>R10</code> is not recognized.
    </p>
    
    <p>
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Nov 28 19:15:27 UTC 2023
    - 36.3K bytes
    - Viewed (0)
  3. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 14:51:03 UTC 2024
    - 93K bytes
    - Viewed (0)
  4. cmd/admin-heal-ops.go

    		clientToken = fmt.Sprintf("%s:%d", h.clientToken, GetProxyEndpointLocalIndex(globalProxyEndpoints))
    	}
    
    	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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  5. CHANGELOG.md

     *  Fix: Honor `RequestBody.isOneShot()` in `MultipartBody`
    
     *  Fix in `okhttp-coroutines`: Don't leak response bodies in `executeAsync()`. We had a bug where
        we didn't call `Response.close()` if the coroutine was canceled before its response was
        returned.
    
     *  Upgrade: [Okio 3.9.0][okio_3_9_0].
    
     *  Upgrade: [Kotlin 1.9.23][kotlin_1_9_23].
    
     *  Upgrade: [Unicode® IDNA 15.1.0][idna_15_1_0]
    
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 18 01:31:39 UTC 2024
    - 21.4K bytes
    - Viewed (0)
  6. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  7. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  8. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  9. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  10. docs/zh/docs/async.md

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