Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 1,079 for while (0.02 sec)

  1. android/guava/src/com/google/common/collect/CartesianList.java

          return -1;
        }
        List<?> list = (List<?>) o;
        if (list.size() != axes.size()) {
          return -1;
        }
        ListIterator<?> itr = list.listIterator();
        int computedIndex = 0;
        while (itr.hasNext()) {
          int axisIndex = itr.nextIndex();
          int elemIndex = axes.get(axisIndex).indexOf(itr.next());
          if (elemIndex == -1) {
            return -1;
          }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Aug 31 13:15:26 UTC 2025
    - 4.7K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/io/CharSequenceReaderTest.java

        assertFullyRead(reader);
    
        // read in chunks to fixed array
        reader = new CharSequenceReader(charSequence);
        buf = new char[5];
        StringBuilder builder = new StringBuilder();
        int read;
        while ((read = reader.read(buf, 0, buf.length)) != -1) {
          builder.append(buf, 0, read);
        }
        assertEquals(expected, builder.toString());
        assertFullyRead(reader);
    
        // read all to one CharBuffer
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  3. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/metadata/ArtifactMetadataSource.java

         * @return {@link List} $lt; {@link ArtifactVersion} &gt;
         * @throws ArtifactMetadataRetrievalException
         *          in case of error while retrieving repository metadata from the repository.
         */
        List<ArtifactVersion> retrieveAvailableVersions(
                Artifact artifact, ArtifactRepository localRepository, List<ArtifactRepository> remoteRepositories)
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  4. 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 Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
  5. 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: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 12.8K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/hash/Murmur3_32HashFunction.java

        @Override
        public Hasher putBytes(ByteBuffer buffer) {
          ByteOrder bo = buffer.order();
          buffer.order(ByteOrder.LITTLE_ENDIAN);
          while (buffer.remaining() >= 4) {
            putInt(buffer.getInt());
          }
          while (buffer.hasRemaining()) {
            putByte(buffer.get());
          }
          buffer.order(bo);
          return this;
        }
    
        @CanIgnoreReturnValue
        @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Apr 14 16:36:11 UTC 2025
    - 11.8K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/util/Base64.java

            }
            final StringBuilder buffer = new StringBuilder((int) Math.ceil(length / 3d) * 4);
            final int remainder = length % 3;
            length -= remainder;
            int block;
            int i = 0;
            while (i < length) {
                block = (bytes[i++] & 0xff) << 16 | (bytes[i++] & 0xff) << 8 | bytes[i++] & 0xff;
                buffer.append(ALPHABET.charAt(block >>> 18));
                buffer.append(ALPHABET.charAt(block >>> 12 & 0x3f));
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 4.1K bytes
    - Viewed (0)
  8. src/test/java/org/codelibs/fess/it/CrawlTestBase.java

            }
            fail("could not start job.");
        }
    
        protected static void waitJob(final String namePrefix) {
            Boolean isRunning = false;
            int count = 0;
    
            while (count < 300 && !isRunning) { // Wait until the crawler starts
                ThreadUtil.sleep(500);
                count++;
                final Map<String, Object> scheduler = getSchedulerItem(namePrefix);
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 10K bytes
    - Viewed (0)
  9. 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 {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

              } catch (Exception e) { // sneaky checked exception
                log.get().log(Level.SEVERE, "Exception while executing runnable " + task, e);
              } finally {
                task = null;
              }
            }
          } finally {
            // Ensure that if the thread was interrupted at all while processing the task queue, it
            // is returned to the delegate Executor interrupted so that it may handle the
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 10.6K bytes
    - Viewed (0)
Back to top