Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 103 for goroutines (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. internal/lsync/lrwmutex_test.go

    	}
    	// Wait for all parallel RLock()s to succeed.
    	for range numReaders {
    		<-clocked
    	}
    	for range numReaders {
    		cunlock <- true
    	}
    	// Wait for the goroutines to finish.
    	for range numReaders {
    		<-cdone
    	}
    }
    
    // Borrowed from rwmutex_test.go
    func TestParallelReaders(t *testing.T) {
    	defer runtime.GOMAXPROCS(runtime.GOMAXPROCS(-1))
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  2. src/bytes/reader_test.go

    		}(i)
    	}
    	wg.Wait()
    }
    
    func TestEmptyReaderConcurrent(t *testing.T) {
    	// Test for the race detector, to verify a Read that doesn't yield any bytes
    	// is okay to use from multiple goroutines. This was our historic behavior.
    	// See golang.org/issue/7856
    	r := NewReader([]byte{})
    	var wg sync.WaitGroup
    	for i := 0; i < 5; i++ {
    		wg.Add(2)
    		go func() {
    			defer wg.Done()
    			var buf [1]byte
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon Dec 13 18:45:54 GMT 2021
    - 8K bytes
    - Click Count (0)
  3. cmd/utils.go

    			return buf.Bytes(), err
    		}
    	case madmin.ProfilerGoroutines:
    		prof.ext = "txt"
    		prof.record("goroutine", 1, "before")
    		prof.record("goroutine", 2, "before,debug=2")
    		prof.stopFn = func() ([]byte, error) {
    			var buf bytes.Buffer
    			err := pprof.Lookup("goroutine").WriteTo(&buf, 1)
    			return buf.Bytes(), err
    		}
    	case madmin.ProfilerTrace:
    		dirPath, err := os.MkdirTemp("", "profile")
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 33K bytes
    - Click Count (0)
  4. docs/ru/docs/async.md

    ## Заключение { #conclusion }
    
    Вернёмся к той же фразе:
    
    > Современные версии Python поддерживают **«асинхронный код»** с помощью **«сопрограмм»** (coroutines) и синтаксиса **`async` и `await`**.
    
    Теперь это должно звучать понятнее. ✨
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Tue Sep 30 11:24:39 GMT 2025
    - 38.5K bytes
    - Click Count (0)
  5. docs/en/docs/async.md

    ## Conclusion { #conclusion }
    
    Let's see the same phrase from above:
    
    > Modern versions of Python have support for **"asynchronous code"** using something called **"coroutines"**, with **`async` and `await`** syntax.
    
    That should make more sense now. ✨
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sun Aug 31 09:56:21 GMT 2025
    - 24K bytes
    - Click Count (0)
  6. docs/fr/docs/async.md

    ## Conclusion
    
    Reprenons la phrase du début de la page :
    
    > Les versions modernes de Python supportent le **code asynchrone** grâce aux **"coroutines"** avec les syntaxes **`async` et `await`**.
    
    Ceci devrait être plus compréhensible désormais. ✨
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sun Aug 31 09:56:21 GMT 2025
    - 25.4K bytes
    - Click Count (0)
  7. 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
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 32.5K bytes
    - Click Count (3)
  8. cmd/bucket-lifecycle.go

    	res := make(DailyAllTierStats, len(t.lastDayStats))
    	for tier, st := range t.lastDayStats {
    		res[tier] = st.clone()
    	}
    	return res
    }
    
    // UpdateWorkers at the end of this function leaves n goroutines waiting for
    // transition tasks
    func (t *transitionState) UpdateWorkers(n int) {
    	t.mu.Lock()
    	defer t.mu.Unlock()
    	if t.objAPI == nil { // Init hasn't been called yet.
    		return
    	}
    	t.updateWorkers(n)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 33.7K bytes
    - Click Count (0)
  9. 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": {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Aug 04 01:46:49 GMT 2025
    - 93.1K bytes
    - Click Count (0)
  10. 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"
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 133.6K bytes
    - Click Count (0)
Back to Top