- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 14 for Interruption (0.1 seconds)
-
src/test/java/org/codelibs/fess/exec/SuggestCreatorTest.java
SuggestCreator.Options options = new SuggestCreator.Options(); assertNotNull(options); } // Test create with interruption @Test public void test_create_withInterruption() { // Test interruption handling SuggestCreator.Options options = new SuggestCreator.Options(); assertNotNull(options); } // Test purge success @Test
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 11K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java
import com.google.common.testing.TearDownAccepter; import java.util.concurrent.TimeUnit; import java.util.logging.Logger; import org.jspecify.annotations.NullUnmarked; /** * Utilities for performing thread interruption in tests * * @author Kevin Bourrillion * @author Chris Povirk */ @NullUnmarked @GwtIncompatible @J2ktIncompatible final class InterruptionUtil {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 15:38:30 GMT 2026 - 3.4K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java
import com.google.common.testing.TearDownAccepter; import java.util.concurrent.TimeUnit; import java.util.logging.Logger; import org.jspecify.annotations.NullUnmarked; /** * Utilities for performing thread interruption in tests * * @author Kevin Bourrillion * @author Chris Povirk */ @NullUnmarked @GwtIncompatible @J2ktIncompatible final class InterruptionUtil {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 15:38:30 GMT 2026 - 3.4K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
e.execute(() -> assertThat(Thread.currentThread().isInterrupted()).isFalse()); // Run those tasks together. fakePool.runAll(); // Check that the interruption of a SequentialExecutor's task is restored to the thread once // it is yielded. Clear the bit while checking so that the test doesn't hose JUnit or some other // test case. assertThat(Thread.interrupted()).isTrue();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 10.5K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
e.execute(() -> assertThat(Thread.currentThread().isInterrupted()).isFalse()); // Run those tasks together. fakePool.runAll(); // Check that the interruption of a SequentialExecutor's task is restored to the thread once // it is yielded. Clear the bit while checking so that the test doesn't hose JUnit or some other // test case. assertThat(Thread.interrupted()).isTrue();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 10.5K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
} private void recordOutputCancellation(boolean interruptIfRunning) { wasCancelled = true; // If all the futures were cancelled with interruption, cancel the input futures // with interruption; otherwise cancel without if (!interruptIfRunning) { shouldInterrupt = false; } recordCompletion(); }Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 19:26:39 GMT 2026 - 64.2K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
inFunction.await(); futureResult.cancel(true); shouldCompleteFunction.countDown(); assertThrows(CancellationException.class, () -> futureResult.get()); // TODO(cpovirk): implement interruption, updating this test: // https://github.com/google/guava/issues/1989 assertEquals(1, gotException.getCount()); // gotException.await(); service.shutdown(); service.awaitTermination(30, SECONDS);
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 134K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
inFunction.await(); futureResult.cancel(true); shouldCompleteFunction.countDown(); assertThrows(CancellationException.class, () -> futureResult.get()); // TODO(cpovirk): implement interruption, updating this test: // https://github.com/google/guava/issues/1989 assertEquals(1, gotException.getCount()); // gotException.await(); service.shutdown(); service.awaitTermination(30, SECONDS);
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 134K bytes - Click Count (0) -
docs/fr/docs/deployment/index.md
qui offre de bonnes performances, une bonne stabilité, _etc._, afin que vos **utilisateurs** puissent **accéder** à l'application efficacement et sans interruption ni problème. Ceci contraste avec les étapes de **développement**, où vous êtes constamment en train de modifier le code, de le casser et de le réparer, d'arrêter et de redémarrer le serveur de développement, _etc._
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:37:13 GMT 2026 - 1.8K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
break; } throw new AssertionError(status); } future.addListener(() -> provideValueAndCloser(consumer, this), executor); } @SuppressWarnings("Interruption") // We are propagating an interrupt from a caller. boolean cancel(boolean mayInterruptIfRunning) { logger.get().log(FINER, "cancelling {0}", closingFutureToString());Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Apr 01 17:27:13 GMT 2026 - 101.7K bytes - Click Count (0)