Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 281 for runnable (0.17 sec)

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

                      + runnable
                      + " with executor "
                      + executor,
                  e);
        }
      }
    
      private static final class RunnableExecutorPair {
        final Runnable runnable;
        final Executor executor;
        @CheckForNull RunnableExecutorPair next;
    
        RunnableExecutorPair(
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 22 21:17:24 GMT 2024
    - 6.9K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

      enum WorkerRunningState {
        /** Runnable is not running and not queued for execution */
        IDLE,
        /** Runnable is not running, but is being queued for execution */
        QUEUING,
        /** runnable has been submitted but has not yet begun execution */
        QUEUED,
        RUNNING,
      }
    
      /** Underlying executor that all submitted Runnable objects are run on. */
      private final Executor 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)
  3. guava-testlib/src/com/google/common/collect/testing/FeatureSpecificTestSuiteBuilder.java

      }
    
      @CanIgnoreReturnValue
      public B withSetUp(Runnable setUp) {
        this.setUp = setUp;
        return self();
      }
    
      public Runnable getSetUp() {
        return setUp;
      }
    
      @CanIgnoreReturnValue
      public B withTearDown(Runnable tearDown) {
        this.tearDown = tearDown;
        return self();
      }
    
      public Runnable getTearDown() {
        return tearDown;
      }
    
      // Features
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Feb 26 19:46:10 GMT 2024
    - 10.2K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

       * otherwise-concurrent GC cycle.
       */
      private static final class TaskNonReentrantExecutor extends AtomicReference<RunningState>
          implements Executor, Runnable {
    
        /**
         * Used to update and read the latestTaskQueue field. Set to null once the runnable has been run
         * or queued.
         */
        @CheckForNull ExecutionSequencer sequencer;
    
        /**
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 22.1K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/MoreExecutors.java

       */
      @J2ktIncompatible
      @GwtIncompatible // concurrency
      static Thread newThread(String name, Runnable runnable) {
        checkNotNull(name);
        checkNotNull(runnable);
        // TODO(b/139726489): Confirm that null is impossible here.
        Thread result = requireNonNull(platformThreadFactory().newThread(runnable));
        try {
          result.setName(name);
        } catch (SecurityException e) {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Apr 17 16:33:44 GMT 2024
    - 41.8K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  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. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        Runnable cancelRunnable =
            new Runnable() {
              @Override
              public void run() {
                cancellationSuccess.set(currentFuture.get().cancel(true));
                awaitUnchecked(barrier);
              }
            };
        Runnable setFutureCompleteSuccessfullyRunnable =
            new Runnable() {
              @Override
              public void run() {
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 46.8K bytes
    - Viewed (0)
Back to top