)

// errOutOfEntropy indicates that the a source of randomness (PRNG) wasn't able
// to produce enough random data. This is fatal error and should cause a panic.

     * @param sitemaps An array of sitemap URLs.
     */
    public void addSitemaps(final String[] sitemaps) {
        sitemapsLocal.set(sitemaps);
    }

    /**
     * Removes sitemaps from the thread-local storage and returns them.
     * @return An array of sitemap URLs, or null if none were present.
     */
    public String[] removeSitemaps() {
        final String[] sitemaps = sitemapsLocal.get();

        // Test complex scenario with multiple operations
        ExtractData data = new ExtractData();

        // Set content
        String content = "This is a long extracted content from a PDF document. " + "It contains multiple paragraphs and rich text.";
        data.setContent(content);

        // Add single values
        data.putValue(ExtractData.RESOURCE_NAME_KEY, "document.pdf");

                    throwValidationErrorApi(messages -> messages.addErrorsFailedToDownloadProtwordsFile(GLOBAL));
                    return null;
                });
    }

    /**
     * Creates an EditBody from a KuromojiItem entity for API responses.
     *
     * @param entity the KuromojiItem entity to convert
     * @param dictId the dictionary ID
     * @return the converted EditBody object
     */

        props.setProperty("jcifs.smb.client.soTimeout", "35000");

        config = new PropertyConfiguration(props);
    }

    @Test
    @DisplayName("Should create configuration from Properties")
    void testConfigurationCreation() throws CIFSException {
        // Then
        assertNotNull(config);
        assertEquals("testuser", config.getDefaultUsername());

     * Usually this is the information in the src element of an <embed> tag.
     */
    private String playerLoc;

    /**
     * The duration of the video in seconds.
     * Value must be from 1 to 28800 (8 hours).
     */
    private String duration;

    /**
     * The date the video was first published, in W3C format.
     */
    private String publicationDate;

    /**

                        session.acquire();
                        acquireCount.incrementAndGet();
                    }

                } catch (Exception e) {
                    // Ignore expected exceptions from over-release
                } finally {
                    endLatch.countDown();
                }
            });
        }

        // Start all threads simultaneously
        startLatch.countDown();

      }
    }
  }

  /**
   * Dispatches all events enqueued prior to this call, serially and in order, for every listener.
   *
   * <p>Note: this method is idempotent and safe to call from any thread
   */
  public void dispatch() {
    // iterate by index to avoid concurrent modification exceptions
    for (int i = 0; i < listeners.size(); i++) {
      listeners.get(i).dispatch();
    }
  }

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

## 创建 `websocket`

在您的 **FastAPI** 应用程序中，创建一个 `websocket`：

{* ../../docs_src/websockets/tutorial001.py hl[1,46:47] *}

/// note | 技术细节

您也可以使用 `from starlette.websockets import WebSocket`。

**FastAPI** 直接提供了相同的 `WebSocket`，只是为了方便开发人员。但它直接来自 Starlette。

///

## 等待消息并发送消息

在您的 WebSocket 路由中，您可以使用 `await` 等待消息并发送消息。

        assertFalse(component.isCloseCalled());

        try {
            failingFactory.destroyObject(pooledObject);
            fail("Should throw exception from close()");
        } catch (Exception e) {
            // Expected - exception should propagate from close()
            assertTrue(e.getMessage().contains("Intentional close failure"));
        }

        // Verify close was attempted