Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 68 for goroutines (0.06 seconds)

  1. cmd/leak-detect_test.go

    		for _, g := range leaked {
    			t.Errorf("Leaked goroutine: %v", g)
    		}
    		return
    	}
    }
    
    // DetectTestLeak -  snapshots the currently running goroutines and returns a
    // function to be run at the end of tests to see whether any
    // goroutines leaked.
    // Usage: `defer DetectTestLeak(t)()` in beginning line of benchmarks or unit tests.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 5.2K bytes
    - Click Count (0)
  2. 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
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  3. 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
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Fri Oct 31 12:13:56 GMT 2025
    - 13.1K bytes
    - Click Count (0)
  4. internal/dsync/drwmutex_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
    - 9.4K bytes
    - Click Count (0)
  5. 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)
  6. docs/tr/docs/async.md

    ## Teknik Detaylar
    
    Python'un modern versiyonlarında **`async` ve `await`** sözdizimi ile **"coroutines"**  kullanan **"asenkron kod"** desteğine sahiptir.
    
    Bu ifadeyi aşağıdaki bölümlerde daha da ayrıntılı açıklayalım:
    
    * **Asenkron kod**
    * **`async` ve `await`**
    * **Coroutines**
    
    ## Asenkron kod
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sun Aug 31 09:56:21 GMT 2025
    - 21.8K bytes
    - Click Count (0)
  7. 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)
  8. 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)
  9. 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)
  10. docs/es/docs/async.md

    ## Conclusión { #conclusion }
    
    Veamos la misma frase de arriba:
    
    > Las versiones modernas de Python tienen soporte para **"código asíncrono"** utilizando algo llamado **"coroutines"**, con la sintaxis **`async` y `await`**.
    
    Eso debería tener más sentido ahora. ✨
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 10:15:01 GMT 2025
    - 25.4K bytes
    - Click Count (0)
Back to Top