Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 656 for iowait (0.05 sec)

  1. guava-testlib/test/com/google/common/testing/FakeTickerTest.java

                      startLatch.countDown();
                      startLatch.await();
                      callable.call();
                      doneLatch.countDown();
                      return null;
                    }
                  });
        }
        doneLatch.await();
      }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 6.3K bytes
    - Viewed (0)
  2. docs/ko/docs/tutorial/request-files.md

    * `seek(offset)`: 파일 내 `offset`(`int`) 위치의 바이트로 이동합니다.
        * 예) `await myfile.seek(0)` 를 사용하면 파일의 시작부분으로 이동합니다.
        * `await myfile.read()` 를 사용한 후 내용을 다시 읽을 때 유용합니다.
    * `close()`: 파일을 닫습니다.
    
    상기 모든 메소드들이 `async` 메소드이기 때문에 “await”을 사용하여야 합니다.
    
    예를들어, `async` *경로 작동 함수*의 내부에서 다음과 같은 방식으로 내용을 가져올 수 있습니다:
    
    ```Python
    contents = await myfile.read()
    ```
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Mon Nov 18 02:25:44 UTC 2024
    - 8K bytes
    - Viewed (0)
  3. docs/zh/docs/advanced/websockets.md

    /// note | 技术细节
    
    您也可以使用 `from starlette.websockets import WebSocket`。
    
    **FastAPI** 直接提供了相同的 `WebSocket`,只是为了方便开发人员。但它直接来自 Starlette。
    
    ///
    
    ## 等待消息并发送消息
    
    在您的 WebSocket 路由中,您可以使用 `await` 等待消息并发送消息。
    
    {* ../../docs_src/websockets/tutorial001.py hl[48:52] *}
    
    您可以接收和发送二进制、文本和 JSON 数据。
    
    ## 尝试一下
    
    如果您的文件名为 `main.py`,请使用以下命令运行应用程序:
    
    ```console
    $ uvicorn main:app --reload
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sat Oct 11 17:48:49 UTC 2025
    - 5.1K bytes
    - Viewed (0)
  4. cmd/prepare-storage.go

    		}
    
    		tries++
    		switch {
    		case errors.Is(err, errNotFirstDisk):
    			// Fresh setup, wait for first server to be up.
    			logger.Info("Waiting for the first server to format the drives (elapsed %s)\n", getElapsedTime())
    		case errors.Is(err, errFirstDiskWait):
    			// Fresh setup, wait for other servers to come up.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 11.1K bytes
    - Viewed (1)
  5. android/guava-testlib/test/com/google/common/testing/FakeTickerTest.java

                      startLatch.countDown();
                      startLatch.await();
                      callable.call();
                      doneLatch.countDown();
                      return null;
                    }
                  });
        }
        doneLatch.await();
      }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  6. cmd/erasure-sets.go

    	g := errgroup.WithNErrs(len(s.sets))
    	for index := range s.sets {
    		g.Go(func() error {
    			storageInfos[index] = s.sets[index].StorageInfo(ctx)
    			return nil
    		}, index)
    	}
    
    	// Wait for the go routines.
    	g.Wait()
    
    	for _, lstorageInfo := range storageInfos {
    		storageInfo.Disks = append(storageInfo.Disks, lstorageInfo.Disks...)
    	}
    
    	return storageInfo
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37K bytes
    - Viewed (1)
  7. cmd/http-tracer_test.go

    				_ = httpStats.toServerHTTPStats(false)
    				_ = httpStats.totalS3Requests.Load(false)
    				_ = httpStats.currentS3Requests.Load(false)
    				time.Sleep(1 * time.Microsecond)
    			}
    		}(i)
    	}
    	wg.Wait()
    
    	finalStats := httpStats.toServerHTTPStats(false)
    	totalRequests := 0
    	for _, v := range finalStats.TotalS3Requests.APIStats {
    		totalRequests += v
    	}
    	if totalRequests == 0 {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  8. src/test/java/jcifs/util/SimpleCircuitBreakerTest.java

        void testTransitionToHalfOpen() throws Exception {
            // Open the circuit
            circuitBreaker.tripBreaker();
            assertEquals(SimpleCircuitBreaker.State.OPEN, circuitBreaker.getState());
    
            // Wait for timeout
            Thread.sleep(150);
    
            // Next call should transition to HALF_OPEN
            String result = circuitBreaker.call(() -> "success");
            assertEquals("success", result);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 10.6K bytes
    - Viewed (0)
  9. docs/ko/docs/advanced/async-tests.md

    {* ../../docs_src/async_tests/test_main.py hl[7] *}
    
    /// tip | 팁
    
    테스트 함수가 이제 `TestClient`를 사용할 때처럼 단순히 `def`가 아니라 `async def`로 작성된 점에 주목해주세요.
    
    ///
    
    그 다음에  `AsyncClient` 로 앱을 만들고 비동기 요청을 `await` 키워드로 보낼 수 있습니다:
    
    {* ../../docs_src/async_tests/test_main.py hl[9:12] *}
    
    위의 코드는:
    
    ```Python
    response = client.get('/')
    ```
    
    `TestClient` 에 요청을 보내던 것과 동일합니다.
    
    /// tip | 팁
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Tue Dec 10 11:03:16 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  10. tests/test_dependency_contextvars.py

        legacy_request_state_context_var.reset(contextvar_token)
    
    
    @app.middleware("http")
    async def custom_middleware(
        request: Request, call_next: Callable[[Request], Awaitable[Response]]
    ):
        response = await call_next(request)
        response.headers["custom"] = "foo"
        return response
    
    
    @app.get("/user", dependencies=[Depends(set_up_request_state_dependency)])
    def get_user():
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Dec 17 21:25:59 UTC 2025
    - 1.5K bytes
    - Viewed (0)
Back to top