- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 2,193 for Done (0.18 sec)
-
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
@Override public void run() {} } // The thread executing the task publishes itself to the superclass' reference and the thread // interrupting sets DONE when it has finished interrupting. private static final Runnable DONE = new DoNothingRunnable(); private static final Runnable PARKED = new DoNothingRunnable(); // Why 1000? WHY NOT! private static final int MAX_BUSY_WAIT_SPINS = 1000;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Sep 29 21:34:48 GMT 2023 - 9.9K bytes - Viewed (0) -
guava/src/com/google/common/base/AbstractIterator.java
protected AbstractIterator() {} private enum State { READY, NOT_READY, DONE, FAILED, } @CheckForNull private T next; @CheckForNull protected abstract T computeNext(); @CanIgnoreReturnValue @CheckForNull protected final T endOfData() { state = State.DONE; return null; } @Override public final boolean hasNext() {
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Fri Jul 09 17:31:04 GMT 2021 - 2.5K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/MacHashFunction.java
checkNotDone(); checkNotNull(bytes); mac.update(bytes); } private void checkNotDone() { checkState(!done, "Cannot re-use a Hasher after calling hash() on it"); } @Override public HashCode hash() { checkNotDone(); done = true; return HashCode.fromBytesNoCopy(mac.doFinal()); } }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 15 22:31:55 GMT 2022 - 3.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
return new TrackedRunnable() { private volatile boolean done = false; @Override public boolean isDone() { return done; } @Override public void run() { try { delay(timeoutMillis); done = true; } catch (InterruptedException ok) { } } }; }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 37.7K bytes - Viewed (0) -
src/main/java/org/codelibs/curl/io/ContentOutputStream.java
protected static final String SUFFIX = ".tmp"; protected boolean done = false; public ContentOutputStream(final int threshold, final File tmpDir) { super(threshold, PREFIX, SUFFIX, tmpDir); } @Override public File getFile() { done = true; return super.getFile(); } @Override public void close() throws IOException {
Java - Registered: Thu May 09 15:34:10 GMT 2024 - Last Modified: Mon Nov 14 21:05:19 GMT 2022 - 1.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFuture.java
* either case, no one needs to read `futures` for cancellation purposes later. (And * cancellation purposes are the main reason to access `futures`, as discussed in its docs.) */ this.futures = null; } enum ReleaseResourcesReason { OUTPUT_FUTURE_DONE, ALL_INPUT_FUTURES_PROCESSED, } /**
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 15.4K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/helper/CrawlerStatsHelperTest.java
crawlerStatsHelper.done(key); logger.info(localLogMsg.get()); String[] values = localLogMsg.get().split("\t"); assertEquals(3, values.length); assertEquals("url:test", values[0]); assertTrue(values[1].startsWith("time:")); assertTrue(values[2].startsWith("done:")); localLogMsg.remove(); crawlerStatsHelper.done(key); assertNull(localLogMsg.get());
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 6K bytes - Viewed (0) -
src/test/java/org/codelibs/curl/io/ContentOutputStreamTest.java
assertFalse(cos.done); assertTrue(cos.isInMemory()); cos.close(); assertFalse(cos.done); } @Test public void inFile() throws IOException { ContentOutputStream cos = new ContentOutputStream(10, Curl.tmpDir); cos.write(new byte[] { 0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 0 }); assertFalse(cos.done); assertFalse(cos.isInMemory());
Java - Registered: Thu May 09 15:34:10 GMT 2024 - Last Modified: Mon Nov 14 21:05:19 GMT 2022 - 2K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/MessageDigestHashFunction.java
checkNotDone(); digest.update(bytes); } private void checkNotDone() { checkState(!done, "Cannot re-use a Hasher after calling hash() on it"); } @Override public HashCode hash() { checkNotDone(); done = true; return (bytes == digest.getDigestLength()) ? HashCode.fromBytesNoCopy(digest.digest())
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed May 25 20:32:46 GMT 2022 - 5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/WebFsIndexHelper.java
crawler.awaitTermination(crawlingExecutionInterval); if (crawler.getCrawlerContext().getStatus() == CrawlerStatus.DONE && !Constants.DONE.equals(crawlerStatusList.get(i))) { crawlerStatusList.set(i, Constants.DONE); final String sid = crawler.getCrawlerContext().getSessionId(); indexUpdater.addFinishedSessionId(sid);
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 22.6K bytes - Viewed (0)