SimpleCircuitBreaker breaker = new SimpleCircuitBreaker("concurrent", 5, 3, 100);
        AtomicInteger successCount = new AtomicInteger(0);
        AtomicInteger failureCount = new AtomicInteger(0);

        // Create multiple threads
        Thread[] threads = new Thread[10];
        for (int i = 0; i < threads.length; i++) {
            final int index = i;
            threads[i] = new Thread(() -> {

    * `description`: uma `str` com uma breve descrição da documentação externa.
    * `url` (**obrigatório**): uma `str` com a URL da documentação externa.

### Criar Metadados para tags { #create-metadata-for-tags }

Vamos tentar isso em um exemplo com tags para `users` e `items`.

Crie metadados para suas tags e passe-os para o parâmetro `openapi_tags`:

import org.dbflute.optional.OptionalEntity;

import jakarta.annotation.Resource;

/**
 * Service class for managing duplicate host configuration CRUD operations.
 * This service provides functionality to create, read, update, and delete
 * duplicate host configurations used by the Fess crawler system.
 *
 * <p>Duplicate host configurations allow administrators to define hostname patterns

        direction.directSecurity(createSecurityResourceProvider());
        direction.directTime(createTimeResourceProvider());
        direction.directMail(createFessMailDeliveryDepartmentCreator().create());
        direction.directJson(createJsonResourceProvider());
    }

    protected FessJsonResourceProvider createJsonResourceProvider() {
        return new FessJsonResourceProvider();
    }

  // transition to DONE
  public void testInterruptThrows() throws Exception {
    CountDownLatch isInterruptibleRegistered = new CountDownLatch(1);
    SettableFuture<String> taskResult = SettableFuture.create();
    InterruptibleTask<String> task =
        new InterruptibleTask<String>() {
          @Override
          String runInterruptibly() throws Exception {
            BrokenChannel bc = new BrokenChannel();

  // transition to DONE
  public void testInterruptThrows() throws Exception {
    CountDownLatch isInterruptibleRegistered = new CountDownLatch(1);
    SettableFuture<String> taskResult = SettableFuture.create();
    InterruptibleTask<String> task =
        new InterruptibleTask<String>() {
          @Override
          String runInterruptibly() throws Exception {
            BrokenChannel bc = new BrokenChannel();

Pero es la forma más sencilla de enfocarse en el lado del servidor de WebSockets y tener un ejemplo funcional:

{* ../../docs_src/websockets_/tutorial001_py310.py hl[2,6:38,41:43] *}

## Crear un `websocket` { #create-a-websocket }

En tu aplicación de **FastAPI**, crea un `websocket`:

{* ../../docs_src/websockets_/tutorial001_py310.py hl[1,46:47] *}

/// note | Detalles Técnicos

* 它可以对该**响应**做一些事情或者执行任何需要的代码。
* 然后它返回这个**响应**。

/// note | 技术细节

如果你有使用 `yield` 的依赖，依赖中的退出代码会在中间件之后运行。

如果有任何后台任务（会在[后台任务](background-tasks.md)一节中介绍，你稍后会看到），它们会在所有中间件之后运行。

///

## 创建中间件 { #create-a-middleware }

要创建中间件，你可以在函数的顶部使用装饰器 `@app.middleware("http")`。

中间件函数会接收：

* `request`。
* 一个函数 `call_next`，它会把 `request` 作为参数接收。
    * 这个函数会把 `request` 传递给相应的*路径操作*。
    * 然后它返回由相应*路径操作*生成的 `response`。

     * <p>
     * Determining the transitive deps of a dependency which has been resolved as
     * non-transitive is difficult because the process of resolving removes the
     * transitive deps. To sidestep this issue, we create a configuration per
     * direct dependency version. This specially named and unique configuration
     * will contain all of the transitive dependencies of this particular

test the deployment using the MinIO Console, an embedded web-based object browser built into MinIO Server. Point a web browser running on the host machine to <http://127.0.0.1:9000> and log in with the root credentials. You can use the Browser to create buckets, upload objects, and browse the contents of the MinIO server. You can also connect using any S3-compatible tool, such as the MinIO Client `mc` commandline tool. See [Test using MinIO Client `mc`](#test-using-minio-client-mc) for more information...