Search Options

Results per page
Sort
Preferred Languages
Advance

Results 331 - 340 of 575 for nwait (0.03 sec)

  1. okhttp-dnsoverhttps/src/main/kotlin/okhttp3/dnsoverhttps/DnsOverHttps.kt

              ) {
                processResponse(response, hostname, responses, failures)
                latch.countDown()
              }
            },
          )
        }
    
        try {
          latch.await()
        } catch (e: InterruptedException) {
          failures.add(e)
        }
      }
    
      private fun processResponse(
        response: Response,
        hostname: String,
        results: MutableList<InetAddress>,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Oct 31 09:27:31 UTC 2024
    - 9.8K bytes
    - Viewed (0)
  2. internal/grid/muxclient.go

    		defer cancel()
    	}
    	// Send request
    	if err := m.send(msg); err != nil {
    		return nil, err
    	}
    	if debugReqs {
    		fmt.Println(m.MuxID, m.parent.String(), "SEND")
    	}
    	// Wait for response or context.
    	select {
    	case v, ok := <-ch:
    		if !ok {
    			return nil, ErrDisconnected
    		}
    		if debugReqs && v.Err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

      }
    
      /** A typical timeout value we'll use in the tests. */
      private static final long SMALL_TIMEOUT_MILLIS = 10;
    
      /** How long to wait when determining that a thread is blocked if we expect it to be blocked. */
      private static final long EXPECTED_HANG_DELAY_MILLIS = 75;
    
      /**
       * How long to wait when determining that a thread is blocked if we DON'T expect it to be blocked.
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 27.1K bytes
    - Viewed (0)
  4. cmd/iam-object-store.go

    				return fmt.Errorf("unable to load the user `%s`: %w", userName, err)
    			}
    			userIdentities[index] = user
    			return nil
    		}, index)
    	}
    
    	err := errors.Join(g.Wait()...)
    	return userIdentities, err
    }
    
    func (iamOS *IAMObjectStore) loadUser(ctx context.Context, user string, userType IAMUserType, m map[string]UserIdentity) error {
    	u, err := iamOS.loadUserIdentity(ctx, user, userType)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 23:40:37 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  5. docs/nl/docs/index.md

        return {"item_id": item_id, "q": q}
    ```
    
    <details markdown="1">
    <summary>Of maak gebruik van <code>async def</code>...</summary>
    
    Als je code gebruik maakt van `async` / `await`, gebruik dan `async def`:
    
    ```Python hl_lines="9  14"
    from typing import Union
    
    from fastapi import FastAPI
    
    app = FastAPI()
    
    
    @app.get("/")
    async def read_root():
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 20 19:20:23 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  6. docs/ja/docs/tutorial/background-tasks.md

    ## タスク関数の作成
    
    バックグラウンドタスクとして実行される関数を作成します。
    
    これは、パラメーターを受け取ることができる単なる標準的な関数です。
    
    これは `async def` または通常の `def` 関数であり、**FastAPI** はこれを正しく処理します。
    
    ここで、タスク関数はファイル書き込みを実行します (メール送信のシミュレーション)。
    
    また、書き込み操作では `async` と `await` を使用しないため、通常の `def` で関数を定義します。
    
    ```Python hl_lines="6-9"
    {!../../docs_src/background_tasks/tutorial001.py!}
    ```
    
    ## バックグラウンドタスクの追加
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 6K bytes
    - Viewed (0)
  7. docs/zh/docs/tutorial/dependencies/index.md

    上述这些操作都是可行的,**FastAPI** 知道该怎么处理。
    
    /// note | "笔记"
    
    如里不了解异步,请参阅[异步:*“着急了?”*](../../async.md){.internal-link target=_blank} 一章中 `async` 和 `await` 的内容。
    
    ///
    
    ## 与 OpenAPI 集成
    
    依赖项及子依赖项的所有请求声明、验证和需求都可以集成至同一个 OpenAPI 概图。
    
    所以,交互文档里也会显示依赖项的所有信息:
    
    <img src="/img/tutorial/dependencies/image01.png">
    
    ## 简单用法
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 7K bytes
    - Viewed (0)
  8. internal/kms/kes.go

    				item = madmin.ItemOnline
    			} else {
    				item = madmin.ItemOffline
    			}
    			results[i] = Result{
    				Endpoint:  c.client.Endpoints[i],
    				ItemState: item,
    			}
    		}(i)
    	}
    	wg.Wait()
    
    	status := make(map[string]madmin.ItemState, len(results))
    	for _, r := range results {
    		if r.ItemState == madmin.ItemOnline {
    			status[r.Endpoint] = madmin.ItemOnline
    		} else {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/publicsuffix/PublicSuffixDatabase.kt

        if (!listRead.get() && listRead.compareAndSet(false, true)) {
          readTheListUninterruptibly()
        } else {
          try {
            readCompleteLatch.await()
          } catch (_: InterruptedException) {
            Thread.currentThread().interrupt() // Retain interrupted status.
          }
        }
    
        check(::publicSuffixListBytes.isInitialized) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  10. docs/em/docs/tutorial/dependencies/index.md

    ⚫️ 🚫 🤔. **FastAPI** 🔜 💭 ⚫️❔.
    
    /// note
    
    🚥 👆 🚫 💭, ✅ [🔁: *"🏃 ❓" *](../../async.md){.internal-link target=_blank} 📄 🔃 `async` &amp; `await` 🩺.
    
    ///
    
    ## 🛠️ ⏮️ 🗄
    
    🌐 📨 📄, 🔬 &amp; 📄 👆 🔗 (&amp; 🎧-🔗) 🔜 🛠️ 🎏 🗄 🔗.
    
    , 🎓 🩺 🔜 ✔️ 🌐 ℹ ⚪️➡️ 👫 🔗 💁‍♂️:
    
    <img src="/img/tutorial/dependencies/image01.png">
    
    ## 🙅 ⚙️
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 6.7K bytes
    - Viewed (0)
Back to top