Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 512 for Runnable (0.42 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java

      }
    
      public void testExceptionsCaught() {
        list.add(THROWING_RUNNABLE, directExecutor());
        list.execute();
        list.add(THROWING_RUNNABLE, directExecutor());
      }
    
      public void testNulls() {
        new NullPointerTester().testAllPublicInstanceMethods(new ExecutionList());
      }
    
      private static final Runnable THROWING_RUNNABLE =
          new Runnable() {
            @Override
            public void run() {
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Feb 09 22:57:07 GMT 2022
    - 4.7K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java

        }
    
        @Override
        public T call() throws Exception {
          return delegate.call();
        }
      }
    
      private static final class WrappedRunnable implements Runnable {
        private final Runnable delegate;
    
        public WrappedRunnable(Runnable delegate) {
          this.delegate = delegate;
        }
    
        @Override
        public void run() {
          delegate.run();
        }
      }
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Dec 16 19:54:45 GMT 2020
    - 7.6K bytes
    - Viewed (0)
  3. android/guava-testlib/test/com/google/common/testing/anotherpackage/ForwardingWrapperTesterTest.java

        tester.testForwarding(
            Runnable.class,
            new Function<Runnable, Runnable>() {
              @Override
              public Runnable apply(final Runnable runnable) {
                return new ForwardingRunnable(runnable);
              }
            });
      }
    
      public void testToStringForwarding() {
        tester.testForwarding(
            Runnable.class,
            new Function<Runnable, Runnable>() {
              @Override
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 15.7K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

        }
    
        @Override
        public T call() throws Exception {
          return delegate.call();
        }
      }
    
      private static final class WrappedRunnable implements Runnable {
        private final Runnable delegate;
    
        public WrappedRunnable(Runnable delegate) {
          this.delegate = delegate;
        }
    
        @Override
        public void run() {
          delegate.run();
        }
      }
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Jan 05 19:41:03 GMT 2023
    - 9.8K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        ThrowingRunnable runnable = new ThrowingRunnable(5, ex);
        future = service.scheduleAtFixedRate(runnable, 1, 1, TimeUnit.MILLISECONDS);
        assertExecutionException(future, ex);
        assertEquals(5, runnable.count);
        assertEquals(0, delegate.getQueue().size());
    
        runnable = new ThrowingRunnable(5, ex);
        future = service.scheduleWithFixedDelay(runnable, 1, 1, TimeUnit.MILLISECONDS);
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 28.2K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java

        }
    
        @Override
        public T call() throws Exception {
          return delegate.call();
        }
      }
    
      private static final class WrappedRunnable implements Runnable {
        private final Runnable delegate;
    
        public WrappedRunnable(Runnable delegate) {
          this.delegate = delegate;
        }
    
        @Override
        public void run() {
          delegate.run();
        }
      }
    
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Wed Dec 16 19:54:45 GMT 2020
    - 7.6K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/ListeningScheduledExecutorServiceTest.java

            Runnable command, long initialDelay, long delay, TimeUnit unit) {
          recordedCommand = command;
          recordedDelay = initialDelay;
          recordedInterval = delay;
          recordedTimeUnit = unit;
          return ImmediateScheduledFuture.of("scheduleWithFixedDelay");
        }
    
        @Override
        public void execute(Runnable runnable) {
          throw new UnsupportedOperationException();
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Mar 17 20:45:59 GMT 2020
    - 6.1K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/SimpleTimeLimiterTest.java

            }
          };
      private static final Runnable GOOD_RUNNABLE =
          new Runnable() {
            @Override
            public void run() {
              try {
                MILLISECONDS.sleep(DELAY_MS);
              } catch (InterruptedException e) {
                throw new RuntimeException(e);
              }
            }
          };
      private static final Runnable BAD_RUNNABLE =
          new Runnable() {
            @Override
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 9.5K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

        try {
          final SequentialExecutor executor = new SequentialExecutor(service);
          Runnable errorTask =
              new Runnable() {
                @Override
                public void run() {
                  throw new MyError();
                }
              };
          Runnable barrierTask =
              new Runnable() {
                @Override
                public void run() {
                  try {
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 11.4K bytes
    - Viewed (0)
  10. 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)
Back to top