While - Code Search

fess-crawler-lasta/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java

            assertEquals(maxCount, dataService.getCount(sessionId2));

            UrlQueue urlQueue;
            while ((urlQueue = urlQueueService.poll(sessionId1)) != null) {
                assertTrue(urlQueue.getUrl().startsWith(url1));
            }
            while ((urlQueue = urlQueueService.poll(sessionId2)) != null) {
                assertTrue(urlQueue.getUrl().startsWith(url2));
            }

Created: Sat Dec 20 11:21:39 GMT 2025

- Last Modified: Sat Sep 06 04:15:37 GMT 2025

- 12.8K bytes

- Click Count (0)

github.com/square/okhttp

docs/contribute/concurrency.md

#### Http2Writer

Socket writes are guarded by the Http2Writer. Only one stream can write at a time so that messages are not interleaved. Writes are either made by application-layer threads or the do-stuff-later pool.

### Holding multiple locks

Created: Fri Dec 26 11:42:13 GMT 2025

- Last Modified: Sun Feb 06 16:35:36 GMT 2022

- 7K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Hpack.kt

        var bytesToRecover = bytesToRecover
        var entriesToEvict = 0
        if (bytesToRecover > 0) {
          // determine how many headers need to be evicted.
          var j = dynamicTable.size - 1
          while (j >= nextHeaderIndex && bytesToRecover > 0) {
            val toEvict = dynamicTable[j]!!
            bytesToRecover -= toEvict.hpackSize
            dynamicTableByteCount -= toEvict.hpackSize
            headerCount--

Created: Fri Dec 26 11:42:13 GMT 2025

- Last Modified: Mon May 05 16:01:00 GMT 2025

- 22.4K bytes

- Click Count (0)

github.com/google/guava

android/guava-tests/test/com/google/common/math/MathBenchmarking.java

   */
  static BigInteger randomPositiveBigInteger(int numBits) {
    BigInteger result;
    do {
      result = randomNonNegativeBigInteger(numBits);
    } while (result.signum() == 0);
    return result;
  }

  /**
   * Generates a number in [0, 2^numBits) with an exponential distribution. The floor of the log2 of

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Sun Aug 10 19:54:19 GMT 2025

- 4.2K bytes

- Click Count (0)

github.com/apache/maven

impl/maven-cli/src/main/java/org/apache/maven/cling/transfer/ConsoleMavenTransferListener.java

        buffer.append("Progress (").append(transfers.size()).append("): ");

        Iterator<TransferResourceAndSize> entries = transfers.values().iterator();
        while (entries.hasNext()) {
            TransferResourceAndSize entry = entries.next();
            // just in case, make sure 0 <= complete <= total
            long complete = Math.max(0, entry.transferredBytes);

Created: Sun Dec 28 03:35:09 GMT 2025

- Last Modified: Fri Nov 22 14:09:32 GMT 2024

- 5.2K bytes

- Click Count (0)

github.com/apache/maven

impl/maven-core/src/test/java/org/apache/maven/lifecycle/internal/stub/AboutTheStubs.html

-->

<html>
<head>
    <title>About these stubs</title>
</head>
<body>
<h2>Design</h2>
These stubs can be thought of as hand-coded mock objects. They allow unit tests to test only specific
aspects of a component while ignoring others.

These stubs form an internally consistent data-set that is not expected to change. They are
used to test the individual components in the lifecycle with data that has expected characteristics

Created: Sun Dec 28 03:35:09 GMT 2025

- Last Modified: Fri Oct 25 12:31:46 GMT 2024

- 2.3K bytes

- Click Count (0)

github.com/google/guava

android/guava/src/com/google/common/io/MultiInputStream.java

  }

  @Override
  public int read() throws IOException {
    while (in != null) {
      int result = in.read();
      if (result != -1) {
        return result;
      }
      advance();
    }
    return -1;
  }

  @Override
  public int read(byte[] b, int off, int len) throws IOException {
    checkNotNull(b);
    while (in != null) {
      int result = in.read(b, off, len);
      if (result != -1) {

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Wed May 14 19:40:47 GMT 2025

- 2.8K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs/en/docs/async.md

<img src="/img/async/concurrent-burgers/concurrent-burgers-04.png" class="illustration">

While you are waiting, you go with your crush and pick a table, you sit and talk with your crush for a long time (as your burgers are very fancy and take some time to prepare).

As you are sitting at the table with your crush, while you wait for the burgers, you can spend that time admiring how awesome, cute and smart your crush is ✨😍✨.

Created: Sun Dec 28 07:19:09 GMT 2025

- Last Modified: Sun Aug 31 09:56:21 GMT 2025

- 24K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs/en/docs/how-to/migrate-from-pydantic-v1-to-pydantic-v2.md

FastAPI version 0.119.0 introduced partial support for Pydantic v1 from inside of Pydantic v2 (as `pydantic.v1`), to facilitate the migration to v2.

FastAPI 0.126.0 dropped support for Pydantic v1, while still supporting `pydantic.v1` for a little while.

/// warning

The Pydantic team stopped support for Pydantic v1 for the latest versions of Python, starting with **Python 3.14**.

Created: Sun Dec 28 07:19:09 GMT 2025

- Last Modified: Sat Dec 20 15:55:38 GMT 2025

- 5.5K bytes

- Click Count (0)

github.com/google/guava

guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

          executor.execute(
              () -> {
                try {
                  startUp();
                  notifyStarted();
                  // If stopAsync() is called while starting we may be in the STOPPING state in
                  // which case we should skip right down to shutdown.
                  if (isRunning()) {
                    try {

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Fri Jul 11 18:52:30 GMT 2025

- 7.5K bytes

- Click Count (0)

Search Options