Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 14 for Interruption (0.1 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top