- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 389 for finished (0.5 sec)
-
src/main/java/org/codelibs/fess/helper/CrawlerStatsHelper.java
} } public enum StatsAction { ACCESSED, // ACCESS_EXCEPTION, // CHILD_URL, // CHILD_URLS, // EVALUATED, // EXCEPTION, // FINISHED, // PARSED, // PREPARED, // REDIRECTED, // PROCESSED,// }
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 9.9K bytes - Viewed (0) -
android/guava/src/com/google/common/io/ReaderInputStream.java
* draining it is flipped (undrained bytes between position and limit). */ private ByteBuffer byteBuffer; /** Whether we've finished reading the reader. */ private boolean endOfInput; /** Whether we're copying encoded bytes to the caller's buffer. */ private boolean draining; /** Whether we've successfully flushed the encoder. */
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 28 20:13:02 GMT 2023 - 9.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/JdkFutureAdaptersTest.java
assertFalse(singleCallListener.wasCalled()); assertTrue(listenableFuture.isDone()); // We call AbstractFuture#set above. // #addListener() will run the listener immediately because the Future is // already finished (we explicitly set the result of it above). listenableFuture.addListener(singleCallListener, directExecutor()); assertEquals(DATA1, listenableFuture.get());
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 9.7K bytes - Viewed (0) -
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) -
maven-core/src/main/java/org/apache/maven/lifecycle/internal/builder/multithreaded/MultiThreadedBuilder.java
rootSession, projectSegment, reactorContext, taskSegment, muxer, duplicateArtifactIds); service.submit(cb); } // for each finished project for (int i = 0; i < analyzer.getNumberOfBuilds(); i++) { try { ProjectSegment projectBuild = service.take().get();
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Fri Sep 22 09:07:17 GMT 2023 - 9.4K bytes - Viewed (0) -
docs/en/docs/advanced/events.md
{!../../../docs_src/events/tutorial003.py!} ``` The first part of the function, before the `yield`, will be executed **before** the application starts. And the part after the `yield` will be executed **after** the application has finished. ### Async Context Manager If you check, the function is decorated with an `@asynccontextmanager`. That converts the function into something called an "**async context manager**". ```Python hl_lines="1 13"
Plain Text - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Thu Apr 18 19:53:19 GMT 2024 - 7.8K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/AbstractIterator.java
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Fri Mar 18 02:04:10 GMT 2022 - 6.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/SuggestCreator.java
} finally { if (systemMonitorTask != null) { systemMonitorTask.cancel(); } destroyContainer(); } logger.info("Finished SuggestCreator."); System.exit(exitCode); } private static void destroyContainer() { TimeoutManager.getInstance().stop(); synchronized (SingletonLaContainerFactory.class) {
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 10K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops.go
// Load healing tracker in this disk tracker, err := loadHealingTracker(ctx, disk) if err != nil { // A healing tracker may be deleted if another disk in the // same erasure set with same healing-id successfully finished // healing. if errors.Is(err, errFileNotFound) { return nil } healingLogIf(ctx, fmt.Errorf("Unable to load healing tracker on '%s': %w, re-initializing..", disk, err))
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.7K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/lifecycle/internal/MojoExecutor.java
* by concurrently running mojo executions. To prevent race conditions, an aggregating execution will block * all other executions until finished. * We also lock on a given project to forbid a forked lifecycle to be executed concurrently with the project. * TODO: ideally, the builder should take care of the ordering in a smarter way
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Wed Feb 28 23:31:09 GMT 2024 - 20.7K bytes - Viewed (0)