# 並行処理と async / await { #concurrency-and-async-await }

*path operation 関数*のための `async def` 構文に関する詳細と、非同期コード、並行処理、並列処理の背景についてです。

## 急いでいますか？ { #in-a-hurry }

<abbr title="too long; didn't read - 長すぎて読まなかった"><strong>TL;DR:</strong></abbr>

次のように `await` で呼び出すよう指示されているサードパーティライブラリを使っているなら:

```Python
results = await some_library()
```

*path operation 関数*は次のように `async def` で宣言します:

```Python hl_lines="2"
@app.get('/')

		// Fan-out requires no copying, and must be carried from original source
		// https://en.wikipedia.org/wiki/Copy_protection so the incoming stream
		// is always going to be in-memory as we cannot re-read from what we
		// wrote to disk - since that amounts to "copying" from a "copy"
		// instead of "copying" from source, we need the stream to be seekable
		// to ensure that we can make fan-out calls concurrently.

- Containers which specify a `startupProbe` but not a `readinessProbe` were previously considered "ready" before the `startupProbe` completed, but are now considered "not-ready". ([#92196](https://github.com/kubernetes/kubernetes/pull/92196), [@thockin](https://github.com/thockin)) [SIG Node]

    - [Container Images](#container-images-6)
  - [Changelog since v1.33.0](#changelog-since-v1330)
  - [Urgent Upgrade Notes](#urgent-upgrade-notes)
    - [(No, really, you MUST read this before you upgrade)](#no-really-you-must-read-this-before-you-upgrade)
  - [Changes by Kind](#changes-by-kind-6)
    - [Deprecation](#deprecation)
    - [API Change](#api-change)
    - [Feature](#feature-4)
    - [Failing Test](#failing-test)

          call: Call,
          response: Response,
        ) {
          val bytes = response.body.byteStream()
          assertThat(bytes.read()).isEqualTo('a'.code)
          assertThat(bytes.read()).isEqualTo('b'.code)
          assertThat(bytes.read()).isEqualTo('c'.code)

          // This request will share a connection with 'A' cause it's all done.

racing

// radio : European Broadcasting Union (EBU)
// https://www.iana.org/domains/root/db/radio.html
radio

// read : Amazon Registry Services, Inc.
// https://www.iana.org/domains/root/db/read.html
read

// realestate : dotRealEstate LLC
// https://www.iana.org/domains/root/db/realestate.html
realestate

// realtor : Real Estate Domains LLC

ranzan.saitama.jp
rar.ve
ras.ru
rauma.no
ravendb.cloud
ravendb.community
ravendb.run
ravenna.it
ravpage.co.il
rawa-maz.pl
rc.it
rdy.jp
re
re.it
re.kr
read
read-books.org
readmyblog.org
readthedocs-hosted.com
readthedocs.io
readymade.jp
realestate
realestate.pl
realm.cz
realtor
realty
rebun.hokkaido.jp
rec.br
rec.nf
rec.ro

tchedCount","setMatched","contextBackup","dirrunsUnique","token","compiled","filters","unique","getText","isXML","selectors","until","truncate","is","siblings","n","rneedsContext","rsingleTag","winnow","qualifier","self","rootjQuery","parseHTML","ready","rparentsprev","guaranteedUnique","children","contents","prev","sibling","cur","targets","l","closest","index","prevAll","add","addBack","parents","parentsUntil","nextAll","nextUntil","prevUntil","contentDocument","content","reverse","rnothtmlwhi...

-intro/) that offers additional functionality like `At-least-once-delivery`, and `Publisher rate limiting`. To configure MinIO server to send notifications to NATS Streaming server, update the MinIO server configuration file as follows:

Read more about sections `cluster_id`, `client_id` on [NATS documentation](https://github.com/nats-io/nats-streaming-server/blob/master/README.md). Section `maxPubAcksInflight` is explained [here](https://github.com/nats-io/stan.go#publisher-rate-limiting)....

pkg syscall (freebsd-386-cgo), func RawSyscall6(uintptr, uintptr, uintptr, uintptr, uintptr, uintptr, uintptr) (uintptr, uintptr, Errno)
pkg syscall (freebsd-386-cgo), func Read(int, []uint8) (int, error)
pkg syscall (freebsd-386-cgo), func ReadDirent(int, []uint8) (int, error)
pkg syscall (freebsd-386-cgo), func Recvfrom(int, []uint8, int) (int, Sockaddr, error)