while - Code Search

android/guava/src/com/google/common/collect/Serialization.java

@J2ktIncompatible
final class Serialization {
  private Serialization() {}

  /**
   * Stores the contents of a map in an output stream, as part of serialization. It does not support
   * concurrent maps whose content may change while the method is running.
   *
   * <p>The serialized output consists of the number of entries, first key, first value, second key,
   * second value, and so on.
   */

Registered: Fri Dec 26 12:43:10 UTC 2025

- Last Modified: Tue Dec 09 15:58:48 UTC 2025

- 6.7K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

    Interruptenator(Thread interruptee, long everyMillis) {
      this.everyMillis = everyMillis;
      this.interruptee = interruptee;
    }

    @Override
    public void run() {
      while (true) {
        try {
          Thread.sleep(everyMillis);
        } catch (InterruptedException e) {
          // ok. just stop sleeping.
        }
        if (shouldStop) {
          break;
        }

Registered: Fri Dec 26 12:43:10 UTC 2025

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

- 4.5K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/collect/CollectionBenchmarkSampleData.java

      }
      List<Element> tmp = new ArrayList<>(elementsInSet);
      shuffle(tmp, random);
      queryList.addAll(tmp.subList(0, extras));
    }

    // now add bad queries
    while (queryList.size() < numQueries) {
      Element candidate = newElement();
      if (!elementsInSet.contains(candidate)) {
        queryList.add(candidate);
      }
    }
    shuffle(queryList, random);

Registered: Fri Dec 26 12:43:10 UTC 2025

- Last Modified: Tue May 13 17:27:14 UTC 2025

- 4.2K bytes

- Viewed (0)

github.com/codelibs/fess-crawler

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));
            }

Registered: Sat Dec 20 11:21:39 UTC 2025

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

- 12.8K bytes

- Viewed (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

Registered: Fri Dec 26 11:42:13 UTC 2025

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

- 7K bytes

- Viewed (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--

Registered: Fri Dec 26 11:42:13 UTC 2025

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

- 22.4K bytes

- Viewed (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

Registered: Fri Dec 26 12:43:10 UTC 2025

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

- 4.2K bytes

- Viewed (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);

Registered: Sun Dec 28 03:35:09 UTC 2025

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

- 5.2K bytes

- Viewed (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

Registered: Sun Dec 28 03:35:09 UTC 2025

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

- 2.3K bytes

- Viewed (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) {

Registered: Fri Dec 26 12:43:10 UTC 2025

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

- 2.8K bytes

- Viewed (0)

Search Options