Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 36 for go_routine (0.04 sec)

  1. internal/dsync/dsync_test.go

    	// non-profitable and allows to confirm that spinning does not do harm.
    	// To achieve this we create excess of goroutines most of which do local work.
    	// These goroutines yield during local work, so that switching from
    	// a blocked goroutine to other goroutines is profitable.
    	// As a matter of fact, this benchmark still triggers some spinning in the mutex.
    	m := NewDRWMutex(ds, "")
    	var acc0, acc1 uint64
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  2. 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")
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 33K bytes
    - Viewed (0)
  3. docs/tr/docs/async.md

    ## Coroutine'ler
    
    **Coroutine**, bir `async def` fonksiyonu tarafından döndürülen değer için çok süslü bir terimdir. Python bunun bir fonksiyon gibi bir noktada başlayıp biteceğini bilir, ancak içinde bir `await` olduğunda dahili olarak da duraklatılabilir ⏸.
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sun Aug 31 09:56:21 UTC 2025
    - 21.8K bytes
    - Viewed (0)
  4. internal/lru/lru.go

    	for i := 0; i < numBuckets; i++ {
    		res.buckets[i] = bucket[K, V]{entries: make(map[K]*Entry[K, V])}
    	}
    
    	// enable deleteExpired() running in separate goroutine for cache with non-zero TTL
    	//
    	// Important: done channel is never closed, so deleteExpired() goroutine will never exit,
    	// it's decided to add functionality to close it in the version later than v2.
    	if res.ttl != noEvictionTTL {
    		go func(done <-chan struct{}) {
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Fri Apr 25 08:22:26 UTC 2025
    - 12.5K bytes
    - Viewed (0)
  5. cmd/erasure.go

    			bucketCh <- b
    		}
    	}
    	xioutil.SafeClose(bucketCh)
    
    	bucketResults := make(chan dataUsageEntryInfo, len(disks))
    
    	// Start async collector/saver.
    	// This goroutine owns the cache.
    	var saverWg sync.WaitGroup
    	saverWg.Add(1)
    	go func() {
    		// Add jitter to the update time so multiple sets don't sync up.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  6. cmd/notification.go

    // returns the slice of errors from all function calls.
    func (g *NotificationGroup) Wait() []NotificationPeerErr {
    	g.workers.Wait()
    	return g.errs
    }
    
    // Go calls the given function in a new goroutine.
    //
    // The first call to return a non-nil error will be
    // collected in errs slice and returned by Wait().
    func (g *NotificationGroup) Go(ctx context.Context, f func() error, index int, addr xnet.Host) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 46K bytes
    - Viewed (0)
  7. docs/ru/docs/async.md

    Часто всю функциональность использования асинхронного кода с `async` и `await` кратко называют «сопрограммами». Это сопоставимо с ключевой особенностью Go — «goroutines».
    
    ## Заключение { #conclusion }
    
    Вернёмся к той же фразе:
    
    > Современные версии Python поддерживают **«асинхронный код»** с помощью **«сопрограмм»** (coroutines) и синтаксиса **`async` и `await`**.
    
    Теперь это должно звучать понятнее. ✨
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Tue Sep 30 11:24:39 UTC 2025
    - 38.5K bytes
    - Viewed (0)
  8. schema/schema.go

    	}
    
    	// Load exist schema cache, return if exists
    	if v, ok := cacheStore.Load(schemaCacheKey); ok {
    		s := v.(*Schema)
    		// Wait for the initialization of other goroutines to complete
    		<-s.initialized
    		return s, s.err
    	}
    
    	var tableName string
    	modelValue := reflect.New(modelType)
    	if specialTableName != "" {
    		tableName = specialTableName
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Fri Oct 31 12:13:56 UTC 2025
    - 13.1K bytes
    - Viewed (0)
  9. docs/fr/docs/async.md

    Mais toutes ces fonctionnalités d'utilisation de code asynchrone avec `async` et `await` sont souvent résumées comme l'utilisation des *coroutines*. On peut comparer cela à la principale fonctionnalité clé de Go, les "Goroutines".
    
    ## 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`**.
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sun Aug 31 09:56:21 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  10. internal/rest/client.go

    		sleep := min(unit*time.Duration(1<<attempt), maxSleep)
    		sleep -= time.Duration(r.Float64() * float64(sleep-unit))
    		return sleep
    	}
    }
    
    func (c *Client) runHealthCheck() bool {
    	// Start goroutine that will attempt to reconnect.
    	// If server is already trying to reconnect this will have no effect.
    	if c.HealthCheckFn != nil && atomic.CompareAndSwapInt32(&c.connected, online, offline) {
    		go func() {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 14.7K bytes
    - Viewed (0)
Back to top