- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 1,079 for while (0.02 sec)
-
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) -
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) -
compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/metadata/ArtifactMetadataSource.java
* @return {@link List} $lt; {@link ArtifactVersion} > * @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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)