Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 512 for Runnable (7.91 sec)

  1. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFuture.java

          throws InterruptedException, ExecutionException, TimeoutException {
        checkNotNull(unit);
        return get();
      }
    
      @Override
      public void addListener(Runnable runnable, Executor executor) {
        Listener listener = new Listener(runnable, executor);
        if (isDone()) {
          listener.execute();
        } else {
          listeners.add(listener);
        }
      }
    
      @CanIgnoreReturnValue
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Jan 22 19:37:41 GMT 2024
    - 12.3K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/WrappingExecutorService.java

       * to any {@code Runnable} passed to the default implementation of {@link #wrapTask(Runnable)}.
       */
      protected abstract <T extends @Nullable Object> Callable<T> wrapTask(Callable<T> callable);
    
      /**
       * Wraps a {@code Runnable} for submission to the underlying executor. The default implementation
       * delegates to {@link #wrapTask(Callable)}.
       */
      protected Runnable wrapTask(Runnable command) {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 5.5K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/AbstractListeningExecutorService.java

       */
      @CanIgnoreReturnValue // TODO(kak): consider removing this
      @Override
      protected final <T extends @Nullable Object> RunnableFuture<T> newTaskFor(
          Runnable runnable, @ParametricNullness T value) {
        return TrustedListenableFutureTask.create(runnable, value);
      }
    
      /**
       * @since 19.0 (present with return type {@code ListenableFutureTask} since 14.0)
       */
      @CanIgnoreReturnValue // TODO(kak): consider removing this
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri May 12 18:32:03 GMT 2023
    - 3K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/FakeTimeLimiter.java

      }
    
      @Override
      @SuppressWarnings("CatchingUnchecked") // sneaky checked exception
      public void runWithTimeout(Runnable runnable, long timeoutDuration, TimeUnit timeoutUnit) {
        checkNotNull(runnable);
        checkNotNull(timeoutUnit);
        try {
          runnable.run();
        } catch (Exception e) { // sneaky checked exception
          throw new UncheckedExecutionException(e);
        } catch (Error e) {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Dec 14 20:35:03 GMT 2023
    - 3.5K bytes
    - Viewed (0)
  5. android/guava-testlib/src/com/google/common/collect/testing/AbstractTester.java

     */
    @GwtCompatible(emulated = true)
    @ElementTypesAreNonnullByDefault
    public class AbstractTester<G> extends TestCase {
      private G subjectGenerator;
      private String suiteName;
      private @Nullable Runnable setUp;
      private @Nullable Runnable tearDown;
    
      // public so that it can be referenced in generated GWT tests.
      @Override
      public void setUp() throws Exception {
        if (setUp != null) {
          setUp.run();
        }
      }
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Feb 21 16:49:06 GMT 2024
    - 2.9K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/reflect/ReflectionTest.java

        assertEquals("java.util", Reflection.getPackageName(Map.Entry.class));
      }
    
      public void testNewProxy() throws Exception {
        Runnable runnable = Reflection.newProxy(Runnable.class, X_RETURNER);
        assertEquals("x", runnable.toString());
      }
    
      public void testNewProxyCantWorkOnAClass() throws Exception {
        assertThrows(
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 2.7K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/reflect/ReflectionTest.java

        assertEquals("java.util", Reflection.getPackageName(Map.Entry.class));
      }
    
      public void testNewProxy() throws Exception {
        Runnable runnable = Reflection.newProxy(Runnable.class, X_RETURNER);
        assertEquals("x", runnable.toString());
      }
    
      public void testNewProxyCantWorkOnAClass() throws Exception {
        assertThrows(
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 2.7K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/Callables.java

              boolean unused = trySetName(oldName, currentThread);
            }
          }
        };
      }
    
      /**
       * Wraps the given runnable such that for the duration of {@link Runnable#run} the thread that is
       * running with have the given name.
       *
       * @param task The Runnable to wrap
       * @param nameSupplier The supplier of thread names, {@link Supplier#get get} will be called once
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri May 12 18:32:03 GMT 2023
    - 4.4K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

       */
      protected ScheduledExecutorService executor() {
        @WeakOuter
        class ThreadFactoryImpl implements ThreadFactory {
          @Override
          public Thread newThread(Runnable runnable) {
            return MoreExecutors.newThread(serviceName(), runnable);
          }
        }
        final ScheduledExecutorService executor =
            Executors.newSingleThreadScheduledExecutor(new ThreadFactoryImpl());
    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/eventbus/AsyncEventBusTest.java

       * Executor Ever.
       *
       * @author cbiffle
       */
      public static class FakeExecutor implements Executor {
        List<Runnable> tasks = Lists.newArrayList();
    
        @Override
        public void execute(Runnable task) {
          tasks.add(task);
        }
    
        public List<Runnable> getTasks() {
          return tasks;
        }
      }
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Mon Dec 04 17:37:03 GMT 2017
    - 2.3K bytes
    - Viewed (0)
Back to top