Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 101 - 110 of 154 for goroutine (0.06 seconds)

  1. docs/uk/docs/async.md

    Але всю цю функціональність використання асинхронного коду з `async` і `await` часто підсумовують як використання «співпрограм». Це порівняно з головною ключовою особливістю Go - «Goroutines».
    
    ## Висновок { #conclusion }
    
    Погляньмо на ту саму фразу ще раз:
    
    > Сучасні версії Python мають підтримку «асинхронного коду» за допомогою так званих «співпрограм», з синтаксисом **`async` і `await`**.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:27:41 GMT 2026
    - 36.6K bytes
    - Click Count (0)
  2. internal/s3select/json/preader.go

    const jsonSplitSize = 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 *PReader) startReaders() {
    	r.bufferPool.New = func() []byte {
    		return make([]byte, jsonSplitSize+1024)
    	}
    
    	// Create queue
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  3. guava/src/com/google/common/cache/CacheBuilder.java

       * does).
       *
       * <p>Entries with keys that have been garbage collected may be counted in {@link Cache#size}, but
       * will never be visible to read or write operations; such entries are cleaned up as part of the
       * routine maintenance described in the class javadoc.
       *
       * @return this {@code CacheBuilder} instance (for chaining)
       * @throws IllegalStateException if the key strength was already set
       */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 13:13:59 GMT 2026
    - 51.7K bytes
    - Click Count (0)
  4. cmd/admin-handlers-pools.go

    	}
    
    	var id string
    	if id, err = pools.initRebalanceMeta(ctx, buckets); err != nil {
    		writeErrorResponseJSON(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	// Rebalance routine is run on the first node of any pool participating in rebalance.
    	pools.StartRebalance()
    
    	b, err := json.Marshal(struct {
    		ID string `json:"id"`
    	}{ID: id})
    	if err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 11.1K 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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  6. 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 Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Dec 13 18:45:54 GMT 2021
    - 8K bytes
    - Click Count (0)
  7. docs/tr/docs/_llm-test.md

    * SDK
    * software development kit
    
    * `APIRouter`
    * `requirements.txt`
    * Bearer Token
    * breaking change
    * bug
    * button
    * callable
    * code
    * commit
    * context manager
    * coroutine
    * database session
    * disk
    * domain
    * engine
    * fake X
    * HTTP GET method
    * item
    * library
    * lifespan
    * lock
    * middleware
    * mobile application
    * module
    * mounting
    * network
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Mar 20 07:53:17 GMT 2026
    - 11.1K bytes
    - Click Count (0)
  8. docs/de/docs/_llm-test.md

    * der `APIRouter`
    * die `requirements.txt`
    * das Bearer-Token
    * der Breaking Change
    * der Bug
    * der Button
    * das Callable
    * der Code
    * der Commit
    * der Contextmanager
    * die Coroutine
    * die Datenbanksession
    * die Festplatte
    * die Domain
    * die Engine
    * das Fake-X
    * die HTTP-GET-Methode
    * das Item
    * die Bibliothek
    * der Lifespan
    * der Lock
    * die Middleware
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 17:58:09 GMT 2026
    - 12.3K bytes
    - Click Count (0)
  9. internal/lock/lock_test.go

    	case <-locked:
    		t.Error("unexpected unblocking")
    	case <-time.After(100 * time.Millisecond):
    	}
    
    	// unlock
    	if err = dupl.Close(); err != nil {
    		t.Fatal(err)
    	}
    
    	// the previously blocked routine should be unblocked
    	select {
    	case <-locked:
    	case <-time.After(1 * time.Second):
    		t.Error("unexpected blocking")
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 3.7K bytes
    - Click Count (0)
  10. 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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 8.8K bytes
    - Click Count (0)
Back to Top