Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 53 for stop (0.13 sec)

  1. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

     *
     * <p>{@code RuntimeException}s thrown by tasks are simply logged and the executor keeps trucking.
     * If an {@code Error} is thrown, the error will propagate and execution will stop until it is
     * restarted by a call to {@link #execute}.
     */
    @J2ktIncompatible
    @GwtIncompatible
    @ElementTypesAreNonnullByDefault
    final class SequentialExecutor implements Executor {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 10.6K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/TestThread.java

      public TestThread(L lockLikeObject, String threadName) {
        super(threadName);
        this.lockLikeObject = checkNotNull(lockLikeObject);
        start();
      }
    
      // Thread.stop() is okay because all threads started by a test are dying at the end of the test,
      // so there is no object state put at risk by stopping the threads abruptly. In some cases a test
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Apr 26 20:07:17 GMT 2023
    - 10.9K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/base/Ascii.java

      /**
       * Device Control 1. Characters for the control of ancillary devices associated with data
       * processing or telecommunication systems, more especially switching devices "on" or "off." (If a
       * single "stop" control is required to interrupt or turn off ancillary devices, DC4 is the
       * preferred assignment.)
       *
       * @since 8.0
       */
      public static final byte DC1 = 17; // aka XON
    
      /**
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Jul 19 15:43:07 GMT 2021
    - 21.6K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

      }
    
      /**
       * This covers a bug where if a listener was installed that would stop the manager if any service
       * fails and something failed during startup before service.start was called on all the services,
       * then awaitStopped would deadlock due to an IllegalStateException that was thrown when trying to
       * stop the timer(!).
       */
      public void testFailStart_stopOthers() throws TimeoutException {
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Oct 02 17:20:27 GMT 2023
    - 23.2K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/cache/CacheExpirationTest.java

        assertThat(keySet).containsExactly(1, 2, 3, 4, 5, 6, 7, 8, 9);
    
        // get doesn't stop 1 from expiring
        getAll(cache, asList(0, 1, 2));
        CacheTesting.drainRecencyQueues(cache);
        ticker.advance(1, MILLISECONDS);
        assertThat(keySet).containsExactly(2, 3, 4, 5, 6, 7, 8, 9, 0);
    
        // get(K, Callable) doesn't stop 2 from expiring
        Integer unused = cache.get(2, Callables.returning(-2));
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Fri Aug 05 17:21:46 GMT 2022
    - 18.7K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/base/Suppliers.java

       * <p>When the underlying delegate throws an exception then this memoizing supplier will keep
       * delegating calls until it returns valid data.
       *
       * @param duration the length of time after a value is created that it should stop being returned
       *     by subsequent {@code get()} calls
       * @param unit the unit that {@code duration} is expressed in
       * @throws IllegalArgumentException if {@code duration} is not positive
       * @since 2.0
       */
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 15.3K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java

        final CountDownLatch hasConfirmedIsRunning = new CountDownLatch(1);
    
        /*
         * The main test thread tries to stop() the service shortly after
         * confirming that it is running. Meanwhile, the service itself is trying
         * to confirm that it is running. If the main thread's stop() call happens
         * before it has the chance, the test will fail. To avoid this, the main
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 29.3K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/TestThread.java

      public TestThread(L lockLikeObject, String threadName) {
        super(threadName);
        this.lockLikeObject = checkNotNull(lockLikeObject);
        start();
      }
    
      // Thread.stop() is okay because all threads started by a test are dying at the end of the test,
      // so there is no object state put at risk by stopping the threads abruptly. In some cases a test
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Apr 26 20:07:17 GMT 2023
    - 10.9K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

     * {@link #runOneIteration} that will be executed periodically as specified by its {@link
     * Scheduler}. When this service is asked to stop via {@link #stopAsync} it will cancel the periodic
     * task (but not interrupt it) and wait for it to stop before running the {@link #shutDown} method.
     *
     * <p>Subclasses are guaranteed that the life cycle methods ({@link #runOneIteration}, {@link
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Dec 13 19:45:20 GMT 2023
    - 25.8K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/cache/CacheExpirationTest.java

        assertThat(keySet).containsExactly(1, 2, 3, 4, 5, 6, 7, 8, 9);
    
        // get doesn't stop 1 from expiring
        getAll(cache, asList(0, 1, 2));
        CacheTesting.drainRecencyQueues(cache);
        ticker.advance(1, MILLISECONDS);
        assertThat(keySet).containsExactly(2, 3, 4, 5, 6, 7, 8, 9, 0);
    
        // get(K, Callable) doesn't stop 2 from expiring
        Integer unused = cache.get(2, Callables.returning(-2));
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Fri Aug 05 17:21:46 GMT 2022
    - 18.7K bytes
    - Viewed (0)
Back to top