Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 78 for go_routine (0.04 sec)

  1. docs/de/docs/async.md

    Aber all diese Funktionalität der Verwendung von asynchronem Code mit `async` und `await` wird oft als Verwendung von „Coroutinen“ zusammengefasst. Es ist vergleichbar mit dem Hauptmerkmal von Go, den „Goroutinen“.
    
    ## Fazit { #conclusion }
    
    Sehen wir uns den gleichen Satz von oben noch mal an:
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sat Sep 20 15:10:09 UTC 2025
    - 27.9K bytes
    - Viewed (0)
  2. fastapi/dependencies/utils.py

    import dataclasses
    import inspect
    import sys
    from collections.abc import Coroutine, Mapping, Sequence
    from contextlib import AsyncExitStack, contextmanager
    from copy import copy, deepcopy
    from dataclasses import dataclass
    from typing import (
        Annotated,
        Any,
        Callable,
        ForwardRef,
        Optional,
        Union,
        cast,
    )
    
    import anyio
    from fastapi import params
    from fastapi._compat import (
        ModelField,
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sat Dec 27 12:54:56 UTC 2025
    - 37.6K bytes
    - Viewed (3)
  3. CHANGELOG/CHANGELOG-1.17.md

    - kube-apiserver: fixed a bug that could cause a goroutine leak if the apiserver encountered an encoding error serving a watch to a websocket watcher ([#84693](https://github.com/kubernetes/kubernetes/pull/84693), [@tedyu](https://github.com/tedyu))
    Registered: Fri Dec 26 09:05:12 UTC 2025
    - Last Modified: Thu Jan 28 10:44:33 UTC 2021
    - 346.2K bytes
    - Viewed (1)
  4. cmd/bucket-lifecycle.go

    		n = tw
    	}
    	t.mu.Lock()
    	defer t.mu.Unlock()
    
    	t.objAPI = objAPI
    	t.updateWorkers(n)
    }
    
    // PendingTasks returns the number of ILM transition tasks waiting for a worker
    // goroutine.
    func (t *transitionState) PendingTasks() int {
    	return len(t.transitionCh)
    }
    
    // ActiveTasks returns the number of active (ongoing) ILM transition tasks.
    func (t *transitionState) ActiveTasks() int64 {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33.7K bytes
    - Viewed (0)
  5. fastapi/routing.py

    import email.message
    import functools
    import inspect
    import json
    from collections.abc import (
        AsyncIterator,
        Awaitable,
        Collection,
        Coroutine,
        Mapping,
        Sequence,
    )
    from contextlib import AsyncExitStack, asynccontextmanager
    from enum import Enum, IntEnum
    from typing import (
        Annotated,
        Any,
        Callable,
        Optional,
        Union,
    )
    
    from annotated_doc import Doc
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sat Dec 27 12:54:56 UTC 2025
    - 174.6K bytes
    - Viewed (0)
  6. 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.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 8.8K bytes
    - Viewed (0)
  7. cmd/erasure-server-pool-rebalance.go

    	if err != nil {
    		rebalanceLogIf(ctx, fmt.Errorf("invalid workers value err: %v, defaulting to %d", err, len(pool.sets)))
    		workerSize = len(pool.sets)
    	}
    
    	// Each decom worker needs one List() goroutine/worker
    	// add that many extra workers.
    	workerSize += len(pool.sets)
    
    	wk, err := workers.New(workerSize)
    	if err != nil {
    		return err
    	}
    
    	for setIdx, set := range pool.sets {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 28.7K bytes
    - Viewed (0)
  8. docs/en/docs/async.md

    But all this functionality of using asynchronous code with `async` and `await` is many times summarized as using "coroutines". It is comparable to the main key feature of Go, the "Goroutines".
    
    ## 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.
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sun Aug 31 09:56:21 UTC 2025
    - 24K bytes
    - Viewed (0)
  9. docs/en/docs/_llm-test.md

    * the `APIRouter`
    * the `requirements.txt`
    * the Bearer Token
    * the breaking change
    * the bug
    * the button
    * the callable
    * the code
    * the commit
    * the context manager
    * the coroutine
    * the database session
    * the disk
    * the domain
    * the engine
    * the fake X
    * the HTTP GET method
    * the item
    * the library
    * the lifespan
    * the lock
    * the middleware
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Thu Dec 11 14:48:47 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  10. cmd/metrics-v3-types.go

    		err = mg.bucketLoader(GlobalContext, metricValues, mg.cache, mg.buckets)
    	} else {
    		err = mg.loader(GlobalContext, metricValues, mg.cache)
    	}
    
    	// There is no way to handle errors here, so we panic the current goroutine
    	// and the Metrics API handler returns a 500 HTTP status code. This should
    	// normally not happen, and usually indicates a bug.
    	logger.CriticalIf(GlobalContext, errors.Wrap(err, "failed to get metrics"))
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Feb 28 19:33:08 UTC 2025
    - 15.6K bytes
    - Viewed (0)
Back to top