Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 127 for goroutines (0.06 seconds)

  1. 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)
  2. internal/s3select/csv/reader.go

    const csvSplitSize = 128 << 10
    
    // startReaders will read the header if needed and spin up a parser
    // and a number of workers based on GOMAXPROCS.
    // If an error is returned no goroutines have been started and r.err will have been set.
    func (r *Reader) startReaders(newReader func(io.Reader) *csv.Reader) error {
    	if r.args.FileHeaderInfo != none {
    		// Read column names
    		// Get one line.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 8.8K bytes
    - Click Count (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top